dag

Documentation

Index

• type DAG
  • func New() *DAG
  • func (d *DAG) Deferred(ctx context.Context) error
  • func (d DAG) Format() string
  • func (d *DAG) Report(r func(context.Context, NodeReport)) *DAG
  • func (d *DAG) Run(ctx context.Context) error
  • func (d *DAG) With(nodes []Node) error
• type Node
  • func Sub(name string, nodes []Node) []Node
• type NodeReport
• type Report
  • func (r Report) With(k string, v any) Report

Types

type DAG

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

func New

func New() *DAG

func (*DAG) Deferred

func (d *DAG) Deferred(ctx context.Context) error

func (DAG) Format

func (d DAG) Format() string

func (*DAG) Report

func (d *DAG) Report(r func(context.Context, NodeReport)) *DAG

func (*DAG) Run

func (d *DAG) Run(ctx context.Context) error

func (*DAG) With

func (d *DAG) With(nodes []Node) error

type Node

type Node struct {
	Name  string
	Wait  []chan struct{}
	Func  func(ctx context.Context, r Report) (Report, error)
	Defer func(ctx context.Context) error
	Done  chan struct{}
	// contains filtered or unexported fields
}

func Sub

func Sub(name string, nodes []Node) []Node

type NodeReport

type NodeReport struct {
	ID            string
	Name          string
	Sub           string
	Report        Report
	Duration      time.Duration
	TotalDuration time.Duration
}

type Report

type Report struct {
	Data map[string]any
}

func (Report) With

func (r Report) With(k string, v any) Report