/// Ingest an individual log message.
Ingest an individual log message.
Ingest an individual log message .
async fn ingest_message(&self, log_msg: Message, source: stats::LogSource) {
        let mut inner = self.inner.lock().await;
        inner.stats.record_log(&log_msg, source);
        inner.listeners.send(&log_msg).await;
        inner.log_msg_buffer.push(log_msg);
    }
async fn ingest_message ( & self , log_msg : Message , source : stats :: LogSource ) { let mut inner = self . inner . lock ( ) . await ; inner . stats . record_log ( & log_msg , source ) ; inner . listeners . send ( & log_msg ) . await ; inner . log_msg_buffer . push ( log_msg ) ; }
Ingest an individual log message.
Ingest an individual log message .
&self
log_msg
Message
source
stats::LogSource