Struct IngestState 

pub struct IngestState<I> {
    pub ingest: Arc<I>,
    pub limits: IngestLimits,
    pub ready: Arc<AtomicBool>,
    pub notifier: Option<Arc<dyn StreamNotifier>>,
}

State for an ingest-only service.

Fields

ingest: Arc<I>

Backend used for writes.

limits: IngestLimits

Limits enforced before writes reach the backend.

ready: Arc<AtomicBool>

Gates ingest writes only.

notifier: Option<Arc<dyn StreamNotifier>>

Optional live-stream notifier.

Implementations

impl<I> IngestState<I>

where I: Ingest,

pub fn new(ingest: Arc<I>) -> Self

pub fn with_notifier(ingest: Arc<I>, notifier: Arc<dyn StreamNotifier>) -> Self

pub fn with_limits(self, limits: IngestLimits) -> Self

Trait Implementations

impl<I> Clone for IngestState<I>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E> From<AppState<E>> for IngestState<E>

fn from(state: AppState<E>) -> Self

Converts to this type from the input type.