goxecutor

README

goxecutor

The graph based task executor

Install

go get github.com/sand8080/goxecutor

Documentation

Index

• type ExecutionPolicy
• type ExecutionStatus
• type Graph
• type Task
• type TrnLogStorage

Types

type ExecutionPolicy

type ExecutionPolicy string

ExecutionPolicy defines graph execution policy

const (
	PolicyRevertOnError ExecutionPolicy = "REVERT_ON_ERROR"
	PolicyFailOnError   ExecutionPolicy = "FAIL_ON_ERROR"
	PolicyIgnoreError   ExecutionPolicy = "IGNORE_ERROR"
)

type ExecutionStatus

type ExecutionStatus string

ExecutionStatus graph execution status

const (
	// StatusSuccess graph executed successfully
	StatusSuccess ExecutionStatus = "SUCCESS"
	// StatusError graph executed with error
	StatusError ExecutionStatus = "ERROR"
	// StatusCancelled graph execution cancelled
	StatusCancelled ExecutionStatus = "CANCELLED"
)

type Graph

type Graph interface {
	Add(task *Task) error
	Check() error
	Exec(ctx context.Context, policy ExecutionPolicy, storage TrnLogStorage) (ExecutionStatus, error)
}

type Task

type Task interface {
}

type TrnLogStorage

type TrnLogStorage interface {
}