dag

Sep 15, 2026

Changes in this version

+ func Suspend(reason string, payload any) error

+ type SuspendError struct

+ Payload any

+ Reason string

+ func (e *SuspendError) Error() string

+ func (e *SuspendError) Is(target error) bool

Sep 15, 2026

Changes in this version

+ func WithLayerCallback(ctx context.Context, fn LayerCallback) context.Context

+ type ExecutionError struct

+ Cause error

+ Completed []string

+ FailedNode string

+ Layer int

+ State *State

+ func (e *ExecutionError) Error() string

+ func (e *ExecutionError) Unwrap() error

+ type LayerCallback func(ctx context.Context, layer int, state *State) error

+ func LayerCallbackFromCtx(ctx context.Context) LayerCallback

Sep 8, 2026

Changes in this version

+ var ErrSuspended = errors.New("graph: execution suspended for human intervention")

Sep 3, 2026

Changes in this version

type DAG

+ func (d *DAG) Name() string

Sep 3, 2026

Changes in this version

type DAG

+ func (d *DAG) ToMermaid() string

Aug 30, 2026

Changes in this version

+ var GlobalTopology = &TopologyRegistry

+ func GetNodeOutput[T any](state *State, nodeID string) (T, error)

+ func OutputKey(nodeID string) string

+ type Builder struct

+ func New(name string) *Builder

+ func (b *Builder) AddEdge(from, to string) *Builder

+ func (b *Builder) AddNode(id string, _ string, act action.AnyAction) *Builder

+ func (b *Builder) Compile() (*DAG, error)

+ type DAG struct

+ func (d *DAG) AsAction() *action.Builder[*State, *State]

+ func (d *DAG) Execute(ctx context.Context, initialState *State) (*State, error)

+ type Edge struct

+ From string

+ To string

+ type EdgeMeta struct

+ Channel string

+ From string

+ Protocol string

+ To string

+ type Node struct

+ Action action.Executable

+ ID string

+ OutputKey string

+ type NodeContext struct

+ Input *State

+ Key string

+ type State struct

+ func AcquireState() *State

+ func (s *State) Clone() *State

+ func (s *State) CopyFrom(src *State)

+ func (s *State) Data() map[string]any

+ func (s *State) Get(key string) (any, bool)

+ func (s *State) Release()

+ func (s *State) Set(key string, val any)

+ type TopologyRegistry struct

+ func (t *TopologyRegistry) Register(from, to, channel, protocol string)

+ func (t *TopologyRegistry) ToMermaid() string

+ type Value struct

+ Key string

+ Val any