Struct ClockConfig 

pub struct ClockConfig {
    pub clock_resolution_usecs: i64,
    pub http_driven: Option<bool>,
    pub now_offset_ms: Option<i64>,
    pub timezone_offset_ms: Option<i64>,
}

ClockConfig

JSON schema

{
 "type": "object",
 "required": [
   "clock_resolution_usecs"
 ],
 "properties": {
   "clock_resolution_usecs": {
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "http_driven": {
     "description": "If `true`, the clock does not advance on wall-clock cadence.\n`NOW()` is held at its current value and only advances when an\nexternal caller invokes the pipeline's `POST /clock/advance`\nendpoint.  Populated from `DevTweaks::now_http_driven`.",
     "type": "boolean"
   },
   "now_offset_ms": {
     "description": "Target value for `NOW()` at the worker's first emitted tick, in\nmilliseconds since the Unix epoch.\n\nPopulated verbatim from `DevTweaks::now_offset` at endpoint\nconstruction; the wall-clock delta is computed inside the\nconnector's worker task from a single `SystemTime::now()`\nreading, so there is no drift between config construction and\nthe first emitted tick.  `None` means no shift is applied.",
     "type": [
       "integer",
       "null"
     ],
     "format": "int64"
   },
   "timezone_offset_ms": {
     "description": "Constant offset added to every emitted `NOW()` value, in milliseconds\neast of UTC.  Populated from the `clock_timezone_offset` pipeline\nproperty; 0 means UTC.",
     "type": "integer",
     "format": "int64"
   }
 }
}

Fields

clock_resolution_usecs: i64

http_driven: Option<bool>

If 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.

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.

timezone_offset_ms: Option<i64>

Constant offset added to every emitted NOW() value, in milliseconds east of UTC. Populated from the clock_timezone_offset pipeline property; 0 means UTC.

Implementations

impl ClockConfig

pub fn builder() -> ClockConfig

Trait Implementations

impl Clone for ClockConfig

fn clone(&self) -> ClockConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ClockConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClockConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&ClockConfig> for ClockConfig

fn from(value: &ClockConfig) -> Self

Converts to this type from the input type.

impl From<ClockConfig> for ClockConfig

fn from(value: ClockConfig) -> Self

Converts to this type from the input type.

impl Serialize for ClockConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<ClockConfig> for ClockConfig

type Error = ConversionError

The type returned in the event of a conversion error.

fn try_from(value: ClockConfig) -> Result<Self, ConversionError>

Performs the conversion.