executor

Documentation

Index

• type Config
• type ExecPostRunFn
• type Executor
  • func New(d dag.DAG, cfg *Config) Executor
• type VertexFuntionRunFn
• type VertexResult

Types

type Config

type Config struct {
	Name string
	From string
	//Handlers
	VertexFuntionRunFn VertexFuntionRunFn
	ExecPostRunFn      ExecPostRunFn
}

type ExecPostRunFn

type ExecPostRunFn func(start, finish time.Time, success bool)

type Executor

type Executor interface {
	Run(ctx context.Context)
}

func New

func New(d dag.DAG, cfg *Config) Executor

type VertexFuntionRunFn

type VertexFuntionRunFn func(ctx context.Context, vertexName string, vertexContext any) bool

type VertexResult

type VertexResult struct {
	Start   time.Time
	Finish  time.Time
	Success bool
	Reason  string
	Input   any
	Output  any
}