crabka-broker 0.3.6

Single-node Apache Kafka-compatible broker (MVP)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12

//! Shared utilities for the transaction subsystem.

/// Returns the current wall-clock time in milliseconds since the Unix epoch.
///
/// Used by transaction handlers to stamp `last_update_ms` on `TxnEntry`.
#[inline]
pub(crate) fn now_millis() -> i64 {
    use std::time::{SystemTime, UNIX_EPOCH};
    SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .map_or(0, |d| i64::try_from(d.as_millis()).unwrap_or(0))
}