Class: LangGraphRB::Observers::BaseObserver

Inherits:
Object
  • Object
show all
Defined in:
lib/langgraph_rb/observers/base.rb

Overview

Abstract base class for observability implementations

Direct Known Subclasses

LoggerObserver, StructuredObserver

Instance Method Summary collapse

Instance Method Details

#on_checkpoint_saved(event) ⇒ Object

Called when checkpoints are saved



54
55
56
 
# File 'lib/langgraph_rb/observers/base.rb', line 54

def on_checkpoint_saved(event)
  # Override in subclasses
end

#on_command_processed(event) ⇒ Object

Called when commands are processed (Send, Command, etc.)



44
45
46
 
# File 'lib/langgraph_rb/observers/base.rb', line 44

def on_command_processed(event)
  # Override in subclasses
end

#on_graph_end(event) ⇒ Object

Called when graph execution completes



14
15
16
 
# File 'lib/langgraph_rb/observers/base.rb', line 14

def on_graph_end(event)
  # Override in subclasses
end

#on_graph_start(event) ⇒ Object

Called when graph execution starts



9
10
11
 
# File 'lib/langgraph_rb/observers/base.rb', line 9

def on_graph_start(event)
  # Override in subclasses
end

#on_interrupt(event) ⇒ Object

Called when interrupts occur



49
50
51
 
# File 'lib/langgraph_rb/observers/base.rb', line 49

def on_interrupt(event)
  # Override in subclasses
end

#on_node_end(event) ⇒ Object

Called when a node execution completes successfully



24
25
26
 
# File 'lib/langgraph_rb/observers/base.rb', line 24

def on_node_end(event)
  # Override in subclasses
end

#on_node_error(event) ⇒ Object

Called when a node execution encounters an error



29
30
31
 
# File 'lib/langgraph_rb/observers/base.rb', line 29

def on_node_error(event)
  # Override in subclasses
end

#on_node_start(event) ⇒ Object

Called when a node execution starts



19
20
21
 
# File 'lib/langgraph_rb/observers/base.rb', line 19

def on_node_start(event)
  # Override in subclasses
end

#on_state_change(event) ⇒ Object

Called when state changes occur



39
40
41
 
# File 'lib/langgraph_rb/observers/base.rb', line 39

def on_state_change(event)
  # Override in subclasses
end

#on_step_complete(event) ⇒ Object

Called when a step completes (multiple nodes may execute in parallel)



34
35
36
 
# File 'lib/langgraph_rb/observers/base.rb', line 34

def on_step_complete(event)
  # Override in subclasses
end

#shutdown ⇒ Object

Shutdown hook for cleanup



59
60
61
 
# File 'lib/langgraph_rb/observers/base.rb', line 59

def shutdown
  # Override in subclasses if cleanup needed
end