layerx_brain_client

Documentation

Index

• Constants
• type BrainAssignTasksMessage
• type LayerXBrainClient
  • func (brainClient *LayerXBrainClient) AssignTasks(nodeId string, taskIds ...string) error
  • func (brainClient *LayerXBrainClient) GetNodes() ([]*lxtypes.Node, error)
  • func (brainClient *LayerXBrainClient) GetPendingTasks() ([]*lxtypes.Task, error)
  • func (brainClient *LayerXBrainClient) GetStagingTasks() ([]*lxtypes.Task, error)
  • func (brainClient *LayerXBrainClient) GetStatusUpdates() ([]*mesosproto.TaskStatus, error)
  • func (brainClient *LayerXBrainClient) MigrateTasks(destinationNodeId string, taskIds ...string) error
• type MigrateTaskMessage

Constants

const (
	GetPendingTasks  = "/GetPendingTasks"
	GetStagingTasks  = "/GetStagingTasks"
	GetNodes         = "/GetNodes"
	GetStatusUpdates = "/GetStatusUpdates"
	AssignTasks      = "/AssignTasks"
	MigrateTasks     = "/MigrateTasks"
)

Types

type BrainAssignTasksMessage

type BrainAssignTasksMessage struct {
	NodeId  string   `json:"node_id"`
	TaskIds []string `json:"task_ids"`
}

type LayerXBrainClient

type LayerXBrainClient struct {
	CoreURL string
}

func (*LayerXBrainClient) AssignTasks

func (brainClient *LayerXBrainClient) AssignTasks(nodeId string, taskIds ...string) error

call this method to assign tasks to a node

func (*LayerXBrainClient) GetNodes

func (brainClient *LayerXBrainClient) GetNodes() ([]*lxtypes.Node, error)

call this method to see submitted nodes and their resources

func (*LayerXBrainClient) GetPendingTasks

func (brainClient *LayerXBrainClient) GetPendingTasks() ([]*lxtypes.Task, error)

call this method to see unassigned tasks

func (*LayerXBrainClient) GetStagingTasks

func (brainClient *LayerXBrainClient) GetStagingTasks() ([]*lxtypes.Task, error)

call this method to see unassigned tasks

func (*LayerXBrainClient) GetStatusUpdates

func (brainClient *LayerXBrainClient) GetStatusUpdates() ([]*mesosproto.TaskStatus, error)

call this method to see most recent status updates for all tasks

func (*LayerXBrainClient) MigrateTasks

func (brainClient *LayerXBrainClient) MigrateTasks(destinationNodeId string, taskIds ...string) error

call this method to migrate running tasks from one node to another

type MigrateTaskMessage

type MigrateTaskMessage struct {
	DestinationNodeId string   `json:"destination_node_id"`
	TaskIds           []string `json:"task_ids"`
}