()
| 101 | } |
| 102 | |
| 103 | pub(crate) fn utc_now() -> TimestampMs { |
| 104 | let millis = SystemTime::now() |
| 105 | .duration_since(UNIX_EPOCH) |
| 106 | .map(|duration| duration.as_millis().min(i64::MAX as u128) as i64) |
| 107 | .unwrap_or(0); |
| 108 | TimestampMs::from_millis(millis) |
| 109 | } |
| 110 | |
| 111 | pub(crate) fn parse_ts_timestamp(value: &str) -> Option<TimestampMs> { |
| 112 | let bytes = value.as_bytes(); |
no test coverage detected