pub struct WriteConcernReceipt { /* private fields */ }Expand description
Actual acknowledgement progress. The receiving node always counts as one.
An unknown replica count is represented by None for local-only writes.
Implementations§
Source§impl WriteConcernReceipt
impl WriteConcernReceipt
pub fn new( receiving_node: String, replica_count: u32, requested: u32, required: u32, acknowledged_nodes: Vec<String>, ) -> Result<Self, WriteConcernPolicyError>
pub fn receiving_node(&self) -> &str
pub fn replica_count(&self) -> Option<u32>
pub fn requested_acknowledgements(&self) -> u32
pub fn required_acknowledgements(&self) -> u32
pub fn acknowledged_nodes(&self) -> &[String]
pub fn was_overridden(&self) -> bool
Sourcepub fn with_region_progress(
self,
receiving_region: String,
outside_region_acknowledged_nodes: Vec<String>,
) -> Result<Self, WriteConcernPolicyError>
pub fn with_region_progress( self, receiving_region: String, outside_region_acknowledged_nodes: Vec<String>, ) -> Result<Self, WriteConcernPolicyError>
Attach progress against the receiving node’s frozen region requirement.
Sourcepub fn receiving_region(&self) -> Option<&str>
pub fn receiving_region(&self) -> Option<&str>
Frozen receiving-region label, present when a region requirement was used.
Sourcepub fn outside_region_acknowledged_nodes(&self) -> &[String]
pub fn outside_region_acknowledged_nodes(&self) -> &[String]
Eligible acknowledged identities classified outside the receiving region by the receiving node’s frozen configuration.
Sourcepub fn other_region_satisfied(&self) -> bool
pub fn other_region_satisfied(&self) -> bool
Whether an eligible outside-region processing acknowledgement was observed.
Sourcepub fn validate_for(
&self,
options: &WriteConcernOptions,
satisfied: bool,
) -> Result<(), WriteConcernPolicyError>
pub fn validate_for( &self, options: &WriteConcernOptions, satisfied: bool, ) -> Result<(), WriteConcernPolicyError>
Validate receipt correlation with the requested policy. A timed-out receipt may lack the required progress but must preserve policy metadata.
Trait Implementations§
Source§impl Clone for WriteConcernReceipt
impl Clone for WriteConcernReceipt
Source§impl Debug for WriteConcernReceipt
impl Debug for WriteConcernReceipt
impl Eq for WriteConcernReceipt
Source§impl PartialEq for WriteConcernReceipt
impl PartialEq for WriteConcernReceipt
impl StructuralPartialEq for WriteConcernReceipt
Auto Trait Implementations§
impl Freeze for WriteConcernReceipt
impl RefUnwindSafe for WriteConcernReceipt
impl Send for WriteConcernReceipt
impl Sync for WriteConcernReceipt
impl Unpin for WriteConcernReceipt
impl UnsafeUnpin for WriteConcernReceipt
impl UnwindSafe for WriteConcernReceipt
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more