Versions in this module Expand all Collapse all v0 v0.1.0 Aug 20, 2026 Changes in this version + const DebugBreakpointAfterNode + const DebugBreakpointBeforeNode + const EndNodeRef + const GraphDefinitionVersion + const GraphInstanceConfigVersion + const RunRequestVersion + func SemanticGraphHash(def GraphDefinition) (string, error) + func SemanticGraphHashWithStateBindings(def GraphDefinition, bindings []StateBindingSemantic) (string, error) + func SerializeGraphInstanceConfig(cfg GraphInstanceConfig) ([]byte, error) + func SerializeRunRequest(req RunRequest) ([]byte, error) + func SnapshotGraphHash(def GraphDefinition) (string, error) + type ConditionSchema struct + ConfigSchema JSONSchema + Description string + DynamicStatePorts *DynamicStatePortDefinition + StatePorts []StatePortDefinition + Title string + Type string + type DebugBreakpoint struct + Enabled *bool + ID string + NodeID string + Stage string + func (b DebugBreakpoint) Effective() DebugBreakpoint + func (b DebugBreakpoint) Validate() error + type DynamicStatePortDefinition struct + Description string + MaxPorts int + MergeStrategy StateMergeStrategy + MinPorts int + Mode StateAccessMode + NamePattern string + Reducer string + Required bool + Schema JSONSchema + type ExecutionPolicy struct + MaxConcurrency int + Retry *RetryPolicy + Timeout string + type FailureRouteSpec struct + CatchAll bool + ErrorClasses []string + Stages []FailureStage + func (route *FailureRouteSpec) Validate() error + type FailureStage string + const FailureStageCondition + const FailureStageNode + type GraphConditionSpec struct + Config map[string]any + ID string + State map[string]StateBinding + Type string + func CloneGraphConditionSpec(spec GraphConditionSpec) GraphConditionSpec + func NormalizeGraphConditionSpec(spec GraphConditionSpec) GraphConditionSpec + type GraphDefinition struct + Description string + Edges []GraphEdgeSpec + EntryPoint string + FinishPoint string + Metadata map[string]any + Name string + Nodes []GraphNodeSpec + Policy *GraphExecutionPolicy + StateModules []StateModuleRef + Version string + func DeserializeGraphDefinition(data []byte) (GraphDefinition, error) + func NormalizeGraphDefinition(def GraphDefinition) GraphDefinition + func (d GraphDefinition) Serialize() ([]byte, error) + func (d GraphDefinition) Validate() error + type GraphEdgeSpec struct + Condition *GraphConditionSpec + Failure *FailureRouteSpec + From string + To string + type GraphExecutionPolicy struct + Limits GraphLimits + NodeDefaults ExecutionPolicy + type GraphInstanceConfig struct + Description string + GraphRef string + GraphVersion string + ID string + Metadata map[string]any + Name string + NodeConfigs map[string]GraphNodeInstanceConfig + Secrets map[string]SecretRef + Version string + func DeserializeGraphInstanceConfig(data []byte) (GraphInstanceConfig, error) + func (c GraphInstanceConfig) Validate() error + type GraphLimits struct + MaxConcurrentNodes int + MaxConcurrentRuns int + MaxConcurrentTools int + MaxFanOut int + MaxNodeExecutions int + MaxStateBytes int64 + MaxSuperSteps int + MaxWallTime string + type GraphNodeInstanceConfig struct + Config map[string]any + Disabled bool + Metadata map[string]any + Secrets map[string]SecretRef + func (c GraphNodeInstanceConfig) Validate(nodeID string) error + type GraphNodeSpec struct + Config map[string]any + Description string + ID string + Name string + Policy *ExecutionPolicy + State map[string]StateBinding + Type string + type GraphNodeSpecProvider interface + GraphNodeSpec func() GraphNodeSpec + type JSONSchema map[string]any + func BuildGraphDefinitionSchema(stateModules map[string]StateModuleDefinition, ...) JSONSchema + func (r JSONSchema) WriteToFile(path string) error + func (s JSONSchema) Clone() JSONSchema + type NodeTypeSchema struct + ConfigSchema JSONSchema + Description string + DynamicStatePorts *DynamicStatePortDefinition + StatePorts []StatePortDefinition + Title string + Type string + type RelativeStateContract struct + Fields []RelativeStateFieldRef + type RelativeStateFieldRef struct + Mode StateAccessMode + Path string + Required bool + type RetryPolicy struct + BackoffMultiplier *float64 + InitialInterval string + Jitter *float64 + MaxAttempts int + MaxInterval string + NonRetryableErrorClasses []string + RetryableErrorClasses []string + func (policy RetryPolicy) MarshalJSON() ([]byte, error) + type RunDebugOptions struct + Breakpoints []DebugBreakpoint + IncludeArtifacts bool + IncludeSnapshots bool + IncludeState bool + IncludeStateDiff bool + PauseAfter []string + PauseBefore []string + StepMode bool + func (o RunDebugOptions) EffectiveBreakpoints() []DebugBreakpoint + func (o RunDebugOptions) Validate() error + type RunRequest struct + Debug *RunDebugOptions + Input map[string]any + InstanceID string + Metadata map[string]any + ResumeFromCheckpointID string + ResumeFromRunID string + Stream bool + Version string + func DeserializeRunRequest(data []byte) (RunRequest, error) + func (r RunRequest) Validate() error + type SecretRef struct + Metadata map[string]any + Ref string + Source string + func (r SecretRef) Validate() error + type StateAccessMode string + const StateAccessRead + const StateAccessReadWrite + const StateAccessWrite + type StateBinding struct + Path string + Reducer string + type StateBindingSemantic struct + Capability string + ComponentID string + ComponentType string + Contract []StateContractSemanticField + EdgeIndex int + Path string + Port string + type StateCapabilityDefinition struct + Fields []StateCapabilityFieldDefinition + ID string + Schema JSONSchema + type StateCapabilityFieldDefinition struct + MergeStrategy StateMergeStrategy + Name string + Reducer string + Schema JSONSchema + type StateContract struct + Fields []StateFieldRef + func (c StateContract) Clone() StateContract + type StateContractSemanticField struct + MergeStrategy StateMergeStrategy + Mode StateAccessMode + Path string + Reducer string + Required bool + Type string + type StateFieldDefinition struct + Description string + Path string + Schema JSONSchema + type StateFieldRef struct + Description string + MergeStrategy StateMergeStrategy + Mode StateAccessMode + Path string + Reducer string + Required bool + Schema JSONSchema + func (f StateFieldRef) Clone() StateFieldRef + type StateMergeStrategy string + const StateMergeAppend + const StateMergeMerge + const StateMergeReplace + type StateModuleDefinition struct + Capabilities []StateCapabilityDefinition + Fields []StateFieldDefinition + Name string + Version string + type StateModuleRef struct + Name string + Version string + type StatePortDefinition struct + Capability string + Contract RelativeStateContract + DefaultPath string + Description string + MergeStrategy StateMergeStrategy + Mode StateAccessMode + Name string + Reducer string + Required bool + Schema JSONSchema
Go to main page