Struct LogProxy

pub struct LogProxy<P> {
    pub processor: P,
    pub buffer_size: usize,
    pub port: u16,
}

Examples

Simple creation:

use aws_lambda_log_proxy::{LogProxy, Sink};

LogProxy::new().simple(|p| p.sink(Sink::stdout().spawn()).build()).start().await;

Custom creation:

use aws_lambda_log_proxy::{LogProxy, Processor, Timestamp};

pub struct MyProcessor;

impl Processor for MyProcessor {
  async fn process(&mut self, _line: String, _timestamp: Timestamp) { }
  async fn truncate(&mut self) { }
}

LogProxy::new().processor(MyProcessor).buffer_size(1024).port(1234).start().await;

Fields

processor: P

The processor for stdin.

buffer_size: usize

See Self::buffer_size.

port: u16

See Self::port.

Implementations

impl LogProxy<()>

pub fn new() -> Self

Create a new instance with the default properties and a mock processor which will discard all logs.

impl<P> LogProxy<P>

pub fn processor<T>(self, processor: T) -> LogProxy<T>

Set Self::processor to a custom processor.

pub fn simple<T>( self, builder: impl FnOnce(SimpleProcessorBuilder<fn(String) -> Option<String>, ()>) -> SimpleProcessor<T>, ) -> LogProxy<SimpleProcessor<T>>

Set Self::processor to a SimpleProcessor via SimpleProcessorBuilder.

Examples

use aws_lambda_log_proxy::{LogProxy, Sink};

LogProxy::new().simple(|p| p.sink(Sink::stdout().spawn()).build());

pub fn buffer_size(self, buffer_size: usize) -> Self

Set how many lines can be buffered if the processing is slow. If the handler process writes too many lines then return the response immediately, the suppression of invocation/next might not working, maybe some logs will be processed in the next invocation. Increase this value should help to prevent logs from being lost. The default value is 256.

pub fn port(self, port: u16) -> Self

Set the port for the log proxy. The default value is 3000.

pub async fn start(self)

where P: Processor,

Start the log proxy. This will block the current thread.

Trait Implementations

impl<P: Default> Default for LogProxy<P>

fn default() -> Self

Returns the “default value” for a type.