Struct EventSink 

pub struct EventSink { /* private fields */ }

Implementations

impl EventSink

pub fn new() -> Self

pub fn with_forwarder(self, tx: UnboundedSender<EventEnvelope>) -> Self

pub fn with_redactor(self, redactor: Arc<Redactor>) -> Self

pub fn next_seq_peek(&self) -> u64

pub fn restore_seq(&self, last_seq: u64)

pub fn reserve_seq(&self) -> u64

pub fn emit_returning_seq(&self, event: Event) -> u64

pub fn emit(&self, event: Event)

pub fn events_handle(&self) -> Arc<Mutex<Vec<EventEnvelope>>>

pub fn redactor(&self) -> Option<Arc<Redactor>>

pub fn mark_compacted(&self)

pub fn last_compact_ago_seconds(&self) -> Option<i64>

pub fn drain(&self) -> Vec<Event>

pub fn snapshot(&self) -> Vec<Event>

pub fn snapshot_envelopes(&self) -> Vec<EventEnvelope>

Trait Implementations

impl Clone for EventSink

fn clone(&self) -> EventSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for EventSink

fn default() -> EventSink

Returns the “default value” for a type.