Struct ProcessingContext

pub struct ProcessingContext<P, C, S>
where
    P: RecordProcessor + Send + Sync + 'static,
    C: KinesisClientTrait + Send + Sync + Clone + 'static,
    S: CheckpointStore + Send + Sync + Clone + 'static,
{
    processor: Arc<P>,
    client: Arc<C>,
    store: Arc<S>,
    config: ProcessorConfig,
    monitoring_tx: Option<Sender<ProcessingEvent>>,
}

Internal context holding processor state and dependencies

Fields

processor: Arc<P>

The user-provided record processor implementation

client: Arc<C>

AWS Kinesis client

store: Arc<S>

Checkpoint storage implementation

config: ProcessorConfig

Processor configuration

monitoring_tx: Option<Sender<ProcessingEvent>>

Channel for sending monitoring events

Implementations

impl<P, C, S> ProcessingContext<P, C, S>

where P: RecordProcessor + Send + Sync + 'static, C: KinesisClientTrait + Send + Sync + Clone + 'static, S: CheckpointStore + Send + Sync + Clone + 'static,

pub fn new( processor: P, client: C, store: S, config: ProcessorConfig, monitoring_tx: Option<Sender<ProcessingEvent>>, ) -> Self

Creates a new processing context

Arguments

• processor - The record processor implementation
• client - AWS Kinesis client
• store - Checkpoint storage implementation
• config - Processor configuration
• monitoring_tx - Optional channel for monitoring events

async fn send_monitoring_event(&self, event: ProcessingEvent)

Sends a monitoring event if monitoring is enabled

fn is_iterator_expired(&self, error: &KinesisClientError) -> bool

Checks if an error indicates an expired iterator

Trait Implementations

impl<P: RecordProcessor, C: KinesisClientTrait + Clone, S: CheckpointStore + Clone> Clone for ProcessingContext<P, C, S>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.