pub struct WriteConcernReceipt { /* private fields */ }Expand description
Actual processing acknowledgement progress. The receiving node always
counts as one after ordinary apply completion. Certified evidence reports
actual local and remote fences; a timed-out or failed-fence receipt may retain
local progress below the requested durability. No failed write is rolled back.
An unknown replica count is represented by None for local-only writes.
Implementations§
Source§impl WriteConcernReceipt
impl WriteConcernReceipt
pub fn requested_durability(&self) -> WriteDurability
pub fn with_requested_durability( self, durability: WriteDurability, ) -> Result<Self, WriteConcernPolicyError>
Sourcepub fn evidence(&self) -> Option<&WriteConcernEvidence>
pub fn evidence(&self) -> Option<&WriteConcernEvidence>
Certified floor and actual reached fences. Legacy responses can omit it
unless require_evidence or a store/stable fence was requested.
pub fn with_evidence( self, evidence: WriteConcernEvidence, ) -> Result<Self, WriteConcernPolicyError>
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.