petri

Function kmsg_log_task

Source
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