Trait Sourceable

pub trait Sourceable<S>
where
    S: Scope,
    S::Timestamp: Timestamp + Lattice,
{
    // Required method
    fn source(
        &self,
        scope: &mut S,
        context: SourcingContext<S::Timestamp>,
    ) -> Vec<(Aid, AttributeConfig, Stream<S, ((Value, Value), S::Timestamp, isize)>)>;
}

An external data source that can provide Datoms.

Required Methods

fn source( &self, scope: &mut S, context: SourcingContext<S::Timestamp>, ) -> Vec<(Aid, AttributeConfig, Stream<S, ((Value, Value), S::Timestamp, isize)>)>

Conjures from thin air (or from wherever the source lives) one or more timely streams feeding directly into attributes.

Implementors

impl<S: Scope> Sourceable<S> for Source

where S::Timestamp: Timestamp + Lattice,

impl<S: Scope<Timestamp = Duration>> Sourceable<S> for DifferentialLogging

impl<S: Scope<Timestamp = Duration>> Sourceable<S> for TimelyLogging