pub struct BatchLogProcessorBuilder<E, R> { /* private fields */ }
Expand description

A builder for creating BatchLogProcessor instances.

Implementations§

source§

impl<E, R> BatchLogProcessorBuilder<E, R>where E: LogExporter + 'static, R: RuntimeChannel<BatchMessage>,

source

pub fn with_max_queue_size(self, size: usize) -> BatchLogProcessorBuilder<E, R>

Set max queue size for batches

source

pub fn with_scheduled_delay( self, delay: Duration ) -> BatchLogProcessorBuilder<E, R>

Set scheduled delay for batches

source

pub fn with_max_timeout( self, timeout: Duration ) -> BatchLogProcessorBuilder<E, R>

Set max timeout for exporting.

source

pub fn with_max_export_batch_size( self, size: usize ) -> BatchLogProcessorBuilder<E, R>

Set max export size for batches, should always less than or equals to max queue size.

If input is larger than max queue size, will lower it to be equal to max queue size

source

pub fn build(self) -> BatchLogProcessor<R>

Build a batch processor

Trait Implementations§

source§

impl<E, R> Debug for BatchLogProcessorBuilder<E, R>where E: Debug, R: Debug,

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<E, R> RefUnwindSafe for BatchLogProcessorBuilder<E, R>where E: RefUnwindSafe, R: RefUnwindSafe,

§

impl<E, R> Send for BatchLogProcessorBuilder<E, R>where E: Send, R: Send,

§

impl<E, R> Sync for BatchLogProcessorBuilder<E, R>where E: Sync, R: Sync,

§

impl<E, R> Unpin for BatchLogProcessorBuilder<E, R>where E: Unpin, R: Unpin,

§

impl<E, R> UnwindSafe for BatchLogProcessorBuilder<E, R>where E: UnwindSafe, R: UnwindSafe,

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> FutureExt for T

source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more