Struct WindowSpec 

pub struct WindowSpec {
    pub step: String,
    pub lower: WindowBind,
    pub upper: WindowBind,
    pub granularity: Option<String>,
    pub lookback: Option<String>,
    pub max_windows: usize,
}

Declarative in-run datetime window slicing (#527).

Fields

step: String

Window size — 45s / 30m / 6h / 30d, or a bare integer (= seconds). Absolute UTC durations (d = 24h); calendar/DST-correct windows are a [faucet backfill] concern, not the incremental cursor.

lower: WindowBind

Lower-bound bind, rendered with the window start.

upper: WindowBind

Upper-bound bind, rendered with the window end.

granularity: Option<String>

Subtract this from each window’s rendered upper bound so [start, end] is non-overlapping for inclusive-inclusive APIs (Airbyte cursor_granularity). Same grammar as step. The persisted bookmark is always the true half-open boundary, so resume never gaps or overlaps — only the value sent to the server is adjusted.

lookback: Option<String>

Re-scan this much before the bookmark on the first window, to catch late-arriving updates without a full replay. Same grammar as step.

max_windows: usize

Safety cap on the number of windows enumerated in one run. On overflow the sweep is truncated (logged, never silently), and the next run resumes from the last window’s end.

Implementations

impl WindowSpec

pub fn validate(&self) -> Result<(), FaucetError>

Validate the whole spec at config-load time.

pub fn step_duration(&self) -> Result<Duration, FaucetError>

The parsed step duration.

pub fn granularity_duration(&self) -> Result<Option<Duration>, FaucetError>

The parsed granularity duration, if any.

pub fn lookback_duration(&self) -> Result<Option<Duration>, FaucetError>

The parsed lookback duration, if any.

pub fn render_lower(&self, w: &Window) -> String

The rendered lower-bound value for a window (the window start).

pub fn render_upper(&self, w: &Window) -> Result<String, FaucetError>

The rendered upper-bound value for a window, applying granularity (the window end, minus granularity if set, for inclusive-inclusive APIs).

Trait Implementations

impl Clone for WindowSpec

fn clone(&self) -> WindowSpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WindowSpec

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WindowSpec

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for WindowSpec

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl PartialEq for WindowSpec

fn eq(&self, other: &WindowSpec) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for WindowSpec

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for WindowSpec