rest

README

Simple REST api for interacting with the orchestrator.

This is NOT how nodes communicate with it and is entirely optional.

Documentation

Index

• type BasicResponse
• type Client
  • func NewClient(addr string) *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
  • func NewRESTAPI(orchestrator *orchestrator.Orchestrator, listenAddr string) *RESTAPI
  • func (ra *RESTAPI) Run() error
• type StatusResponse

Types

type BasicResponse

type BasicResponse struct {
	Message string
	Error   bool
}

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(addr string) *Client

func (*Client) BlacklistNode

func (c *Client) BlacklistNode(node string) (msg string, err error)

func (*Client) GetDeployedVersion

func (c *Client) GetDeployedVersion() (version string, err error)

func (*Client) GetStatus

func (c *Client) GetStatus() (status *StatusResponse, err error)

func (*Client) MigrateAllNodesToNewNodes

func (c *Client) MigrateAllNodesToNewNodes() (msg string, err error)

func (*Client) MigrateNode

func (c *Client) MigrateNode(originNodeID, newNodeID string, shutdown bool) (msg string, err error)

func (*Client) MigrateShard

func (c *Client) MigrateShard(newNodeID string, shard int) (msg string, err error)

func (*Client) PullNewVersion

func (c *Client) PullNewVersion() (newVersion string, err error)

func (*Client) ShutdownNode

func (c *Client) ShutdownNode(nodeID string) (msg string, err error)

func (*Client) StartNewNode

func (c *Client) StartNewNode() (msg string, err error)

func (*Client) StopShard

func (c *Client) StopShard(shard int) (msg string, err error)

type RESTAPI

type RESTAPI struct {
	// contains filtered or unexported fields
}

func NewRESTAPI

func NewRESTAPI(orchestrator *orchestrator.Orchestrator, listenAddr string) *RESTAPI

func (*RESTAPI) Run

func (ra *RESTAPI) Run() error

type StatusResponse

type StatusResponse struct {
	Nodes []*orchestrator.NodeStatus
}