executor

Documentation

Index

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

Types

type Executor

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

func NewExecutor

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

func (*Executor) ExecuteInstructionSet

func (exe *Executor) ExecuteInstructionSet() error

type ExecutorOption

type ExecutorOption struct {
	Master       *string
	Host         *string
	Port         *int
	Dir          *string
	DataCenter   *string
	Rack         *string
	MaxExecutor  *int
	MemoryMB     *int64
	CPULevel     *int
	CleanRestart *bool
	HashCode     *uint32
}