Skip to main content

SourceDecl

Struct SourceDecl 

Source
pub struct SourceDecl {
    pub name: Ident,
    pub provider: Ident,
    pub clock: Option<ClockPolicy>,
    pub path: Option<StringLiteral>,
    pub watch: Option<StringLiteral>,
    pub url: Option<StringLiteral>,
    pub dedup: Option<SourceValue>,
    pub observe_binding: Ident,
    pub emit: SourceEmit,
    pub span: SourceSpan,
}
Expand description

A top-level source declaration: source <provider> as <name> { ... } or source clock as <name> { ... }. Lowers through the source_declaration construct family to a signal_source (generic provider) or clock_source (the clock provider) admission template (spec/std-time.md, spec/construct-grammar.md). A source admits a durable signal fact; it never fires a rule directly.

Fields§

§name: Ident

as <name> — the source instance name.

§provider: Ident

The provider keyword (clock) or a generic provider identifier.

§clock: Option<ClockPolicy>

Recurrence/timezone/missed policy; Some only for the clock provider.

§path: Option<StringLiteral>

path "<file>"file provider, line mode (exactly one of path/watch); rejected elsewhere. The file is read line-by-line; each non-empty line is admitted once as a durable signal fact (spec/std-time.md admission semantics, append-only).

§watch: Option<StringLiteral>

watch "<glob>"file provider, occurrence mode (exactly one of path/watch); rejected elsewhere (spec/std-ingress.md I2a). Each matched file is admitted once per new (path, content-hash) occurrence: a dropped file admits once, an unchanged file never re-admits, a content change re-admits. Content READING stays std.files.

§url: Option<StringLiteral>

url "<url>" — required for the http provider, rejected elsewhere. The URL is GET’d and its JSON-array body admitted one element per signal, keyed by (source, element index) so re-polls are idempotent (append-only).

§dedup: Option<SourceValue>

dedup <observe>.<field> — optional provider delivery-id source for file (line mode) and http sources (spec/std-ingress.md I2a): the named observation field becomes the admission key instead of the positional ordinal, so a re-ordered or head-inserted feed still admits each delivery exactly once.

§observe_binding: Ident

observe as <binding> — binds the provider observation schema.

§emit: SourceEmit

emit <signal> { <field> <value> ... } — maps the observation into the declared signal payload.

§span: SourceSpan

Trait Implementations§

Source§

impl Clone for SourceDecl

Source§

fn clone(&self) -> SourceDecl

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for SourceDecl

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Eq for SourceDecl

Source§

impl PartialEq for SourceDecl

Source§

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

Equality operator ==. Read more
1.0.0 (const: unstable) · Source§

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

Inequality operator !=. Read more
Source§

impl StructuralPartialEq for SourceDecl

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.