Struct InMemoryAgentPoolStore 

pub struct InMemoryAgentPoolStore { /* private fields */ }

In-memory AgentPoolStore implementation. Cloning this value shares the same backing map, making it useful for tests that simulate two process-local AgentPool handles sharing one coordination authority. Separate default values are isolated.

Trait Implementations

impl AgentPoolStore for InMemoryAgentPoolStore

fn open_pool( &self, pool_id: AgentPoolId, config: AgentPoolStoreConfig, ) -> Result<AgentPoolSnapshot, AgentError>

Create or open a logical pool and return the durable snapshot.

fn snapshot( &self, pool_id: &AgentPoolId, ) -> Result<AgentPoolSnapshot, AgentError>

Rehydrate the current durable pool snapshot.

fn record_pool_created( &self, pool_id: &AgentPoolId, ) -> Result<AgentPoolStoreCursor, AgentError>

Mark the pool-created lifecycle as durable.

fn join_member( &self, pool_id: &AgentPoolId, member: AgentPoolMember, ) -> Result<AgentPoolStoreCursor, AgentError>

Persist member join.

fn leave_member( &self, pool_id: &AgentPoolId, run_id: &RunId, ) -> Result<(AgentPoolMember, AgentPoolStoreCursor), AgentError>

Persist member leave and return the removed member.

fn message_receipt( &self, pool_id: &AgentPoolId, idempotency_key: &IdempotencyKey, ) -> Result<Option<MessageReceipt>, AgentError>

Look up message dedupe state by idempotency key.

fn record_message( &self, pool_id: &AgentPoolId, message: RunMessage, receipt: MessageReceipt, ) -> Result<AgentPoolStoreCursor, AgentError>

Persist one message status transition.

fn wake_registration( &self, pool_id: &AgentPoolId, idempotency_key: &IdempotencyKey, ) -> Result<Option<WakeRegistration>, AgentError>

Look up wake dedupe state by idempotency key.

fn wake( &self, pool_id: &AgentPoolId, condition_id: &WakeConditionId, ) -> Result<Option<AgentPoolStoredWake>, AgentError>

Look up one stored wake by condition id.

fn record_wake( &self, pool_id: &AgentPoolId, condition: WakeCondition, compiled_filter: CompiledEventFilter, registration: WakeRegistration, ) -> Result<AgentPoolStoreCursor, AgentError>

Persist one wake status transition.

fn watch( &self, pool_id: &AgentPoolId, cursor: Option<AgentPoolStoreCursor>, ) -> Result<AgentPoolStoreStream, AgentError>

Read durable pool changes after the supplied cursor.

fn next_event_sequence(&self, pool_id: &AgentPoolId) -> Result<u64, AgentError>

Allocate a unique event sequence for pool event IDs.

impl Clone for InMemoryAgentPoolStore

fn clone(&self) -> InMemoryAgentPoolStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for InMemoryAgentPoolStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InMemoryAgentPoolStore

fn default() -> InMemoryAgentPoolStore

Returns the “default value” for a type.