Struct slog_async::AsyncCore

pub struct AsyncCore { /* fields omitted */ }

Core of Async drain

See Async for documentation.

Wrapping AsyncCore allows implementing custom overflow (and other errors) handling strategy.

Note: On drop AsyncCore waits for it’s worker-thread to finish (after handling all previous Records sent to it). If you can’t tolerate the delay, make sure you drop it eg. in another thread.

Implementations

impl AsyncCore

pub fn new<D>(drain: D) -> Self where
    D: Drain<Err = Never, Ok = ()> + Send + 'static,
    D: RefUnwindSafe, 

New AsyncCore with default parameters

pub fn custom<D: Drain<Err = Never, Ok = ()> + Send + 'static>(
    drain: D
) -> AsyncCoreBuilder<D>

Build AsyncCore drain with custom parameters

Trait Implementations

impl Drain for AsyncCore

type Ok = ()

Type returned by this drain

type Err = AsyncError

Type of potential errors that can be returned by this Drain

fn log(
    &self,
    record: &Record<'_>,
    logger_values: &OwnedKVList
) -> AsyncResult<()>

Handle one logging statement (Record)

pub fn is_enabled(&self, level: Level) -> bool

Avoid: Check if messages at the specified log level are maybe enabled for this logger.

pub fn is_critical_enabled(&self) -> bool

Avoid: See is_enabled

pub fn is_error_enabled(&self) -> bool

Avoid: See is_enabled

pub fn is_warning_enabled(&self) -> bool

Avoid: See is_enabled

pub fn is_info_enabled(&self) -> bool

Avoid: See is_enabled

pub fn is_debug_enabled(&self) -> bool

Avoid: See is_enabled

pub fn is_trace_enabled(&self) -> bool

Avoid: See is_enabled

pub fn map<F, R>(self, f: F) -> R where
    F: FnOnce(Self) -> R, 

Pass Drain through a closure, eg. to wrap into another Drain.

pub fn filter<F>(self, f: F) -> Filter<Self, F> where
    F: FilterFn, 

Filter logging records passed to Drain

pub fn filter_level(self, level: Level) -> LevelFilter<Self>

Filter logging records passed to Drain (by level)

pub fn map_err<F, E>(self, f: F) -> MapError<Self, E> where
    F: MapErrFn<Self::Err, E>, 

Map logging errors returned by this drain

pub fn ignore_res(self) -> IgnoreResult<Self>

Ignore results returned by this drain

pub fn fuse(self) -> Fuse<Self> where
    Self::Err: Debug, 

Make Self panic when returning any errors

impl Drop for AsyncCore

fn drop(&mut self)

Executes the destructor for this type.