Struct AtomicOptionTimestamp 

pub struct AtomicOptionTimestamp(/* private fields */);

Atomic wrapper for optional timestamps used in structs so we can avoid locks for LRU and similar operations

Implementations

impl AtomicOptionTimestamp

pub fn new(opt_ts: Option<Timestamp>) -> Self

pub fn none() -> Self

pub fn now() -> Self

pub fn now_non_decreasing() -> Self

pub fn now_increasing() -> Self

pub fn get(&self) -> Option<Timestamp>

pub fn set(&self, opt_t: Option<Timestamp>)

pub fn fetch_update( &self, f: impl FnMut(Option<Timestamp>) -> Option<Option<Timestamp>>, ) -> Result<Option<Timestamp>, Option<Timestamp>>

Fetch and update the optional timestamp atomically

Parameters:

• f: A function that takes the current optional timestamp and returns an optional new optional timestamp

Returns:

• The new optional timestamp if the update was successful, otherwise the current optional timestamp

pub fn expiration_state( &self, cur_ts: Timestamp, expiration: TimestampDuration, ) -> Option<ExpirationState>

Check if a timestamp has expired atomically

Parameters:

• cur_ts: The current timestamp
• expiration: The expiration duration

Returns:

• true if the timestamp has expired, false if it has not

pub fn update_if_not_expired( &self, cur_ts: Timestamp, expiration: TimestampDuration, ) -> ExpirationState

Check if a timestamp is expired and update it to the current time if it is not, atomically. Useful for LRU caching.

Parameters:

• cur_ts: The current timestamp
• expiration: The expiration duration

Returns:

• true if the timestamp was updated, false if it was expired

Trait Implementations

impl Clone for AtomicOptionTimestamp

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AtomicOptionTimestamp

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

Formats the value using the given formatter.

impl Default for AtomicOptionTimestamp

fn default() -> AtomicOptionTimestamp

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AtomicOptionTimestamp

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for AtomicOptionTimestamp

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

Formats the value using the given formatter.

impl From<&AtomicOptionTimestamp> for Option<Timestamp>

fn from(at: &AtomicOptionTimestamp) -> Self

Converts to this type from the input type.

impl From<AtomicOptionTimestamp> for Option<Timestamp>

fn from(at: AtomicOptionTimestamp) -> Self

Converts to this type from the input type.

impl From<Option<Timestamp>> for AtomicOptionTimestamp

fn from(opt_t: Option<Timestamp>) -> Self

Converts to this type from the input type.

impl From<Timestamp> for AtomicOptionTimestamp

fn from(t: Timestamp) -> Self

Converts to this type from the input type.

impl GetSize for AtomicOptionTimestamp

fn get_heap_size(&self) -> usize

Determines how many bytes this object occupies inside the heap.

fn get_heap_size_with_tracker<TRACKER: GetSizeTracker>( &self, tracker: TRACKER, ) -> (usize, TRACKER)

Determines how many bytes this object occupies inside the heap while using a tracker.

fn get_stack_size() -> usize

Determines how may bytes this object occupies inside the stack.

fn get_size(&self) -> usize

Determines the total size of the object.

fn get_size_with_tracker<T>(&self, tracker: T) -> (usize, T)

where T: GetSizeTracker,

Determines the total size of the object while using a tracker.

impl Serialize for AtomicOptionTimestamp

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.