Struct Sink

pub struct Sink<T: AsyncWrite + Send + Unpin + 'static> { /* private fields */ }

A sink to write log lines to.

Caveats

To prevent interleaved output, you should clone a SinkHandle instead of creating a new one if you want to write to the same sink.

Examples

use aws_lambda_log_proxy::{Sink, SinkHandle};

#[tokio::main]
async fn main() {
  let sink: SinkHandle = Sink::stdout().spawn();
  let sink2 = sink.clone();
}

Implementations

impl<T: AsyncWrite + Send + Unpin + 'static> Sink<T>

pub fn new(writer: T) -> Self

Create a new Standard sink from an AsyncWrite implementor.

pub fn format(self, kind: OutputFormat) -> Self

Set the output format of the sink.

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

Set the buffer size of the sink. The default buffer size is 16 lines.

pub fn spawn(self) -> SinkHandle

Spawn the sink and return a SinkHandle to write to it.

impl Sink<Stdout>

pub fn stdout() -> Self

Create a new stdout sink.

impl Sink<Stderr>

pub fn stderr() -> Self

Create a new stderr sink.

impl Sink<MockSink>

pub fn mock() -> Self

Create a new MockSink for testing.

impl Sink<File>

pub fn lambda_telemetry_log_fd() -> Result<Self, Error>

Create a new sink from the _LAMBDA_TELEMETRY_LOG_FD environment variable.