Versions in this module Expand all Collapse all v0 v0.1.0 Aug 9, 2025 Changes in this version + type EdgeInfo struct + Condition string + From string + Metadata map[string]interface{} + To string + type ExecutionStep struct + Duration time.Duration + Error string + ID string + Input interface{} + Metadata map[string]interface{} + NodeID string + Output interface{} + StateSnapshot *core.BaseState + StepType string + ThreadID string + Timestamp time.Time + type GraphTopology struct + Edges []EdgeInfo + Nodes []NodeInfo + type GraphVisualizer struct + func NewGraphVisualizer(config *VisualizerConfig, checkpointer persistence.Checkpointer) *GraphVisualizer + func (gv *GraphVisualizer) GenerateDotDiagram(topology *GraphTopology) string + func (gv *GraphVisualizer) GenerateExecutionTrace(threadID string) string + func (gv *GraphVisualizer) GenerateMermaidDiagram(topology *GraphTopology) string + func (gv *GraphVisualizer) GetDebugInfo(threadID string) map[string]interface{} + func (gv *GraphVisualizer) GetExecutionHistory(threadID string) []ExecutionStep + func (gv *GraphVisualizer) GetGraphTopology(graph *core.Graph) *GraphTopology + func (gv *GraphVisualizer) RecordStep(step *ExecutionStep) + func (gv *GraphVisualizer) Subscribe(subscriber VisualizationSubscriber) + type NodeInfo struct + ID string + IsEndNode bool + IsStartNode bool + Metadata map[string]interface{} + Name string + Position *Position + Type string + type Position struct + X int + Y int + type VisualizationSubscriber interface + OnError func(err error) + OnGraphCompleted func(threadID string, steps []ExecutionStep) + OnStepExecuted func(step *ExecutionStep) + type VisualizerConfig struct + EnableRealTimeUpdates bool + IncludeMetadata bool + IncludeTimestamps bool + MaxHistorySize int + OutputFormat string + func DefaultVisualizerConfig() *VisualizerConfig + type WebSocketSubscriber struct + SendMessage func(message interface{}) error + func NewWebSocketSubscriber(sendMessage func(message interface{}) error) *WebSocketSubscriber + func (ws *WebSocketSubscriber) OnError(err error) + func (ws *WebSocketSubscriber) OnGraphCompleted(threadID string, steps []ExecutionStep) + func (ws *WebSocketSubscriber) OnStepExecuted(step *ExecutionStep)
Go to main page