Struct DirectConfig 

pub struct DirectConfig {
    pub batch_length: u32,
    pub linger_time: IggyDuration,
}

The Apache Iggy producer/consumer escape hatch: same types Topic::iggy_producer/Topic::iggy_consumer/Topic::iggy_consumer_group return, and the stored message a failed publish hands back, re-exported so reaching for them doesn’t need an iggy dependency of your own. Configuration for a direct producer.

A direct producer writes from the calling task. send() splits a batch into requests of at most batch_length messages, awaits them one after another and returns their confirmations. Nothing is buffered between calls. Unlike background mode, there is no queue to bound, no worker to route to, and nothing to flush on shutdown.

A send that fails part way through returns IggyError::ProducerSendFailed, where committed holds the confirmations returned for earlier requests and failed holds the unconfirmed tail. See send() for what resending that tail means.

Examples

use iggy::prelude::*;
use std::time::Duration;

// One request per message, with no configured delay between sequential calls.
let low_latency = DirectConfig::builder()
    .batch_length(1)
    .linger_time(IggyDuration::from(0))
    .build();

// Up to 500 messages per request, with a 200 ms minimum gap between sequential sends.
let paced = DirectConfig::builder()
    .batch_length(500)
    .linger_time(IggyDuration::new(Duration::from_millis(200)))
    .build();

Fields

batch_length: u32

Maximum number of messages in one request.

A send carrying more than this is split into consecutive requests of this size, each awaited before the next one starts. A batch of 2500 therefore becomes three requests at the default.

0 limits to 1,000,000 messages per request.

linger_time: IggyDuration

Requested minimum gap between sequential direct sends.

A send waits out whatever is left of this interval since the previous request completed successfully. Concurrent callers can wait against the same timestamp and then proceed together, so this is not a global rate limiter. When one call is split by batch_length, the linger interval is applied before the call rather than between its chunks. The default of zero does not wait.

Implementations

impl DirectConfig

pub fn builder() -> DirectConfigBuilder

Create an instance of DirectConfig using the builder syntax

Trait Implementations

impl Clone for DirectConfig

fn clone(&self) -> DirectConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.