Struct AppState 

pub struct AppState<E> {
    pub engine: Arc<E>,
    pub ingest_limits: IngestLimits,
    pub ready: Arc<AtomicBool>,
    pub stream: Arc<StreamHub>,
}

All-in-one single-process composition for a backend that serves every store capability. Split deployments construct the narrower capability states directly.

Fields

engine: Arc<E>

Backend that implements every store capability.

ingest_limits: IngestLimits

Limits enforced by the ingest service before writing.

ready: Arc<AtomicBool>

Gates ingest (writes) only. The read and administrative services remain available during drains so that in-flight reads can complete while the worker sheds write traffic.

stream: Arc<StreamHub>

Shared fan-out hub for log.stream.v1.Subscribe.

Implementations

impl<E> AppState<E>

where E: StoreEngine,

pub fn new(engine: Arc<E>) -> Self

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

Trait Implementations

impl<E> Clone for AppState<E>

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.

impl<E> From<AppState<E>> for QueryState<E>

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

Converts to this type from the input type.

impl<E> From<AppState<E>> for PruneState<E>

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

Converts to this type from the input type.

impl<E> From<AppState<E>> for RetentionState<E>

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

Converts to this type from the input type.

impl<E> From<AppState<E>> for StreamState<E>

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

Converts to this type from the input type.