Documentation
¶
Index ¶
- func AssignTasks(state *lxstate.State, ...) error
- func DeregisterTaskProvider(state *lxstate.State, tpId string) error
- func GetNodes(state *lxstate.State) ([]*lxtypes.Node, error)
- func GetPendingTasks(state *lxstate.State) ([]*lxtypes.Task, error)
- func GetStagingTasks(state *lxstate.State) ([]*lxtypes.Task, error)
- func GetStatusUpdate(state *lxstate.State, taskId string) (*mesosproto.TaskStatus, error)
- func GetStatusUpdates(state *lxstate.State, tpId string) ([]*mesosproto.TaskStatus, error)
- func GetTaskProviders(state *lxstate.State) ([]*lxtypes.TaskProvider, error)
- func KillTask(state *lxstate.State, tpiUrl, taskProviderId, taskId string) error
- func MigrateTasks(state *lxstate.State, ...) error
- func ProcessStatusUpdate(state *lxstate.State, tpiUrl string, status *mesosproto.TaskStatus) error
- func PurgeTask(state *lxstate.State, taskId string) error
- func RegisterRpi(state *lxstate.State, rpiRegister layerx_rpi_client.RpiInfo) error
- func RegisterTaskProvider(state *lxstate.State, taskProvider *lxtypes.TaskProvider) error
- func RegisterTpi(state *lxstate.State, tpiUrl string) error
- func RescindResource(state *lxstate.State, resourceID string) error
- func SubmitResource(state *lxstate.State, resource *lxtypes.Resource) error
- func SubmitTask(state *lxstate.State, tpId string, task *lxtypes.Task) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AssignTasks ¶
func AssignTasks(state *lxstate.State, assignTasksMessage layerx_brain_client.BrainAssignTasksMessage) error
func GetStatusUpdate ¶
func GetStatusUpdate(state *lxstate.State, taskId string) (*mesosproto.TaskStatus, error)
func GetStatusUpdates ¶
func GetStatusUpdates(state *lxstate.State, tpId string) ([]*mesosproto.TaskStatus, error)
func GetTaskProviders ¶
func GetTaskProviders(state *lxstate.State) ([]*lxtypes.TaskProvider, error)
func MigrateTasks ¶
func MigrateTasks(state *lxstate.State, migrateTasksMessage layerx_brain_client.MigrateTaskMessage) error
func ProcessStatusUpdate ¶
func ProcessStatusUpdate(state *lxstate.State, tpiUrl string, status *mesosproto.TaskStatus) error
func RegisterRpi ¶
func RegisterRpi(state *lxstate.State, rpiRegister layerx_rpi_client.RpiInfo) error
func RegisterTaskProvider ¶
func RegisterTaskProvider(state *lxstate.State, taskProvider *lxtypes.TaskProvider) error
Types ¶
This section is empty.
Source Files
¶
- handle_assign_tasks.go
- handle_deregister_task_provider.go
- handle_get_nodes.go
- handle_get_pending_tasks.go
- handle_get_staging_tasks.go
- handle_get_status_update.go
- handle_get_status_updates.go
- handle_get_task_providers.go
- handle_kill_task.go
- handle_migrate_tasks.go
- handle_purge_task.go
- handle_register_rpi.go
- handle_register_task_provider.go
- handle_register_tpi.go
- handle_rescind_resource.go
- handle_submit_resource.go
- handle_submit_status_update.go
- handle_submit_task.go
Click to show internal directories.
Click to hide internal directories.