driver

Documentation

Overview

Package driver coordinates distributed execution.

Package driver coordinates distributed execution.

Index

• type FlowContextDriver
  • func NewFlowContextDriver(option *Option) *FlowContextDriver
  • func (fcd *FlowContextDriver) GetTaskGroupStatus(taskGroup *plan.TaskGroup) *pb.FlowExecutionStatus_TaskGroup
  • func (fcd *FlowContextDriver) RunFlowContext(fc *flow.FlowContext)
• type Option

Types

type FlowContextDriver

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

func NewFlowContextDriver

func NewFlowContextDriver(option *Option) *FlowContextDriver

func (*FlowContextDriver) GetTaskGroupStatus

func (fcd *FlowContextDriver) GetTaskGroupStatus(taskGroup *plan.TaskGroup) *pb.FlowExecutionStatus_TaskGroup

func (*FlowContextDriver) RunFlowContext

func (fcd *FlowContextDriver) RunFlowContext(fc *flow.FlowContext)

driver runs on local, controlling all tasks

type Option

type Option struct {
	RequiredFiles []rsync.FileResource
	Master        string
	DataCenter    string
	Rack          string
	TaskMemoryMB  int
	FlowBid       float64
	Module        string
	Host          string
	Port          int
}