Struct WriteSinks 

pub struct WriteSinks<'a> {
    pub indexer_tx: &'a Sender<IndexEvent>,
    pub events: Option<&'a dyn EventPublisher>,
    pub index_health: Option<&'a IndexHealth>,
    pub source: EventSource,
}

The two places a durable write is reported to, and on whose behalf.

Fields

indexer_tx: &'a Sender<IndexEvent>

The in-process indexing queue (D38).

events: Option<&'a dyn EventPublisher>

The event log, when NOTEDTHAT_EVENTS_BACKEND selects one.

index_health: Option<&'a IndexHealth>

Where what happened at the queue — enqueued, refused, or a queue with no worker behind it — is recorded for the health view (#97). None only in tests that have no health view to keep.

source: EventSource

The surface making the write, stamped on every event it publishes.

Implementations

impl<'a> WriteSinks<'a>

pub fn new( indexer_tx: &'a Sender<IndexEvent>, events: Option<&'a dyn EventPublisher>, index_health: &'a IndexHealth, source: EventSource, ) -> Self

Both sinks, recording on index_health.

pub fn indexer_only(indexer_tx: &'a Sender<IndexEvent>) -> Self

The indexing queue alone, as every deployment without an events backend runs, attributed to the HTTP API, with nothing keeping a health record.

Trait Implementations

impl<'a> Clone for WriteSinks<'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> Copy for WriteSinks<'a>