MCPcopy Create free account
hub / github.com/comnik/declarative-dataflow / Sourceable

Interface Sourceable

src/sources/mod.rs:47–63  ·  view source on GitHub ↗

An external data source that can provide Datoms.

Source from the content-addressed store, hash-verified

45
46/// An external data source that can provide Datoms.
47pub trait Sourceable<S>
48where
49 S: Scope,
50 S::Timestamp: Timestamp + Lattice,
51{
52 /// Conjures from thin air (or from wherever the source lives) one
53 /// or more timely streams feeding directly into attributes.
54 fn source(
55 &self,
56 scope: &mut S,
57 context: SourcingContext<S::Timestamp>,
58 ) -> Vec<(
59 Aid,
60 AttributeConfig,
61 Stream<S, ((Value, Value), S::Timestamp, isize)>,
62 )>;
63}
64
65/// Supported external data sources.
66#[derive(Hash, PartialEq, Eq, PartialOrd, Ord, Clone, Debug, Serialize, Deserialize)]

Callers

nothing calls this directly

Implementers 6

timely_logging.rssrc/sources/timely_logging.rs
mod.rssrc/sources/mod.rs
json_file.rssrc/sources/json_file.rs
declarative_logging.rssrc/sources/declarative_logging.rs
differential_logging.rssrc/sources/differential_logging.rs
csv_file.rssrc/sources/csv_file.rs

Calls

no outgoing calls

Tested by

no test coverage detected