Documentation ¶
Index ¶
- type BasicResponse
- type Client
- func (c *Client) BlacklistNode(node string) (msg string, err error)
- func (c *Client) GetDeployedVersion() (version string, err error)
- func (c *Client) GetStatus() (status *StatusResponse, err error)
- func (c *Client) MigrateAllNodesToNewNodes() (msg string, err error)
- func (c *Client) MigrateNode(originNodeID, newNodeID string, shutdown bool) (msg string, err error)
- func (c *Client) MigrateShard(newNodeID string, shard int) (msg string, err error)
- func (c *Client) PullNewVersion() (newVersion string, err error)
- func (c *Client) ShutdownNode(nodeID string) (msg string, err error)
- func (c *Client) StartNewNode() (msg string, err error)
- func (c *Client) StopShard(shard int) (msg string, err error)
- type RESTAPI
- type StatusResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasicResponse ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) GetDeployedVersion ¶
func (*Client) GetStatus ¶
func (c *Client) GetStatus() (status *StatusResponse, err error)
func (*Client) MigrateAllNodesToNewNodes ¶
func (*Client) MigrateNode ¶
func (*Client) MigrateShard ¶
func (*Client) PullNewVersion ¶
func (*Client) StartNewNode ¶
type RESTAPI ¶
type RESTAPI struct {
// contains filtered or unexported fields
}
func NewRESTAPI ¶
func NewRESTAPI(orchestrator *orchestrator.Orchestrator, listenAddr string) *RESTAPI
type StatusResponse ¶
type StatusResponse struct {
Nodes []*orchestrator.NodeStatus
}
Click to show internal directories.
Click to hide internal directories.