Struct PollConsumerConfig 

pub struct PollConsumerConfig {
    pub consumer_id: CdcConsumerId,
    pub poll_interval: Duration,
    pub priority: Priority,
    pub max_batch_size: Option<u64>,
}

Configuration for a CDC poll consumer

Fields

consumer_id: CdcConsumerId

Unique identifier for this consumer

poll_interval: Duration

How often to poll for new CDC events

priority: Priority

Priority for the polling task in the worker pool

max_batch_size: Option<u64>

Maximum batch size for fetching CDC events (None = unbounded)

Implementations

impl PollConsumerConfig

pub fn new( consumer_id: CdcConsumerId, poll_interval: Duration, max_batch_size: Option<u64>, ) -> Self

pub fn with_priority(self, priority: Priority) -> Self

Trait Implementations

impl Clone for PollConsumerConfig

fn clone(&self) -> PollConsumerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PollConsumerConfig

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

Formats the value using the given formatter.