Trait Source 

pub trait Source<T: DatasetItem>: Send + Sync {
    // Required methods
    fn name(&self) -> &str;
    fn stream(self: Box<Self>, cancel: CancellationToken) -> BoxItemStream<T>;
    fn cache_key(&self) -> Value;
    fn max_items(&self) -> Option<usize>;

    // Provided methods
    fn display_name(&self) -> &str { ... }
    fn set_resume_state(&mut self, _offset: usize, _already_fetched: usize) { ... }
}

Protocol for dataset sources over any DatasetItem type.

Required Methods

fn name(&self) -> &str

Stable source identifier used in manifests.

fn stream(self: Box<Self>, cancel: CancellationToken) -> BoxItemStream<T>

Stream items from this source.

fn cache_key(&self) -> Value

Stable cache key describing this source’s configured inputs.

fn max_items(&self) -> Option<usize>

Optional maximum number of items this source will emit.

Provided Methods

fn display_name(&self) -> &str

Human-readable source label.

fn set_resume_state(&mut self, _offset: usize, _already_fetched: usize)

Configure resume state before streaming.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl Source<DatasetRecord> for RecordSource