Struct SimpleProcessor

pub struct SimpleProcessor<T> {
    pub transformer: T,
    pub sink: SinkHandle,
    /* private fields */
}

Process log lines with Self::transformer and write them to Self::sink.

You can use SimpleProcessorBuilder to create this.

Fields

transformer: T

See SimpleProcessorBuilder::transformer.

sink: SinkHandle

See SimpleProcessorBuilder::sink.

Implementations

impl<T> SimpleProcessor<T>

pub fn new(transformer: T, sink: SinkHandle) -> Self

Trait Implementations

impl<T: FnMut(String) -> Option<String> + Send + 'static> Processor for SimpleProcessor<T>

async fn process(&mut self, line: String, timestamp: Timestamp)

Process a log line. The line is guaranteed to be non-empty and does not contain a newline character.

async fn truncate(&mut self)

Flushes the underlying output stream, ensuring that all intermediately buffered contents reach their destination. This method is called when the current invocation is about to end (the proxy got the request of invocation/next).