Documentation
¶
Overview ¶
Package executorcmd contains the gRPC client, as well as facilities for processing and committing incoming transition events.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExecutorCommand_Transition ¶
type ExecutorCommand_Transition struct {
controlcommands.MesosCommand_Transition
// contains filtered or unexported fields
}
func (*ExecutorCommand_Transition) Commit ¶
func (e *ExecutorCommand_Transition) Commit() (finalState string, err error)
func (*ExecutorCommand_Transition) PrepareResponse ¶
func (e *ExecutorCommand_Transition) PrepareResponse(err error, currentState string, taskId string) *controlcommands.MesosCommandResponse_Transition
type RpcClient ¶
type RpcClient struct {
pb.OccClient
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(controlPort uint64, controlMode controlmode.ControlMode) *RpcClient
func (*RpcClient) FromDeviceState ¶
func (*RpcClient) UnmarshalTransition ¶
func (r *RpcClient) UnmarshalTransition(data []byte) (cmd *ExecutorCommand_Transition, err error)
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package transitioner defines the Transitioner interface, as well as its implementations in order to translate between internal O² state machine states and events, and the states and events of some other process state machine (such as the FairMQ Device state machine).
|
Package transitioner defines the Transitioner interface, as well as its implementations in order to translate between internal O² state machine states and events, and the states and events of some other process state machine (such as the FairMQ Device state machine). |
Click to show internal directories.
Click to hide internal directories.