Struct CloudDrainBuilder 

pub struct CloudDrainBuilder { /* private fields */ }

Cloud drain builder.

Implementations

impl CloudDrainBuilder

pub const fn new() -> Self

Create a new cloud drain builder.

pub fn queue_capacity(self, queue_capacity: Option<usize>) -> Self

Set the log message queue capacity or None for unlimited (the default is None).

pub fn max_concurrency(self, max_concurrency: usize) -> Self

Set the maximum number of concurrent message sends (the default is 16).

pub fn initial_retry_delay(self, initial_retry_delay: Duration) -> Self

Set the initial retry delay (the default is 1 second).

pub fn max_retry_delay(self, max_retry_delay: Duration) -> Self

Set the maximum retry delay (the default is 60 seconds).

pub fn max_retries(self, max_retries: Option<u32>) -> Self

Set the maximum number of retries or None for unlimited (the default is unlimited).

pub fn debug(self, debug: bool) -> Self

Enable or disable debug mode (the default is disabled).

In the debug mode you’ll be able to see some runtime info on stderr that will help you with setting up the drain (e.g. failed requests). With debug mode disabled, all errors will be silently ignored.

pub fn build<C, S, M, B, BB>( self, client: C, serializer: S, batch_builder: BB, ) -> (CloudDrain<S, M>, CloudDrainTask, CloudDrainHandle<M>)

where C: Client<Message = B> + Send + Sync + 'static, B: Clone + Send + Sync + 'static, BB: BatchBuilder<Item = M, Batch = B> + Send + 'static, M: Send + 'static,

Build the cloud drain.

Arguments

• client - a cloud service client
• serializer - log message serializer
• batch_builder - log message batch builder

Trait Implementations

impl Default for CloudDrainBuilder

fn default() -> Self

Returns the “default value” for a type.