layerx_rpi_client

Documentation

Index

• Constants
• type LaunchTasksMessage
• type LayerXRpi
  • func (rpi *LayerXRpi) GetNodes() ([]*lxtypes.Node, error)
  • func (rpi *LayerXRpi) RegisterRpi(name, rpiUrl string) error
  • func (rpi *LayerXRpi) RescindResource(resourceID string) error
  • func (rpi *LayerXRpi) SubmitResource(resource *lxtypes.Resource) error
  • func (rpi *LayerXRpi) SubmitStatusUpdate(status *mesosproto.TaskStatus) error
• type RpiInfo

Constants

const (
	RegisterRpi        = "/RegisterRpi"
	SubmitResource     = "/SubmitResource"
	RescindResource    = "/RescindResource"
	SubmitStatusUpdate = "/SubmitStatusUpdate"
	GetNodes           = "/GetNodes"
)

Types

type LaunchTasksMessage

type LaunchTasksMessage struct {
	TasksToLaunch  []*lxtypes.Task     `json:"tasks_to_launch"`
	ResourcesToUse []*lxtypes.Resource `json:"resources_to_use"`
}

type LayerXRpi

type LayerXRpi struct {
	CoreURL string
	RpiName string
}

func (*LayerXRpi) GetNodes

func (rpi *LayerXRpi) GetNodes() ([]*lxtypes.Node, error)

call this method to see submitted nodes and their resources + tasks call this to see tasks that the specific RPI should care about. useful for knowing what tasks we should get status updates for TODO: flip all these things so that it's always one-way (i.e. the RPI should always be told, never have to ask)

func (*LayerXRpi) RegisterRpi

func (rpi *LayerXRpi) RegisterRpi(name, rpiUrl string) error

call this method to register the RPI with layerx

func (*LayerXRpi) RescindResource

func (rpi *LayerXRpi) RescindResource(resourceID string) error

call this method if a resource has been rescinded or is no longer valid / available

func (*LayerXRpi) SubmitResource

func (rpi *LayerXRpi) SubmitResource(resource *lxtypes.Resource) error

call this method when submitting a new resource from the rpi

func (*LayerXRpi) SubmitStatusUpdate

func (rpi *LayerXRpi) SubmitStatusUpdate(status *mesosproto.TaskStatus) error

call this method when submitting a status update from the rpi

type RpiInfo

type RpiInfo struct {
	Name string `json:"name"`
	Url  string `json:"rpi_url"`
}