Struct ProcessorConfig

pub struct ProcessorConfig {

    pub stream_name: String,
    pub batch_size: i32,
    pub api_timeout: Duration,
    pub processing_timeout: Duration,
    pub total_timeout: Option<Duration>,
    pub max_retries: Option<u32>,
    pub shard_refresh_interval: Duration,
    pub max_concurrent_shards: Option<u32>,
    pub monitoring: MonitoringConfig,
    pub initial_position: InitialPosition,
    pub prefer_stored_checkpoint: bool,
    pub minimum_batch_retrieval_time: Duration,
    pub max_batch_retrieval_loops: Option<u32>,
}

Configuration for the Kinesis processor

Fields

stream_name: String

Name of the Kinesis stream to process

batch_size: i32

Maximum number of records to request per GetRecords call

api_timeout: Duration

Timeout for API calls to AWS

processing_timeout: Duration

Maximum time allowed for processing a single record

total_timeout: Option<Duration>

Optional total runtime limit

max_retries: Option<u32>

Maximum number of retry attempts (None for infinite)

shard_refresh_interval: Duration

How often to refresh the shard list

max_concurrent_shards: Option<u32>

Maximum number of shards to process concurrently

monitoring: MonitoringConfig

Monitoring configuration

initial_position: InitialPosition

Where to start reading from in the stream

prefer_stored_checkpoint: bool

Whether to prefer stored checkpoints over initial position

minimum_batch_retrieval_time: Duration

Minimum time to retrieve a batch of records from multiple client batch retrievals

max_batch_retrieval_loops: Option<u32>

Maximum number of loops to retrieve batches of records

Trait Implementations

impl Clone for ProcessorConfig

fn clone(&self) -> ProcessorConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessorConfig

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

Formats the value using the given formatter.

impl Default for ProcessorConfig

fn default() -> Self

Returns the “default value” for a type.