Enum IngestDecision 

pub enum IngestDecision<WorkerId> {
    Route(WorkerId),
    DropStale,
    NoRoute,
}

Routing decision made by an ingest router.

Variants

Route(WorkerId)

Send the write to this worker.

DropStale

Drop the write because it is older than the configured watermark.

NoRoute

No assigned range matched the write key.

Trait Implementations

impl<WorkerId: Clone> Clone for IngestDecision<WorkerId>

fn clone(&self) -> IngestDecision<WorkerId>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<WorkerId: Debug> Debug for IngestDecision<WorkerId>

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

Formats the value using the given formatter.

impl<WorkerId: PartialEq> PartialEq for IngestDecision<WorkerId>

fn eq(&self, other: &IngestDecision<WorkerId>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<WorkerId: Eq> Eq for IngestDecision<WorkerId>

impl<WorkerId> StructuralPartialEq for IngestDecision<WorkerId>