exgraph

README

exgraph

Documentation

Index

• type Context
• type Executor
  • func NewExecutor() Executor
• type Graph
  • func NewGraph() Graph
• type Job
• type Task
• type TaskFunc

Types

type Context

type Context interface {
	Context() context.Context
}

type Executor

type Executor interface {
	Exec(ctx context.Context, dag Graph) error
}

func NewExecutor

func NewExecutor() Executor

type Graph

type Graph interface {
	Pipeline(tasks ...Task) *pipelineDSL
	Spawns(tasks ...Task) *spawnsDSL
	Exec(ctx context.Context) error
	Task
}

Graph represents directed acyclic graph

func NewGraph

func NewGraph() Graph

New creates new Graph

type Job

type Job struct {
	// contains filtered or unexported fields
}

Job - Each job consists of one or more tasks Each Job can runs tasks in order(Sequential) or unordered

type Task

type Task interface {
	Run(Context) error
}

type TaskFunc

type TaskFunc func(Context) error