Struct slog_async::AsyncCore
[−]
[src]
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 Record
s sent to it). If you can't tolerate the
delay, make sure you drop it eg. in another thread.
Methods
impl AsyncCore
[src]
fn new<D>(drain: D) -> Self where
D: Drain<Err = Never, Ok = ()> + Send + 'static,
D: RefUnwindSafe,
[−]
D: Drain<Err = Never, Ok = ()> + Send + 'static,
D: RefUnwindSafe,
New AsyncCore
with default parameters
fn custom<D: Drain<Err = Never, Ok = ()> + Send + 'static>(
drain: D
) -> AsyncCoreBuilder<D>
[−]
drain: D
) -> AsyncCoreBuilder<D>
Build AsyncCore
drain with custom parameters
Trait Implementations
impl Drain for AsyncCore
[src]
type Ok = ()
Type returned by this drain Read more
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
) Read more
fn map<F, R>(self, f: F) -> R where
F: FnOnce(Self) -> R,
[−]
F: FnOnce(Self) -> R,
Pass Drain
through a closure, eg. to wrap into another Drain
. Read more
fn filter<F>(self, f: F) -> Filter<Self, F> where
F: FilterFn,
[−]
F: FilterFn,
Filter logging records passed to Drain
Read more
fn filter_level(self, level: Level) -> LevelFilter<Self>
[−]
Filter logging records passed to Drain
(by level) Read more
fn map_err<F, E>(self, f: F) -> MapError<Self, E> where
F: MapErrFn<Self::Err, E>,
[−]
F: MapErrFn<Self::Err, E>,
Map logging errors returned by this drain Read more
fn ignore_res(self) -> IgnoreResult<Self>
[−]
Ignore results returned by this drain Read more
fn fuse(self) -> Fuse<Self> where
Self::Err: Debug,
[−]
Self::Err: Debug,
Make Self
panic when returning any errors Read more