Struct SqlitePartitionCoordinator 

pub struct SqlitePartitionCoordinator { /* private fields */ }

Implementations

impl SqlitePartitionCoordinator

pub fn new(conn: SqliteConn, config: SqlitePartitionCoordinatorConfig) -> Self

pub fn connect( conn: SqliteConn, config: SqlitePartitionCoordinatorConfig, ) -> Result<Self>

pub fn prepare_schema( conn: &SqliteConn, config: &SqlitePartitionCoordinatorConfig, ) -> Result<()>

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

Trait Implementations

impl Clone for SqlitePartitionCoordinator

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl PartitionCoordinator<SqliteCursor> for SqlitePartitionCoordinator

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<SqliteCursor>>>

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<SqliteCursor>, 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<SqliteCursor>, ) -> 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<SqliteCursor>, cursor: SqliteCursor, ) -> Result<()>

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