Struct DedupEntry 

pub struct DedupEntry { /* private fields */ }

Persisted dedup cache entry for one producer idempotency key.

Implementations

impl DedupEntry

pub fn new( idempotency_key: impl Into<String>, receipt: Option<Vec<u8>>, timestamp_millis: u64, ) -> Self

Builds an entry containing the original key, optional receipt bytes, and epoch millis.

pub fn idempotency_key(&self) -> &str

Returns the original idempotency key stored with this entry.

pub fn receipt(&self) -> Option<&[u8]>

Returns the stored opaque receipt bytes, when processing has completed.

pub const fn timestamp_millis(&self) -> u64

Returns the entry timestamp in epoch milliseconds.

pub fn serialize(&self) -> Result<Vec<u8>, DurabilityError>

Serializes this active cache entry into deterministic storage bytes.

Errors

Returns DurabilityError::EnvelopeError when a field length cannot be encoded.

pub fn deserialize(bytes: &[u8]) -> Result<Self, DurabilityError>

Deserializes an active cache entry previously produced by Self::serialize.

Errors

Returns DurabilityError::EnvelopeError when bytes are malformed or contain a tombstone.

Trait Implementations

impl Clone for DedupEntry

fn clone(&self) -> DedupEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DedupEntry

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

Formats the value using the given formatter.

impl Eq for DedupEntry

impl PartialEq for DedupEntry

fn eq(&self, other: &DedupEntry) -> 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 DedupEntry