Struct InMemoryProjectorCoordinator 

pub struct InMemoryProjectorCoordinator { /* private fields */ }

In-memory projector coordinator for single-process deployments.

InMemoryProjectorCoordinator provides coordination for projectors within a single process using an in-memory lock table. This is suitable for testing and single-process deployments where distributed coordination is not required.

For distributed deployments with multiple process instances, use a database-backed coordinator implementation (e.g., PostgreSQL advisory locks).

Implementations

impl InMemoryProjectorCoordinator

pub fn new() -> Self

Create a new in-memory projector coordinator.

Trait Implementations

impl Clone for InMemoryProjectorCoordinator

fn clone(&self) -> InMemoryProjectorCoordinator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryProjectorCoordinator

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

Formats the value using the given formatter.

impl Default for InMemoryProjectorCoordinator

fn default() -> InMemoryProjectorCoordinator

Returns the “default value” for a type.

impl ProjectorCoordinator for InMemoryProjectorCoordinator

type Error = InMemoryCoordinationError

Error type returned when leadership acquisition fails.

type Guard = InMemoryCoordinationGuard

Guard type that releases leadership when dropped.

async fn try_acquire( &self, subscription_name: &str, ) -> Result<Self::Guard, Self::Error>

Attempt to acquire leadership for a subscription.