clusters

Documentation

Index

• func GetIndex() int
• func NewRunnerV2(data, mapper maps.Mapper, executor Executor, setting *Settings) *runners.Runner
• type Executor
• type ExecutorParameter
• type Settings

Functions

func GetIndex

func GetIndex() int

func NewRunnerV2

func NewRunnerV2(data, mapper maps.Mapper, executor Executor, setting *Settings) *runners.Runner

Types

type Executor

type Executor func(p *ExecutorParameter) error

type ExecutorParameter

type ExecutorParameter struct {
	// Executor index, this always unique
	Index int

	// Name of the executor
	Name string

	// type of current executor
	Type string

	// whole configuration mapper
	Config maps.Mapper

	// generator data
	Data maps.Mapper

	// fs configuration
	VarConfig maps.Mapper

	// helper for logging message
	Logger *loggers.Logger
}

type Settings

type Settings struct {
	DefaultWithCluster bool
}