workflow/client/client.go at 59331461d559552fd1daccefc6dee8cbfa80a1cf · drycc/workflow · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
package client

import (
	"errors"

	"github.com/deis/deisctl/backend"
	"github.com/deis/deisctl/backend/fleet"
	"github.com/deis/deisctl/cmd"
)

type DeisCtlClient interface {
	Config() error
	Install(targets []string) error
	Journal(targets []string) error
	List() error
	RefreshUnits() error
	Restart(targets []string) error
	Scale(targets []string) error
	Start(targets []string) error
	Status(targets []string) error
	Stop(targets []string) error
	Uninstall(targets []string) error
	Update() error
}

type Client struct {
	Backend backend.Backend
}

func NewClient(requestedBackend string) (*Client, error) {
	var backend backend.Backend

	if requestedBackend == "" {
		requestedBackend = "fleet"
	}

	switch requestedBackend {
	case "fleet":
		b, err := fleet.NewClient()
		if err != nil {
			return nil, err
		}
		backend = b
	default:
		return nil, errors.New("invalid backend")
	}
	return &Client{Backend: backend}, nil
}

func (c *Client) Config() error {
	return cmd.Config()
}

func (c *Client) Install(targets []string) error {
	return cmd.Install(c.Backend, targets)
}

func (c *Client) Journal(targets []string) error {
	return cmd.Journal(c.Backend, targets)
}

func (c *Client) List() error {
	return cmd.ListUnits(c.Backend)
}

func (c *Client) RefreshUnits() error {
	return cmd.RefreshUnits()
}

func (c *Client) Restart(targets []string) error {
	return cmd.Restart(c.Backend, targets)
}

func (c *Client) Scale(targets []string) error {
	return cmd.Scale(c.Backend, targets)
}

func (c *Client) Start(targets []string) error {
	return cmd.Start(c.Backend, targets)
}

func (c *Client) Status(targets []string) error {
	return cmd.Status(c.Backend, targets)
}

func (c *Client) Stop(targets []string) error {
	return cmd.Stop(c.Backend, targets)
}

func (c *Client) Uninstall(targets []string) error {
	return cmd.Uninstall(c.Backend, targets)
}

func (c *Client) Update() error {
	return cmd.Update()
}