Embabel Agent Documentation/com.embabel.agent.spi.support/InMemoryAgentProcessRepository

InMemoryAgentProcessRepository

class InMemoryAgentProcessRepository(properties: ProcessRepositoryProperties = ProcessRepositoryProperties()) : AbstractAgentProcessRepository

In-memory implementation of AgentProcessRepository with configurable window size to prevent memory overflow by evicting the oldest entries when the limit is reached.

Constructors

constructor(properties: ProcessRepositoryProperties = ProcessRepositoryProperties())

Functions

clear

fun clear(): <Error class: unknown class>

Clear all entries from the repository for testing purposes.

delete

open override fun delete(agentProcess: AgentProcess)

findById

open override fun findById(id: String): AgentProcess?

findByParentId

open override fun findByParentId(parentId: String): List<AgentProcess>

Find all child processes for the given parent process ID.

save

override fun save(agentProcess: AgentProcess): AgentProcess

Save a new agent process. This method checks if the process is ephemeral and logs an error if persistence is attempted. Non-ephemeral processes are delegated to doSave.

size

fun size(): Int

Get current size of the repository for testing purposes.

update

override fun update(agentProcess: AgentProcess)

Update an existing agent process. This method checks if the process is ephemeral and logs an error if persistence is attempted. Non-ephemeral processes are delegated to doUpdate.