loom

Jul 29, 2026

Changes in this version

+ type CheckpointEvent struct

+ GraphName string

+ RunID string

+ Seq int64

+ Stage CheckpointObservationStage

+ type CheckpointObservationStage string

+ const CheckpointLatestPutAfter

+ const CheckpointLatestPutBefore

+ type CheckpointObserver interface

+ ObserveCheckpoint func(context.Context, CheckpointEvent) error

type Graph

+ func (g *Graph) ResumeAtWithLifecycle(ctx context.Context, sourceRunID string, seq int64, allocatedRunID string, ...) (*RunResult, error)

+ func (g *Graph) ResumeWithLifecycle(ctx context.Context, runID string, input State, store Store, ...) (*RunResult, error)

+ func (g *Graph) RunWithLifecycle(ctx context.Context, input State, store Store, hooks LifecycleHooks) (*RunResult, error)

+ type LifecycleHooks struct

+ CheckpointObserver CheckpointObserver

+ ExecutionContext RunExecutionContext

+ RunAllocated RunAllocated

+ Terminalizer Terminalizer

+ type RunAllocated interface

+ RunAllocated func(context.Context, RunAllocationEvent) error

+ type RunAllocationEvent struct

+ GraphName string

+ ParentRunID string

+ ParentSeq int64

+ RunID string

+ State State

+ type RunExecutionContext interface

+ ExecutionContext func(context.Context, RunAllocationEvent) (context.Context, error)

+ type TerminalizationEvent struct

+ GraphName string

+ LastStep string

+ LatestCheckpointPersisted bool

+ LatestCheckpointSeq int64

+ RunID string

+ State State

+ StopReason StopReason

+ Yielded bool

+ type Terminalizer interface

+ Terminalize func(context.Context, TerminalizationEvent) error

Jul 22, 2026

Changes in this version

type Graph

+ func (g *Graph) Entry() string

+ func (g *Graph) StepNames() []string

Jul 22, 2026

Changes in this version

+ const CurrentCheckpointSchema

Jul 18, 2026

Changes in this version

+ type CheckpointInfo struct

+ LastStep string

+ SavedAt time.Time

+ Seq int64

+ YieldPhase string

type Graph

+ func (g *Graph) History(ctx context.Context, store Store, runID string) ([]CheckpointInfo, error)

+ func (g *Graph) ResumeAt(ctx context.Context, runID string, seq int64, input State, store Store) (*RunResult, error)

type GraphOption

+ func WithCheckpointHistory(keep int) GraphOption

Apr 15, 2026

Changes in this version

+ var ErrBudgetExhausted = errors.New("loom: global step budget exhausted")

+ var ErrCheckpointNotFound = errors.New("loom: checkpoint not found")

+ var ErrCorruptCheckpoint = errors.New("loom: corrupt checkpoint")

+ var ErrMaxIterations = errors.New("loom: max iterations exceeded")

+ var ErrNestedTx = errors.New("loom: nested transactions not supported")

+ var ErrStepNotFound = errors.New("loom: step not found")

+ type CheckpointPolicy int

+ const CheckpointBestEffort

+ const CheckpointRequired

+ type Edge struct

+ Label string

+ To string

+ type Graph struct

+ Name string

+ func NewGraph(name string, entry string, opts ...GraphOption) *Graph

+ func (g *Graph) AddStep(name string, step Step, after Router)

+ func (g *Graph) Resume(ctx context.Context, runID string, input State, store Store) (*RunResult, error)

+ func (g *Graph) Run(ctx context.Context, input State, store Store) (*RunResult, error)

+ func (g *Graph) SetHooks(h HookPoints)

+ func (g *Graph) SetTopology(topo []StepInfo)

+ func (g *Graph) Topology() []StepInfo

+ type GraphOption func(*Graph)

+ func WithCheckpointPolicy(p CheckpointPolicy) GraphOption

+ func WithMaxIterations(n int) GraphOption

+ func WithMergeConfig(cfg *MergeConfig) GraphOption

+ func WithStepBudget(n int64) GraphOption

+ type HookPoints struct

+ After []StepHook

+ Before []StepHook

+ type MemStore struct

+ func NewMemStore() *MemStore

+ func (s *MemStore) Delete(_ context.Context, ns, key string) error

+ func (s *MemStore) Get(_ context.Context, ns, key string) ([]byte, error)

+ func (s *MemStore) List(_ context.Context, ns, prefix string) ([]string, error)

+ func (s *MemStore) Put(_ context.Context, ns, key string, value []byte) error

+ func (s *MemStore) Tx(_ context.Context, fn func(Store) error) error

+ type MergeConfig struct

+ func DefaultMergeConfig() *MergeConfig

+ func NewMergeConfig() *MergeConfig

+ func (mc *MergeConfig) Register(key string, policy MergePolicy)

+ type MergePolicy func(existing, incoming any) any

+ var AppendSlice MergePolicy = func(existing, incoming any) any { ... }

+ var Overwrite MergePolicy = func(_, incoming any) any { ... }

+ var SumFloat MergePolicy = func(existing, incoming any) any { ... }

+ var SumInt MergePolicy = func(existing, incoming any) any { ... }

+ type Router func(ctx context.Context, state State) (string, error)

+ func Always(next string) Router

+ func Branch(key string, routes map[string]string, fallback string) Router

+ func BranchFunc(extract func(State) string, routes map[string]string, fallback string) Router

+ func Condition(pred func(State) bool, ifTrue, ifFalse string) Router

+ func End() Router

+ type RunResult struct

+ LastStep string

+ RunID string

+ State State

+ Steps int

+ StopReason StopReason

+ Yielded bool

+ type State map[string]any

+ func UnmarshalState(b []byte) (State, error)

+ func (s State) Marshal() ([]byte, error)

+ func (s State) Merge(update State, cfg *MergeConfig) State

+ type Step func(ctx context.Context, state State) (State, error)

+ type StepHook func(ctx context.Context, stepName string, state State) error

+ type StepInfo struct

+ Detail string

+ Edges []Edge

+ Name string

+ type StopReason string

+ const StopBudget

+ const StopCompleted

+ const StopError

+ const StopHookAbort

+ const StopMaxIter

+ const StopYielded

+ type Store interface

+ Delete func(ctx context.Context, ns string, key string) error

+ Get func(ctx context.Context, ns string, key string) ([]byte, error)

+ List func(ctx context.Context, ns string, prefix string) ([]string, error)

+ Put func(ctx context.Context, ns string, key string, value []byte) error

+ Tx func(ctx context.Context, fn func(Store) error) error