Struct FileAgentPoolStore 

pub struct FileAgentPoolStore { /* private fields */ }

Filesystem-backed agent-pool coordination store.

Implementations

impl FileAgentPoolStore

pub fn new(root: impl Into<PathBuf>) -> Self

Creates an agent-pool store rooted under the provided directory.

Trait Implementations

impl AgentPoolStore for FileAgentPoolStore

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<CoreStoredWake>, 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 FileAgentPoolStore

fn clone(&self) -> FileAgentPoolStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileAgentPoolStore

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

Formats the value using the given formatter.