AsyncPersistenceStorageProvider

Storage provider (ex: database, S3, file) to be used in ai.koog.agents.snapshot.feature.Persistence feature.

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
suspend override fun getCheckpoints(sessionId: String, filter: Filter?): List<AgentCheckpointData>

Retrieves the list of checkpoints of the AI agent with the given sessionId that match the provided filter

open suspend fun getCheckpoints(sessionId: String): List<AgentCheckpointData>

Retrieves the list of checkpoints of the AI agent with the given sessionId

Link copied to clipboard

Retrieves the list of checkpoints of the AI agent with the given agentId that match the provided filter.

Link copied to clipboard
suspend override fun getLatestCheckpoint(sessionId: String, filter: Filter?): AgentCheckpointData?

Retrieves the latest checkpoint of the AI agent with sessionId matching the provided filter

open suspend fun getLatestCheckpoint(sessionId: String): AgentCheckpointData?

Retrieves the latest checkpoint of the AI agent with sessionId

Link copied to clipboard

Retrieves the latest checkpoint of the AI agent with agentId matching the provided filter

Link copied to clipboard
suspend override fun saveCheckpoint(sessionId: String, agentCheckpointData: AgentCheckpointData)

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)