List of all items
Structs
- monitoring::MetricsAggregator
- monitoring::MonitoringConfig
- monitoring::ProcessingEvent
- monitoring::ShardMetrics
- monitoring::TestMonitoringHarness
- monitoring::metrics::BatchMetrics
- monitoring::metrics::MetricsAggregator
- monitoring::metrics::ProcessingMetrics
- monitoring::metrics::ShardMetrics
- monitoring::types::MonitoringConfig
- monitoring::types::ProcessingEvent
- monitoring::types::TestMonitoringHarness
- processor::BatchProcessingResult
- processor::BatchProcessor
- processor::CheckpointMetadata
- processor::KinesisProcessor
- processor::ProcessingContext
- processor::ProcessorConfig
- processor::RecordMetadata
- processor::ShardProcessingState
- retry::RetryConfig
- retry::RetryHandle
- retry::backoff::ExponentialBackoff
- retry::backoff::ExponentialBackoffBuilder
- retry::backoff::FixedBackoff
- store::dynamodb::DynamoDbCheckpointStore
- store::dynamodb::DynamoDbCheckpointStoreBuilder
- store::memory::InMemoryCheckpointStore
Enums
- client::KinesisClientError
- error::BeforeCheckpointError
- error::CheckpointError
- error::ProcessingError
- error::ProcessorError
- error::RetryError
- error::ShardError
- monitoring::IteratorEventType
- monitoring::ProcessingEventType
- monitoring::ShardEventType
- monitoring::types::IteratorEventType
- monitoring::types::ProcessingEventType
- monitoring::types::ShardEventType
- processor::BatchResult
- processor::InitialPosition
- processor::RecordProcessingResult
- retry::error::RetryError
Traits
- client::KinesisClientTestExt
- client::KinesisClientTrait
- processor::RecordProcessor
- retry::backoff::Backoff
- store::CheckpointStore
- store::CheckpointStoreTestExt