pub struct ClockConfig {
pub clock_resolution_usecs: u64,
pub timezone_offset_ms: i64,
pub now_offset_ms: Option<i64>,
pub http_driven: bool,
}Fields§
§clock_resolution_usecs: u64§timezone_offset_ms: i64Constant offset added to every emitted NOW() value, in milliseconds
east of UTC. Populated from the clock_timezone_offset pipeline
property; 0 means UTC.
now_offset_ms: Option<i64>Target value for NOW() at the worker’s first emitted tick, in
milliseconds since the Unix epoch.
Populated verbatim from DevTweaks::now_offset at endpoint
construction; the wall-clock delta is computed inside the
connector’s worker task from a single SystemTime::now()
reading, so there is no drift between config construction and
the first emitted tick. None means no shift is applied.
http_driven: boolIf true, the clock does not advance on wall-clock cadence.
NOW() is held at its current value and only advances when an
external caller invokes the pipeline’s POST /clock/advance
endpoint. Populated from DevTweaks::now_http_driven.
Implementations§
Source§impl ClockConfig
impl ClockConfig
pub fn clock_resolution_ms(&self) -> u64
Trait Implementations§
Source§impl Clone for ClockConfig
impl Clone for ClockConfig
Source§fn clone(&self) -> ClockConfig
fn clone(&self) -> ClockConfig
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for ClockConfig
impl Debug for ClockConfig
Source§impl<'de> Deserialize<'de> for ClockConfig
impl<'de> Deserialize<'de> for ClockConfig
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
impl Eq for ClockConfig
Source§impl PartialEq for ClockConfig
impl PartialEq for ClockConfig
Source§impl Serialize for ClockConfig
impl Serialize for ClockConfig
impl StructuralPartialEq for ClockConfig
Auto Trait Implementations§
impl Freeze for ClockConfig
impl RefUnwindSafe for ClockConfig
impl Send for ClockConfig
impl Sync for ClockConfig
impl Unpin for ClockConfig
impl UnsafeUnpin for ClockConfig
impl UnwindSafe for ClockConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.