Struct NonBlockingBuilder
pub struct NonBlockingBuilder { /* private fields */ }Expand description
A builder for NonBlocking.
Implementations§
§impl NonBlockingBuilder
impl NonBlockingBuilder
pub fn buffered_lines_limit(
self,
buffered_lines_limit: usize,
) -> NonBlockingBuilder
pub fn buffered_lines_limit( self, buffered_lines_limit: usize, ) -> NonBlockingBuilder
Sets the number of lines to buffer before dropping logs or exerting backpressure on senders
pub fn lossy(self, is_lossy: bool) -> NonBlockingBuilder
pub fn lossy(self, is_lossy: bool) -> NonBlockingBuilder
Sets whether NonBlocking should be lossy or not.
If set to true, logs will be dropped when the buffered limit is reached. If false, backpressure
will be exerted on senders, blocking them until the buffer has capacity again.
By default, the built NonBlocking will be lossy.
pub fn thread_name(self, name: &str) -> NonBlockingBuilder
pub fn thread_name(self, name: &str) -> NonBlockingBuilder
Override the worker thread’s name.
The default worker thread name is “tracing-appender”.
pub fn finish<T>(self, writer: T) -> (NonBlocking, WorkerGuard)
pub fn finish<T>(self, writer: T) -> (NonBlocking, WorkerGuard)
Completes the builder, returning the configured NonBlocking.
Trait Implementations§
§impl Debug for NonBlockingBuilder
impl Debug for NonBlockingBuilder
§impl Default for NonBlockingBuilder
impl Default for NonBlockingBuilder
§fn default() -> NonBlockingBuilder
fn default() -> NonBlockingBuilder
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for NonBlockingBuilder
impl RefUnwindSafe for NonBlockingBuilder
impl Send for NonBlockingBuilder
impl Sync for NonBlockingBuilder
impl Unpin for NonBlockingBuilder
impl UnwindSafe for NonBlockingBuilder
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a rama_grpc::Request§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Create a new
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more