driver

Documentation

Overview

Package driver coordinates distributed execution.

Package driver coordinates distributed execution.

Index

• type FlowDriver
  • func NewFlowDriver(option *Option) *FlowDriver
  • func (fcd *FlowDriver) GetTaskGroupStatus(taskGroup *plan.TaskGroup) *pb.FlowExecutionStatus_TaskGroup
  • func (fcd *FlowDriver) RunFlowContext(parentCtx context.Context, fc *flow.Flow)
• type Option

Types

type FlowDriver

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

func NewFlowDriver

func NewFlowDriver(option *Option) *FlowDriver

func (*FlowDriver) GetTaskGroupStatus

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

func (*FlowDriver) RunFlowContext

func (fcd *FlowDriver) RunFlowContext(parentCtx context.Context, fc *flow.Flow)

driver runs on local, controlling all tasks

type Option

type Option struct {
	RequiredFiles []resource.FileResource
	Master        string
	DataCenter    string
	Rack          string
	TaskMemoryMB  int
	FlowBid       float64
	Module        string
	IsProfiling   bool
	BinaryPath    string
}