Struct PostgresAgentPoolStore 

pub struct PostgresAgentPoolStore { /* private fields */ }

Implementations

impl PostgresAgentPoolStore

pub fn new(client: PostgresStoreClient) -> Self

Trait Implementations

impl AgentPoolStore for PostgresAgentPoolStore

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 PostgresAgentPoolStore

fn clone(&self) -> PostgresAgentPoolStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.