Enum WriterClock 

pub enum WriterClock {
    Live,
    Test(Arc<AtomicU64>),
}

Minimal Send time source for streaming writers.

Live reads the wall clock directly; Test reads a shared atomic that the owner of the source clock (e.g. a PyO3 wrapper holding a VirtualClock) refreshes before forwarding writer calls.

Variants

Live

Wall-clock time via [nanos_since_unix_epoch].

Test(Arc<AtomicU64>)

Externally driven time stored in a shared atomic (nanoseconds since the UNIX epoch).

Implementations

impl WriterClock

pub fn timestamp_ns(&self) -> UnixNanos

Returns the current timestamp in nanoseconds since the UNIX epoch.

pub fn from_shared_clock( clock: &Rc<RefCell<dyn Clock>>, ) -> (Self, Option<Arc<AtomicU64>>)

Builds a writer clock from a shared dyn Clock.

Returns WriterClock::Live for a [LiveClock]. For any other clock (e.g. VirtualClock) it returns a WriterClock::Test source seeded with the clock’s current time, plus the shared atomic the caller must refresh from the source clock before each forwarded writer call.

Trait Implementations

impl Clone for WriterClock

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 WriterClock

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

Formats the value using the given formatter.