driver

package
Version: v0.0.0-...-4413804 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 14, 2015 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Directories

Path Synopsis
Package cmd is a generated protocol buffer package.
Package cmd is a generated protocol buffer package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL