taskflow

package module
v0.0.0-...-0c4a1ff Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 18, 2023 License: MIT Imports: 8 Imported by: 0

README

taskflow

temporal DAG

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterActivityFunc

func RegisterActivityFunc(activityName string, activity ActivityFunc)

func Workflow

func Workflow(ctx workflow.Context, flow entity.Flow) error

Types

type ActivityFunc

type ActivityFunc func(ctx context.Context, taskParams map[string]map[string]interface{}) (map[string]interface{},
	error)

type DAG

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

func NewDAG

func NewDAG(ctx workflow.Context, flow entity.Flow) (*DAG, error)

func (*DAG) Schedule

func (d *DAG) Schedule(ctx workflow.Context) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL