Struct AtomicTimestamp 

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

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

Implementations

impl AtomicTimestamp

pub fn now() -> Self

pub fn now_non_decreasing() -> Self

pub fn now_increasing() -> Self

pub fn new(t: Timestamp) -> Self

pub fn get(&self) -> Timestamp

pub fn set(&self, t: Timestamp)

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

Fetch and update the timestamp atomically

Parameters:

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

Returns:

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

pub fn expiration_state( &self, cur_ts: Timestamp, expiration: TimestampDuration, ) -> 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 AtomicTimestamp

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 AtomicTimestamp

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

Formats the value using the given formatter.

impl Default for AtomicTimestamp

fn default() -> AtomicTimestamp

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AtomicTimestamp

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for AtomicTimestamp

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

Formats the value using the given formatter.

impl From<&AtomicTimestamp> for Timestamp

fn from(at: &AtomicTimestamp) -> Self

Converts to this type from the input type.

impl From<AtomicTimestamp> for Timestamp

fn from(at: AtomicTimestamp) -> Self

Converts to this type from the input type.

impl From<Timestamp> for AtomicTimestamp

fn from(t: Timestamp) -> Self

Converts to this type from the input type.

impl GetSize for AtomicTimestamp

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 AtomicTimestamp

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

where __S: Serializer,

Serialize this value into the given Serde serializer.