controlcommands

Aug 15, 2022

Changes in this version

type MesosCommandBase

+ Labels map[string]string

+ func (m *MesosCommandBase) GetLabels() map[string]string

Aug 1, 2022

Changes in this version

type MesosCommand

+ GetEnvironmentId func() uid.ID

type MesosCommandBase

+ EnvironmentId uid.ID

+ func (m *MesosCommandBase) GetEnvironmentId() uid.ID

type MesosCommandResponse

+ GetEnvironmentId func() uid.ID

type MesosCommandResponseBase

+ EnvironmentId uid.ID

+ func (m *MesosCommandResponseBase) GetEnvironmentId() uid.ID

Oct 6, 2021

Changes in this version

type MesosCommandMultiResponse

+ func (m *MesosCommandMultiResponse) Errors() map[MesosCommandTarget]error

+ func (m *MesosCommandMultiResponse) GetResponseSenders() []MesosCommandTarget

type MesosCommandResponse

+ Errors func() map[MesosCommandTarget]error

+ GetResponseSenders func() []MesosCommandTarget

type MesosCommandResponseBase

+ ResponseSenders []MesosCommandTarget

+ func (m *MesosCommandResponseBase) Errors() map[MesosCommandTarget]error

+ func (m *MesosCommandResponseBase) GetResponseSenders() []MesosCommandTarget

Aug 20, 2020

Changes in this version

+ type MesosCommandResponse_TriggerHook struct

+ TaskId string

+ func NewMesosCommandResponse_TriggerHook(mesosCommand *MesosCommand_TriggerHook, err error, taskId string) *MesosCommandResponse_TriggerHook

+ type MesosCommand_TriggerHook struct

+ func NewMesosCommand_TriggerHook(receivers []MesosCommandTarget) *MesosCommand_TriggerHook

+ func (m *MesosCommand_TriggerHook) MakeSingleTarget(target MesosCommandTarget) (cmd MesosCommand)

Mar 12, 2019

Changes in this version

+ const QUEUE_SIZE

+ type Call struct

+ Done chan empty

+ Error error

+ Request MesosCommand

+ Response MesosCommandResponse

+ func NewCall(cmd MesosCommand) *Call

+ type CallId struct

+ Id uuid.Array

+ Target MesosCommandTarget

+ type Command interface

+ Args func() map[string]interface{}

+ IsMultiCmd func() bool

+ IsMutator func() bool

+ Name func() string

+ type CommandQueue struct

+ func NewCommandQueue(s *Servent) *CommandQueue

+ func (m *CommandQueue) Enqueue(cmd MesosCommand, callback chan<- MesosCommandResponse) error

+ func (m *CommandQueue) Start()

+ func (m *CommandQueue) Stop()

+ type MesosCommand interface

+ GetId func() uuid.Array

+ GetName func() string

+ GetResponseTimeout func() time.Duration

+ IsMultiCmd func() bool

+ IsMutator func() bool

+ MakeSingleTarget func(target MesosCommandTarget) MesosCommand

+ type MesosCommandBase struct

+ Arguments PropertyMap

+ Id uuid.Array

+ Name string

+ ResponseTimeout time.Duration

+ TargetList []MesosCommandTarget

+ func NewMesosCommand(name string, receivers []MesosCommandTarget, argMap PropertyMapsMap) *MesosCommandBase

+ func (m *MesosCommandBase) GetId() uuid.Array

+ func (m *MesosCommandBase) GetName() string

+ func (m *MesosCommandBase) GetResponseTimeout() time.Duration

+ func (m *MesosCommandBase) IsMultiCmd() bool

+ func (m *MesosCommandBase) IsMutator() bool

+ func (m *MesosCommandBase) MakeSingleTarget(receiver MesosCommandTarget) (cmd MesosCommand)

+ type MesosCommandMultiResponse struct

+ func (m *MesosCommandMultiResponse) Err() error

+ func (m *MesosCommandMultiResponse) GetResponses() map[MesosCommandTarget]MesosCommandResponse

+ func (m *MesosCommandMultiResponse) IsMultiResponse() bool

+ type MesosCommandResponse interface

+ Err func() error

+ GetCommandId func() uuid.Array

+ GetCommandName func() string

+ IsMultiResponse func() bool

+ type MesosCommandResponseBase struct

+ CommandId uuid.Array

+ CommandName string

+ ErrorString string

+ MessageType string

+ func NewMesosCommandResponse(mesosCommand MesosCommand, err error) *MesosCommandResponseBase

+ func (m *MesosCommandResponseBase) Err() error

+ func (m *MesosCommandResponseBase) GetCommandId() uuid.Array

+ func (m *MesosCommandResponseBase) GetCommandName() string

+ func (m *MesosCommandResponseBase) IsMultiResponse() bool

+ type MesosCommandResponse_Transition struct

+ CurrentState string

+ TaskId string

+ func NewMesosCommandResponse_Transition(mesosCommand *MesosCommand_Transition, err error, currentState string, ...) *MesosCommandResponse_Transition

+ type MesosCommandTarget struct

+ AgentId mesos.AgentID

+ ExecutorId mesos.ExecutorID

+ TaskId mesos.TaskID

+ type MesosCommand_Transition struct

+ Destination string

+ Event string

+ Source string

+ func NewMesosCommand_Transition(receivers []MesosCommandTarget, source string, event string, ...) *MesosCommand_Transition

+ func (m *MesosCommand_Transition) MakeSingleTarget(target MesosCommandTarget) (cmd MesosCommand)

+ type PropertyMap map[string]string

+ type PropertyMapsMap map[MesosCommandTarget]PropertyMap

+ type SendCommandFunc func(command MesosCommand, receiver MesosCommandTarget) error

+ type Servent struct

+ SendFunc SendCommandFunc

+ func NewServent(commandFunc SendCommandFunc) *Servent

+ func (s *Servent) ProcessResponse(res MesosCommandResponse, sender MesosCommandTarget)

+ func (s *Servent) RunCommand(cmd MesosCommand, receiver MesosCommandTarget) (MesosCommandResponse, error)