Struct archivist_lib::logs::repository::LogsRepository

pub struct LogsRepository { /* private fields */ }

LogsRepository holds all diagnostics data and is a singleton wrapped by multiple [pipeline::Pipeline]s in a given Archivist instance.

Implementations

impl LogsRepository

pub fn new(logs_max_cached_original_bytes: u64, parent: &Node) -> Arc<Self>

pub fn drain_debuglog<K>(&self, klog_reader: K)

where K: DebugLog + Send + Sync + 'static,

Drain the kernel’s debug log. The returned future completes once existing messages have been ingested.

pub fn logs_cursor( &self, mode: StreamMode, selectors: Option<Vec<Selector>>, parent_trace_id: Id ) -> impl Stream<Item = Arc<LogsData>> + Send + 'static

pub fn get_log_container( &self, identity: Arc<ComponentIdentity> ) -> Arc<LogsArtifactsContainer>

pub async fn wait_for_termination(&self)

Stop accepting new messages, ensuring that pending Cursors return Poll::Ready(None) after consuming any messages received before this call.

pub fn stop_accepting_new_log_sinks(&self)

Closes the connection in which new logger draining tasks are sent. No more logger tasks will be accepted when this is called and we’ll proceed to terminate logs.

pub fn new_interest_connection(&self) -> usize

Returns an id to use for a new interest connection. Used by both LogSettings and Log, to ensure shared uniqueness of their connections.

pub fn update_logs_interest( &self, connection_id: usize, selectors: Vec<LogInterestSelector> )

Updates log selectors associated with an interest connection.

pub fn finish_interest_connection(&self, connection_id: usize)

Indicates that the connection associated with the given ID is now done.

Trait Implementations

impl EventConsumer for LogsRepository

fn handle(self: Arc<Self>, event: Event)

Event consumers will receive a call on this method when an event they are interested on happens.