Struct AsyncPoolSinkBuilder 

pub struct AsyncPoolSinkBuilder { /* private fields */ }

Implementations

impl AsyncPoolSinkBuilder

pub fn sink(self, sink: Arc<dyn Sink>) -> Self

Available on crate feature multi-thread only.

Add a Sink.

Examples found in repository

examples/07-async.rs (line 13)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let path = env::current_exe()?.with_file_name("async.log");
    let file_sink = FileSink::builder().path(path).build_arc()?;

    // AsyncPoolSink is a combined sink which wraps other sinks
    let async_pool_sink = AsyncPoolSink::builder().sink(file_sink).build_arc()?;

    let async_logger = Logger::builder()
        .sink(async_pool_sink)
        .flush_level_filter(LevelFilter::All)
        .build_arc()?;

    info!(logger: async_logger, "Hello, async!");

    Ok(())
}

pub fn sinks<I>(self, sinks: I) -> Self

where I: IntoIterator<Item = Arc<dyn Sink>>,

Available on crate feature multi-thread only.

Add multiple Sinks.

pub fn overflow_policy(self, overflow_policy: OverflowPolicy) -> Self

Available on crate feature multi-thread only.

Specifies a overflow policy.

This parameter is optional, and defaults to OverflowPolicy::Block.

When the channel is full, an incoming operation is handled according to the specified policy.

pub fn thread_pool(self, thread_pool: Arc<ThreadPool>) -> Self

Available on crate feature multi-thread only.

Specifies a custom thread pool.

This parameter is optional, and defaults to the internal shared default thread pool.

pub fn level_filter(self, level_filter: LevelFilter) -> Self

Available on crate feature multi-thread only.

Specifies a log level filter.

This parameter is optional, and defaults to LevelFilter::All.

pub fn error_handler<F: Into<ErrorHandler>>(self, handler: F) -> Self

Available on crate feature multi-thread only.

Specifies an error handler.

This parameter is optional, and defaults to ErrorHandler::default().

pub fn build(self) -> Result<AsyncPoolSink>

Available on crate feature multi-thread only.

Builds a AsyncPoolSink.

pub fn build_arc(self) -> Result<Arc<AsyncPoolSink>>

Available on crate feature multi-thread only.

Builds a Arc<AsyncPoolSink>.

This is a shorthand method for .build().map(Arc::new).

Examples found in repository

examples/07-async.rs (line 13)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let path = env::current_exe()?.with_file_name("async.log");
    let file_sink = FileSink::builder().path(path).build_arc()?;

    // AsyncPoolSink is a combined sink which wraps other sinks
    let async_pool_sink = AsyncPoolSink::builder().sink(file_sink).build_arc()?;

    let async_logger = Logger::builder()
        .sink(async_pool_sink)
        .flush_level_filter(LevelFilter::All)
        .build_arc()?;

    info!(logger: async_logger, "Hello, async!");

    Ok(())
}