Struct DurableChannel 

pub struct DurableChannel { /* private fields */ }

Haematite-backed durable channel state.

Implementations

impl DurableChannel

pub fn new( channel_id: impl Into<String>, partition_count: usize, store: Arc<dyn DurableStore>, ) -> Result<Self, DurabilityError>

Creates a new durable channel with all partition sequences initialized to zero.

Errors

Returns DurabilityError::ConfigError when partition_count is zero.

pub fn with_partition_key<F>( channel_id: impl Into<String>, partition_count: usize, store: Arc<dyn DurableStore>, partition_key: F, ) -> Result<Self, DurabilityError>

where F: Fn(&MessageEnvelope) -> u64 + Send + Sync + 'static,

Creates a durable channel with a caller-provided partition key function.

Errors

Returns DurabilityError::ConfigError when partition_count is zero.

pub fn from_recovered_sequences( channel_id: impl Into<String>, partition_count: usize, store: Arc<dyn DurableStore>, next_sequences: Vec<u64>, ) -> Result<Self, DurabilityError>

Creates a durable channel from explicit recovered next sequence counters.

Errors

Returns DurabilityError::ConfigError when partition_count is zero or the recovered sequence vector length differs from partition_count.

pub fn from_config( channel_id: impl Into<String>, config: DurabilityConfig, store: Arc<dyn DurableStore>, ) -> Result<Self, DurabilityError>

Creates a durable channel from validated durability configuration.

Errors

Returns DurabilityError::ConfigError when config is ephemeral.

pub fn channel_id(&self) -> &str

Returns the durable channel identifier.

pub const fn partition_count(&self) -> usize

Returns the number of partitions owned by this channel.

pub fn next_expected_sequence(&self, partition_index: usize) -> Option<u64>

Returns the next expected sequence for a partition, if it exists.

pub fn next_sequences(&self) -> &[u64]

Returns all next expected sequence counters.

pub fn partition_for(&self, envelope: &MessageEnvelope) -> usize

Computes the partition index for an envelope without touching storage.

pub fn stream_key_for(&self, partition_index: usize) -> String

Formats the haematite stream key for a channel partition.

pub async fn publish( &mut self, envelope: &MessageEnvelope, ) -> Result<u64, DurabilityError>

Persists an envelope before acknowledging the publish.

Errors

Returns envelope serialization errors and propagates any DurabilityError returned by DurableStore::append, including DurabilityError::SequenceConflict.

pub async fn flush_store(&self) -> Result<(), DurabilityError>

Flushes the backing store so every appended message is durably persisted.

Errors

Propagates any DurabilityError returned by DurableStore::flush.

Trait Implementations

impl Clone for DurableChannel

fn clone(&self) -> DurableChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DurableChannel

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

Formats the value using the given formatter.