Struct PostgresProjectorCoordinator 

pub struct PostgresProjectorCoordinator { /* private fields */ }

Postgres-backed projector coordinator for distributed leadership.

PostgresProjectorCoordinator uses PostgreSQL advisory locks to ensure only one projector instance processes events for a given subscription at a time, preventing duplicate processing in distributed deployments.

Implementations

impl PostgresProjectorCoordinator

pub async fn new<S: Into<String>>( connection_string: S, ) -> Result<Self, CoordinationError>

Create a new PostgresProjectorCoordinator with default configuration.

pub async fn with_config<S: Into<String>>( connection_string: S, config: PostgresConfig, ) -> Result<Self, CoordinationError>

Create a new PostgresProjectorCoordinator with custom configuration.

pub fn from_pool(pool: Pool<Postgres>) -> Self

Create a PostgresProjectorCoordinator from an existing connection pool.

Trait Implementations

impl Clone for PostgresProjectorCoordinator

fn clone(&self) -> PostgresProjectorCoordinator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresProjectorCoordinator

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

Formats the value using the given formatter.

impl ProjectorCoordinator for PostgresProjectorCoordinator

type Error = CoordinationError

Error type returned when leadership acquisition fails.

type Guard = CoordinationGuard

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.