Struct PgPartitionCoordinator 

pub struct PgPartitionCoordinator { /* private fields */ }

Implementations

impl PgPartitionCoordinator

pub fn new(pool: PgPool, config: PgPartitionCoordinatorConfig) -> Self

pub async fn connect( pool: PgPool, config: PgPartitionCoordinatorConfig, ) -> Result<Self>

pub async fn prepare_schema( pool: &PgPool, config: &PgPartitionCoordinatorConfig, ) -> Result<()>

pub fn schema_sql(config: &PgPartitionCoordinatorConfig) -> String

Trait Implementations

impl Clone for PgPartitionCoordinator

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl PartitionCoordinator<PgCursor> for PgPartitionCoordinator

async fn heartbeat<'a>( &'a self, scope: &'a CheckpointScope, owner_id: &'a OwnerId, lease_duration: Duration, ) -> Result<()>

async fn live_consumers<'a>( &'a self, scope: &'a CheckpointScope, ) -> Result<usize>

async fn release_consumer<'a>( &'a self, scope: &'a CheckpointScope, owner_id: &'a OwnerId, ) -> Result<()>

Remove this consumer’s registration so other consumers stop counting it as live when computing target_partition_count. Called by CoordinatedReader on stream shutdown. Should be idempotent and must not return an error when the consumer record is missing.

async fn claim<'a>( &'a self, scope: &'a CheckpointScope, owner_id: &'a OwnerId, partition: Partition, lease_duration: Duration, ) -> Result<Option<PartitionLease<PgCursor>>>

Attempt to take a partition. Returns Ok(Some(lease)) on success or Ok(None) if another live owner holds it. Increments generation on every successful claim.

async fn renew<'a>( &'a self, lease: &'a PartitionLease<PgCursor>, lease_duration: Duration, ) -> Result<()>

Extend lease_until only if (owner_id, generation) still matches. Returns Err(Error::OwnershipLost(_)) on mismatch.

async fn release<'a>( &'a self, lease: &'a PartitionLease<PgCursor>, ) -> Result<()>

Clear owner_id and lease_until only if (owner_id, generation) matches. Increments generation. Returns Err(Error::OwnershipLost(_)) on mismatch.

async fn checkpoint<'a>( &'a self, lease: &'a PartitionLease<PgCursor>, cursor: PgCursor, ) -> Result<()>

Write cursor only if (owner_id, generation) matches. The update is monotonic via Cursor::order_key(). Returns Err(Error::OwnershipLost(_)) on mismatch.