AsyncPersistenceStorageProvider
abstract class AsyncPersistenceStorageProvider<Filter> : PersistenceStorageProvider<Filter> (source)
Storage provider (ex: database, S3, file) to be used in ai.koog.agents.snapshot.feature.Persistence feature.
Functions
Link copied to clipboard
abstract fun getCheckpointsAsync(agentId: String, filter: Filter?): CompletableFuture<List<AgentCheckpointData>>
Link copied to clipboard
Retrieves the latest checkpoint of the AI agent with sessionId
Link copied to clipboard
abstract fun getLatestCheckpointAsync(agentId: String, filter: Filter?): CompletableFuture<AgentCheckpointData?>
Link copied to clipboard
Saves provided checkpoint (agentCheckpointData) of the agent with sessionId to the storage (ex: database, S3, file)
Link copied to clipboard
abstract fun saveCheckpointAsync(agentId: String, agentCheckpointData: AgentCheckpointData): CompletableFuture<Boolean>
Saves provided checkpoint (agentCheckpointData) of the agent with agentId to the storage (ex: database, S3, file)