dag

Documentation

Index

• func GetResult(ctx context.Context) (r map[string]string)
• func SetResult(ctx context.Context, r map[string]string) context.Context
• func SetResultKV(ctx context.Context, k, v string) context.Context
• type Graph
  • func New() *Graph
  • func NewJson(buf []byte) *Graph
  • func (s *Graph) AddEdge(from, to string)
  • func (s *Graph) AddNode(name, propmt string)
  • func (s *Graph) IsEmpty() bool
  • func (s *Graph) Run(ctx context.Context, f func(context.Context, string, string) error) (e error)
• type GraphNode

Functions

func GetResult

func GetResult(ctx context.Context) (r map[string]string)

func SetResult

func SetResult(ctx context.Context, r map[string]string) context.Context

func SetResultKV

func SetResultKV(ctx context.Context, k, v string) context.Context

Types

type Graph

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

func New

func New() *Graph

func NewJson

func NewJson(buf []byte) *Graph

func (*Graph) AddEdge

func (s *Graph) AddEdge(from, to string)

func (*Graph) AddNode

func (s *Graph) AddNode(name, propmt string)

func (*Graph) IsEmpty

func (s *Graph) IsEmpty() bool

func (*Graph) Run

func (s *Graph) Run(ctx context.Context, f func(context.Context, string, string) error) (e error)

type GraphNode

type GraphNode struct {
	Name  string   `json:"name"`
	Input string   `json:"input"`
	After []string `json:"after"`
}