Struct StreamManager 

pub struct StreamManager<A: Application> { /* private fields */ }

Implementations

impl<A: Application> StreamManager<A>

pub fn follow(&self, resume: Cursor) -> StreamFeed<A>

pub fn frontier(&self) -> Cursor

pub fn publish<S: Stream<A>>(&self, row: S)

pub fn query<S: Stream<A>>(&self, range: impl RangeBounds<Position>) -> Query<S>

pub fn survey<S: Stream<A> + Axial>( &self, range: impl RangeBounds<u64>, ) -> Survey<S>

pub fn seal<S: Stream<A>>(&self) -> Seal<S>

pub fn watch<S: Stream<A>>( &self, ) -> impl Stream<Item = Item<S>> + Send + Unpin + use<S, A>

pub fn batches<S: Stream<A> + Batched>(&self) -> Batches<S>

pub fn demand<S: Stream<A>>(&self) -> Demand

impl<A: Application> StreamManager<A>

pub async fn admit( &self, owner: &str, declaration: StreamDeclaration, ) -> Result<PublicationLease, StreamAdmissionError>

pub fn validate_publications( &self, owner: &str, declarations: impl IntoIterator<Item = StreamDeclaration>, ) -> Result<(), StreamAdmissionError>

pub async fn admit_all( &self, owner: &str, declarations: impl IntoIterator<Item = StreamDeclaration>, ) -> Result<Vec<PublicationLease>, StreamAdmissionError>

pub fn publication(&self, id: &str, version: u32) -> Option<PluginStream>

pub fn definitions(&self) -> Vec<Definition>

Trait Implementations

impl<A: Application> Clone for StreamManager<A>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Application> Debug for StreamManager<A>

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

Formats the value using the given formatter.