petri

Function kmsg_log_task

Source 
pub async fn kmsg_log_task(
    log_file: PetriLogFile,
    diag_client: DiagClient,
) -> Result<()>
Expand description

read from the kmsg stream and write entries to the log