executor

Documentation

Index

• type Config
• type DAGExecutor
  • func NewDAGExecutor[T any](ctx context.Context, d dag.DAG[T], cfg *Config[T]) (DAGExecutor, error)
• type ExecHandler
• type VertexResult

Types

type Config

type Config[T any] struct {
	Name    string
	From    string
	Handler ExecHandler[T]
}

type DAGExecutor

type DAGExecutor interface {
	Run(ctx context.Context) bool
}

func NewDAGExecutor

func NewDAGExecutor[T any](ctx context.Context, d dag.DAG[T], cfg *Config[T]) (DAGExecutor, error)

type ExecHandler

type ExecHandler[T any] interface {
	BlockRun(ctx context.Context, vertexName string, vertexContext T) bool
	PostRun(ctx context.Context, start, finish time.Time, success bool)
}

type VertexResult

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