controlcommands

type Call struct {
	Request  MesosCommand
	Response MesosCommandResponse
	Done     chan empty
	Error    error
}

type CallId struct {
	Id     xid.ID
	Target MesosCommandTarget
}

type Command interface {
	Name() string
	Args() map[string]interface{}
	IsMultiCmd() bool
	IsMutator() bool
}

type CommandQueue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type MesosCommand interface {
	common.Labeler
	GetName() string
	GetId() xid.ID
	GetEnvironmentId() uid.ID
	IsMultiCmd() bool
	MakeSingleTarget(target MesosCommandTarget) MesosCommand
	IsMutator() bool
	GetResponseTimeout() time.Duration
	// contains filtered or unexported methods
}

type MesosCommandBase struct {
	Name            string               `json:"name"`
	Id              xid.ID               `json:"id"`
	EnvironmentId   uid.ID               `json:"environmentId"`
	ResponseTimeout time.Duration        `json:"timeout"`
	Arguments       PropertyMap          `json:"arguments"`
	TargetList      []MesosCommandTarget `json:"targetList"`
	Labels          map[string]string    `json:"labels"`
	// contains filtered or unexported fields
}

type MesosCommandMultiResponse struct {
	MesosCommandResponseBase
	// contains filtered or unexported fields
}

type MesosCommandResponse interface {
	GetCommandName() string
	GetCommandId() xid.ID
	GetEnvironmentId() uid.ID
	GetResponseSenders() []MesosCommandTarget
	IsMultiResponse() bool
	Err() error
	Errors() map[MesosCommandTarget]error
}

type MesosCommandResponseBase struct {
	CommandName     string               `json:"name"`
	CommandId       xid.ID               `json:"id"`
	EnvironmentId   uid.ID               `json:"environmentId"`
	ErrorString     string               `json:"error"`
	MessageType     string               `json:"_messageType"`
	ResponseSenders []MesosCommandTarget `json:"-"`
}

type MesosCommandResponse_Transition struct {
	MesosCommandResponseBase

	CurrentState string `json:"state"`
	TaskId       string `json:"taskId"`
}

type MesosCommandResponse_TriggerHook struct {
	MesosCommandResponseBase
	TaskId string `json:"taskId"`
}

type MesosCommandTarget struct {
	AgentId    mesos.AgentID
	ExecutorId mesos.ExecutorID
	TaskId     mesos.TaskID
}

type MesosCommand_Transition struct {
	MesosCommandBase

	Source      string `json:"source"`
	Event       string `json:"event"`
	Destination string `json:"destination"`
}

type MesosCommand_TriggerHook struct {
	MesosCommandBase
}

type PropertyMap map[string]string

type PropertyMapsMap map[MesosCommandTarget]PropertyMap

type SendCommandFunc func(command MesosCommand, receiver MesosCommandTarget) error

type Servent struct {
	SendFunc SendCommandFunc
	// contains filtered or unexported fields
}