Embabel Agent Documentation/com.embabel.agent.spi.persistence/AgentProcessSnapshotStore

AgentProcessSnapshotStore

interface AgentProcessSnapshotStore

Storage SPI for serialized process checkpoints.

Implementations may store the payload in memory, Redis, JDBC/Postgres, or another backend. The payload is opaque to the store.

A null expectedVersion means "create only": saving must fail if a snapshot already exists for the process. A non-null expectedVersion means compare-and-set update: saving must fail unless the stored snapshot currently has that version.

Inheritors

Functions

Link copied to clipboard
abstract fun delete(processId: String)

Delete the latest serialized snapshot for the process.

Link copied to clipboard
abstract fun findByParentId(parentId: String): List<SerializedAgentProcessSnapshot>

Return latest serialized snapshots for direct child processes.

Link copied to clipboard
abstract fun findLatestByProcessId(processId: String): SerializedAgentProcessSnapshot?

Return the latest serialized snapshot for the process, if one exists.

Link copied to clipboard
abstract fun save(snapshot: SerializedAgentProcessSnapshot, expectedVersion: Long? = null): StoredSnapshotMetadata

Save a new or updated snapshot.