| Copyright | Copyright © 2013-2015 PivotCloud, Inc. |
|---|---|
| License | Apache-2.0 |
| Maintainer | Jon Sterling <jsterling@alephcloud.com> |
| Stability | experimental |
| Safe Haskell | None |
| Language | Haskell2010 |
Aws.Kinesis.Client.Consumer.Kit
Description
- data ConsumerKit
- makeConsumerKit :: KinesisKit -> StreamName -> ConsumerKit
- ckKinesisKit :: Lens' ConsumerKit KinesisKit
- ckStreamName :: Lens' ConsumerKit StreamName
- ckBatchSize :: Lens' ConsumerKit Natural
- ckIteratorType :: Lens' ConsumerKit ShardIteratorType
- ckSavedStreamState :: Lens' ConsumerKit (Maybe SavedStreamState)
- data SavedStreamState
- _SavedStreamState :: Iso' SavedStreamState (Map ShardId SequenceNumber)
Documentation
data ConsumerKit Source
The ConsumerKit contains what is needed to initialize a KinesisConsumer.
makeConsumerKit :: KinesisKit -> StreamName -> ConsumerKit Source
Create a ConsumerKit with default settings (using iterator type
Latest and a batch size of 200).
ckKinesisKit :: Lens' ConsumerKit KinesisKit Source
A lens for _ckKinesisKit.
ckStreamName :: Lens' ConsumerKit StreamName Source
A lens for _ckStreamName.
ckBatchSize :: Lens' ConsumerKit Natural Source
A lens for _ckBatchSize.
ckIteratorType :: Lens' ConsumerKit ShardIteratorType Source
A lens for _ckIteratorType.
ckSavedStreamState :: Lens' ConsumerKit (Maybe SavedStreamState) Source
A lens for _ckSavedStreamState.
data SavedStreamState Source
Instances
_SavedStreamState :: Iso' SavedStreamState (Map ShardId SequenceNumber) Source
An iso for SavedStreamState.