Module processor

Core processor implementation for handling Kinesis streams

This module provides the main processing logic for consuming records from Kinesis streams. It handles:

• Shard discovery and management
• Record batch processing with retries
• Checkpointing of progress
• Monitoring and metrics
• Graceful shutdown

Structs

• BatchProcessingResult 🔒
  Result of processing a batch of records
• BatchProcessor 🔒
• CheckpointMetadata
  Metadata associated with a checkpoint operation
• KinesisProcessor
  Main Kinesis stream processor
• ProcessingContext
  Internal context holding processor state and dependencies
• ProcessorConfig
  Configuration for the Kinesis processor
• RecordMetadata
  Metadata associated with a Kinesis record during processing
• ShardProcessingState 🔒
  Tracks the state of shard processing

Enums

• BatchResult 🔒
  Result of batch processing operations
• InitialPosition
  Specifies where to start reading from in the stream
• RecordProcessingResult 🔒

Traits

• RecordProcessor
  Trait for implementing record processing logic