driver

Documentation

Index

• func GetReadChannel(name string) (chan []byte, error)
• func GetSendChannel(name string, wg *sync.WaitGroup) (chan []byte, error)
• func NewStartRequest(path string, dir string, args ...string) *cmd.ControlMessage
• func RemoteExecute(leader string, agentName string, command *cmd.ControlMessage) error
• type DriverOption
• type FlowContextDriver
  • func NewFlowContextDriver(option *DriverOption) *FlowContextDriver
  • func (fcd *FlowContextDriver) IsDriverMode() bool
  • func (fcd *FlowContextDriver) Run(fc *flame.FlowContext)
• type NetworkContext
• type TaskOption
• type TaskRunner
  • func NewTaskRunner(option *TaskOption) *TaskRunner
  • func (tr *TaskRunner) IsTaskMode() bool
  • func (tr *TaskRunner) Run(fc *flame.FlowContext)

Functions

func GetReadChannel

func GetReadChannel(name string) (chan []byte, error)

func GetSendChannel

func GetSendChannel(name string, wg *sync.WaitGroup) (chan []byte, error)

func NewStartRequest

func NewStartRequest(path string, dir string, args ...string) *cmd.ControlMessage

func RemoteExecute

func RemoteExecute(leader string, agentName string, command *cmd.ControlMessage) error

Types

type DriverOption

type DriverOption struct {
	ShouldStart bool
	Leader      string
}

type FlowContextDriver

type FlowContextDriver struct {
	// contains filtered or unexported fields
}

func NewFlowContextDriver

func NewFlowContextDriver(option *DriverOption) *FlowContextDriver

func (*FlowContextDriver) IsDriverMode

func (fcd *FlowContextDriver) IsDriverMode() bool

func (*FlowContextDriver) Run

func (fcd *FlowContextDriver) Run(fc *flame.FlowContext)

driver runs on local, controlling all tasks

type NetworkContext

type NetworkContext struct {
	LeaderAddress string
	AgentPort     int
}

type TaskOption

type TaskOption struct {
	ContextId   int
	TaskGroupId int
}

type TaskRunner

type TaskRunner struct {
	Tasks []*flame.Task
	// contains filtered or unexported fields
}

func NewTaskRunner

func NewTaskRunner(option *TaskOption) *TaskRunner

func (*TaskRunner) IsTaskMode

func (tr *TaskRunner) IsTaskMode() bool

func (*TaskRunner) Run

func (tr *TaskRunner) Run(fc *flame.FlowContext)

if this should not run, return false