Module agentforge4j.runtime

Package com.agentforge4j.runtime.repository

Class InMemoryWorkflowStateRepository

java.lang.Object

com.agentforge4j.runtime.repository.InMemoryWorkflowStateRepository

All Implemented Interfaces:

WorkflowStateRepository

public final class InMemoryWorkflowStateRepository
extends Object
implements WorkflowStateRepository

In-memory WorkflowStateRepository backed by a concurrent map keyed by run id.

Constructor Summary

Constructors

Constructor	Description
InMemoryWorkflowStateRepository()	Creates an empty repository.

Method Summary

Modifier and Type	Method	Description
List<WorkflowState>	findAll()	Returns all stored run states; order is implementation-defined.
Optional<WorkflowState>	findById(String runId)	Returns the latest persisted state for runId, if any.
void	save(WorkflowState state)	Inserts or replaces state in the backing store.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InMemoryWorkflowStateRepository

public InMemoryWorkflowStateRepository()

Creates an empty repository.

Method Details

save

public void save(WorkflowState state)

Description copied from interface: WorkflowStateRepository

Inserts or replaces state in the backing store.

Specified by:

save in interface WorkflowStateRepository

findById

public Optional<WorkflowState> findById(String runId)

Description copied from interface: WorkflowStateRepository

Returns the latest persisted state for runId, if any.

Specified by:

findById in interface WorkflowStateRepository

Parameters:

runId - run id to load

findAll

public List<WorkflowState> findAll()

Description copied from interface: WorkflowStateRepository

Returns all stored run states; order is implementation-defined.

Specified by:

findAll in interface WorkflowStateRepository