pub struct BatchConfig { /* private fields */ }
Expand description

Batch span processor configuration

Implementations§

source§

impl BatchConfig

source

pub fn with_max_queue_size(self, max_queue_size: usize) -> BatchConfig

Set max_queue_size for BatchConfig. It’s the maximum queue size to buffer spans for delayed processing. If the queue gets full it will drops the spans. The default value of is 2048.

source

pub fn with_max_export_batch_size( self, max_export_batch_size: usize ) -> BatchConfig

Set max_export_batch_size for BatchConfig. It’s the maximum number of spans to process in a single batch. If there are more than one batch worth of spans then it processes multiple batches of spans one batch after the other without any delay. The default value is 512.

source

pub fn with_max_concurrent_exports( self, max_concurrent_exports: usize ) -> BatchConfig

Set max_concurrent_exports for BatchConfig. It’s the maximum number of concurrent exports. Limits the number of spawned tasks for exports and thus memory consumed by an exporter. The default value is 1. IF the max_concurrent_exports value is default value, it will cause exports to be performed synchronously on the BatchSpanProcessor task.

source

pub fn with_scheduled_delay(self, scheduled_delay: Duration) -> BatchConfig

Set scheduled_delay_duration for BatchConfig. It’s the delay interval in milliseconds between two consecutive processing of batches. The default value is 5000 milliseconds.

source

pub fn with_max_export_timeout( self, max_export_timeout: Duration ) -> BatchConfig

Set max_export_timeout for BatchConfig. It’s the maximum duration to export a batch of data. The The default value is 30000 milliseconds.

Trait Implementations§

source§

impl Debug for BatchConfig

source§

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

Formats the value using the given formatter. Read more
source§

impl Default for BatchConfig

source§

fn default() -> BatchConfig

Returns the “default value” for a type. Read more

Auto Trait Implementations§

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