driver

package
v0.0.0-...-08a93fc Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2019 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package driver coordinates distributed execution.

Package driver coordinates distributed execution.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Source Files

View all Source files

Directories

Path Synopsis
Schedule tasks to run on available resources assigned by master.
 Schedule tasks to run on available resources assigned by master.
market

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.