Struct DurabilityConfig 

pub struct DurabilityConfig { /* private fields */ }

Explicit durability configuration supplied per channel.

Implementations

impl DurabilityConfig

pub fn new( mode: DurabilityMode, partition_count: usize, dedup_ttl: Duration, checkpoint_policy: CheckpointPolicy, ) -> Result<Self, DurabilityError>

Creates validated durability configuration from caller-supplied fields.

Errors

Returns DurabilityError::ConfigError when partition_count is zero, when mode is DurabilityMode::DurableDedup and dedup_ttl is zero, or when checkpoint_policy is CheckpointPolicy::PerBatch with a zero batch size.

pub const fn mode(&self) -> DurabilityMode

Returns the configured channel durability strategy.

pub const fn partition_count(&self) -> usize

Returns the number of independent durable partitions.

pub const fn dedup_ttl(&self) -> Duration

Returns the time-to-live for dedup receipts.

pub const fn checkpoint_policy(&self) -> CheckpointPolicy

Returns the consumer checkpoint policy.

Trait Implementations

impl Clone for DurabilityConfig

fn clone(&self) -> DurabilityConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for DurabilityConfig

impl Debug for DurabilityConfig

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

Formats the value using the given formatter.

impl Eq for DurabilityConfig

impl From<DurabilityConfig> for CheckpointPolicy

fn from(config: DurabilityConfig) -> Self

Converts to this type from the input type.

impl PartialEq for DurabilityConfig

fn eq(&self, other: &DurabilityConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for DurabilityConfig