pub async fn kmsg_log_task(
log_file: PetriLogFile,
file_stream: KmsgStream,
) -> Result<()>
Expand description
read from the kmsg stream and write entries to the log
pub async fn kmsg_log_task(
log_file: PetriLogFile,
file_stream: KmsgStream,
) -> Result<()>
read from the kmsg stream and write entries to the log