executorcmd

Documentation

Overview

Package executorcmd contains the gRPC client, as well as facilities for processing and committing incoming transition events.

Index

• Constants
• type ControlTransport
• type ExecutorCommand_Transition
  • func NewLocalExecutorCommand_Transition(transitioner transitioner.Transitioner, ...) *ExecutorCommand_Transition
  • func (e *ExecutorCommand_Transition) Commit() (finalState string, err error)
  • func (e *ExecutorCommand_Transition) PrepareResponse(err error, currentState string, taskId string) *controlcommands.MesosCommandResponse_Transition
• type RpcClient
  • func NewClient(controlPort uint64, controlMode controlmode.ControlMode, ...) *RpcClient
  • func (r *RpcClient) Close() error
  • func (r *RpcClient) FromDeviceState(state string) string

Constants

const (
	ProtobufTransport = ControlTransport(0)
	JsonTransport     = ControlTransport(1)
)

const GRPC_DIAL_TIMEOUT = 30 * time.Second

Types

type ControlTransport

type ControlTransport uint32

type ExecutorCommand_Transition

type ExecutorCommand_Transition struct {
	controlcommands.MesosCommand_Transition

	Transitioner transitioner.Transitioner
}

func NewLocalExecutorCommand_Transition

func NewLocalExecutorCommand_Transition(transitioner transitioner.Transitioner, receivers []controlcommands.MesosCommandTarget, source string, event string, destination string, arguments controlcommands.PropertyMapsMap) *ExecutorCommand_Transition

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

	Transitioner transitioner.Transitioner
	TaskCmd      *exec.Cmd
	// contains filtered or unexported fields
}

func NewClient

func NewClient(
	controlPort uint64,
	controlMode controlmode.ControlMode,
	controlTransport ControlTransport,
	log *logrus.Entry,
) *RpcClient

func (*RpcClient) Close

func (r *RpcClient) Close() error

func (*RpcClient) FromDeviceState

func (r *RpcClient) FromDeviceState(state string) string