executor

Documentation

Index

• type Executor
  • func NewExecutor(option *ExecutorOption, instructions *pb.InstructionSet) *Executor
  • func (exe *Executor) CollectExecutionStatistics(stream pb.GleamExecutor_CollectExecutionStatisticsServer) error
  • func (exe *Executor) ExecuteInstructionSet() error
• type ExecutorOption

Types

type Executor

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

func NewExecutor

func NewExecutor(option *ExecutorOption, instructions *pb.InstructionSet) *Executor

func (*Executor) CollectExecutionStatistics

func (exe *Executor) CollectExecutionStatistics(stream pb.GleamExecutor_CollectExecutionStatisticsServer) error

Collect stat from "gleam execute" started mapper reducer process

func (*Executor) ExecuteInstructionSet

func (exe *Executor) ExecuteInstructionSet() error

type ExecutorOption

type ExecutorOption struct {
	Dir          string
	AgentAddress string
	HashCode     uint32
}