Class: GraphAgent::Checkpoint::BaseSaver

Inherits:
Object
  • Object
show all
Defined in:
lib/graph_agent/checkpoint/base_saver.rb

Direct Known Subclasses

InMemorySaver

Instance Method Summary collapse

Instance Method Details

#delete_thread(thread_id) ⇒ Object

Raises:

  • (NotImplementedError) 


33
34
35
 
# File 'lib/graph_agent/checkpoint/base_saver.rb', line 33

def delete_thread(thread_id)
  raise NotImplementedError.new("#{self.class}#delete_thread must be implemented")
end

#get(config) ⇒ Object 



12
13
14
15
 
# File 'lib/graph_agent/checkpoint/base_saver.rb', line 12

def get(config)
  tuple = get_tuple(config)
  tuple&.checkpoint
end

#get_tuple(config) ⇒ Object

Raises:

  • (NotImplementedError) 


17
18
19
 
# File 'lib/graph_agent/checkpoint/base_saver.rb', line 17

def get_tuple(config)
  raise NotImplementedError.new("#{self.class}#get_tuple must be implemented")
end

#list(config, filter: nil, before: nil, limit: nil) ⇒ Object

Raises:

  • (NotImplementedError) 


21
22
23
 
# File 'lib/graph_agent/checkpoint/base_saver.rb', line 21

def list(config, filter: nil, before: nil, limit: nil)
  raise NotImplementedError.new("#{self.class}#list must be implemented")
end

#put(config, checkpoint, metadata, new_versions) ⇒ Object

Raises:

  • (NotImplementedError) 


25
26
27
 
# File 'lib/graph_agent/checkpoint/base_saver.rb', line 25

def put(config, checkpoint, metadata, new_versions)
  raise NotImplementedError.new("#{self.class}#put must be implemented")
end

#put_writes(config, writes, task_id) ⇒ Object

Raises:

  • (NotImplementedError) 


29
30
31
 
# File 'lib/graph_agent/checkpoint/base_saver.rb', line 29

def put_writes(config, writes, task_id)
  raise NotImplementedError.new("#{self.class}#put_writes must be implemented")
end