Struct SqliteAgentPoolStore 

pub struct SqliteAgentPoolStore { /* private fields */ }

SQLite-backed implementation of AgentPoolStore.

Two independent SqliteAgentPoolStore values opened against the same database file share pool membership, messages, wake registrations, dedupe, rehydration, and watch cursors. The adapter stores core pool records as JSON and replays them into snapshots; it does not own workflow scheduling or a second event bus.

Implementations

impl SqliteAgentPoolStore

pub fn open(path: impl AsRef<Path>) -> Result<Self, AgentError>

Opens or creates a SQLite-backed agent-pool store.

pub fn path(&self) -> &Path

Returns the backing database path.

Trait Implementations

impl AgentPoolStore for SqliteAgentPoolStore

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 SqliteAgentPoolStore

fn clone(&self) -> SqliteAgentPoolStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.