Versions in this module Expand all Collapse all v0 v0.1.0 Aug 20, 2026 Changes in this version + const EndNodeRef + func LoadGraphDefinitionFile(path string) (dsl.GraphDefinition, error) + func NewGraphRunner(targetGraph *Graph, executionStore fruntime.ExecutionStore, ...) (*fruntime.GraphRunner, error) + func SetLogger(l *zap.Logger) + type Builder struct + func NewBuilder(reg *registry.Registry) *Builder + func (builder *Builder) Build(def dsl.GraphDefinition, ctx *registry.BuildContext) (*Graph, error) + func (builder *Builder) BuildFile(path string, ctx *registry.BuildContext) (*Graph, error) + func (builder *Builder) BuildInstance(def dsl.GraphDefinition, instance dsl.GraphInstanceConfig, ...) (*Graph, error) + type ConditionError struct + ConditionID string + ConditionType string + Err error + SourceNodeID string + StatePaths []string + TargetNodeID string + func (conditionErr *ConditionError) Class() core.ErrorClass + func (conditionErr *ConditionError) Details() map[string]any + func (conditionErr *ConditionError) Error() string + func (conditionErr *ConditionError) RetryAfter() time.Duration + func (conditionErr *ConditionError) Unwrap() error + type Graph struct + func NewGraph(reg *registry.Registry) *Graph + func (g *Graph) AddConditionalEdge(from, to string, condition registry.EdgeCondition) error + func (g *Graph) AddEdge(from, to string) error + func (g *Graph) AddFailureRoute(from, to string, route dsl.FailureRouteSpec) error + func (g *Graph) AddNode(targetNode core.Node) error + func (g *Graph) AddResolvedConditionalEdge(from, to string, condition registry.EdgeCondition, contract state.Contract) error + func (g *Graph) Compile() (*Runnable, error) + func (g *Graph) ContractDiagnostics() []core.ContractDiagnostic + func (g *Graph) Definition() (dsl.GraphDefinition, error) + func (g *Graph) DrawMermaid() (string, error) + func (g *Graph) ExecutionPolicy() fruntime.GraphExecutionPolicy + func (g *Graph) InitialStateRequirements() core.InitialStateRequirements + func (g *Graph) InitialStateRequirementsFor(provider *core.EntryStateProvider) core.InitialStateRequirements + func (g *Graph) NodeSpecs() map[string]dsl.GraphNodeSpec + func (g *Graph) Run(ctx context.Context, initialState *state.State) (*state.State, error) + func (g *Graph) SemanticHash() (string, error) + func (g *Graph) SetEntryPoint(ref string) error + func (g *Graph) SetExecutionPolicy(policy fruntime.GraphExecutionPolicy) error + func (g *Graph) SetFinishPoint(ref string) error + func (g *Graph) SetNodeExecutionPolicy(nodeID string, policy fruntime.ExecutionPolicy) error + func (g *Graph) SetNodeSpec(spec dsl.GraphNodeSpec) error + func (g *Graph) SnapshotHash() (string, error) + func (g *Graph) Validate() error + func (g *Graph) ValidateInitialState(initial *state.State) error + func (g *Graph) WriteToFile(path string) error + type NodeEvent string + const EventChainEnd + const EventChainStart + const EventNodeComplete + const EventNodeError + const EventNodeStart + type Runnable struct + func (r *Runnable) Invoke(ctx context.Context, initialState *state.State) (*state.State, error) + func (r *Runnable) InvokeWithConfig(ctx context.Context, initialState *state.State, ...) (*state.State, error) + func (r *Runnable) Stream(ctx context.Context, initialState *state.State) <-chan StreamEvent + type StreamEvent struct + Duration time.Duration + Error error + Event NodeEvent + NodeName string + State *state.State + Timestamp time.Time
Go to main page