Struct JournaldLogger 

pub(super) struct JournaldLogger {
    shared: Arc<Shared>,
}

Writes the container output to the journal with the container ID fields and priorities conmon uses, so that journalctl CONTAINER_ID=<id> finds it and podman can put partial lines back together.

Fields

shared: Arc<Shared>

Shared with the blocking tasks which send the entries.

Implementations

impl JournaldLogger

const SHORT_ID_LEN: usize = 12

The length of the short container ID field.

const PARTIAL_FIELD: (&'static str, &'static str)

The field marking a line which had no ending yet.

pub(super) fn new(id: &str, name: &str) -> Self

A logger with the fields conmon writes: the container ID, the name if given and the syslog identifier, which is the name, or the short container ID without one, like for conmon without a tag.

fn priority(pipe: Pipe) -> Priority

The journal priority of the output of a pipe.

fn send(shared: &Shared, pipe: Pipe, lines: &[Line<'_>], wait: Wait) -> usize

Send the lines to the journal and return how many of them it took or got dropped. A journal which is unavailable, for example while it restarts, must not end the output of the container, so failures are only logged, once until a send succeeds again. Without a journal, or with one which did not take a line in time, the rest of the chunk is dropped right away instead of failing the same way line by line. Without waiting, the sending stops at the first line which the journal does not take right away. Waiting, the lines which did not go out by the deadline of the wait get dropped, a journal which takes each line just in time would block the log of the container for minutes per chunk otherwise.

impl JournaldLogger

pub(super) async fn write_lines( &self, pipe: Pipe, lines: &[Line<'_>], ) -> Result<()>

Write whole lines of output of the pipe, one entry each. A journal which keeps up takes the lines right away. The ones it does not take are sent from a single blocking task, which waits for it a bounded time, instead of one per line, unless the last wait timed out, see Shared::timed_out. The lines which borrow the chunk get copied for it, the others share their buffer.

Trait Implementations

impl Debug for JournaldLogger

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.