| 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.Producer.Kit
Description
- data ProducerKit
- makeProducerKit :: KinesisKit -> StreamName -> ProducerKit
- pkKinesisKit :: Lens' ProducerKit KinesisKit
- pkStreamName :: Lens' ProducerKit StreamName
- pkBatchPolicy :: Lens' ProducerKit BatchPolicy
- pkRetryPolicy :: Lens' ProducerKit RetryPolicy
- pkMessageQueueBounds :: Lens' ProducerKit Natural
- pkMaxConcurrency :: Lens' ProducerKit Natural
- pkCleanupTimeout :: Lens' ProducerKit (Maybe Natural)
- pkQueueImplementation :: Setter' ProducerKit QueueImplementation
- data QueueImplementation = forall proxy q . BoundedCloseableQueue q MessageQueueItem => QueueImplementation (proxy q)
- defaultQueueImplementation :: QueueImplementation
- data BatchPolicy
- defaultBatchPolicy :: BatchPolicy
- bpBatchSize :: Lens' BatchPolicy Natural
- data RetryPolicy
- defaultRetryPolicy :: RetryPolicy
- rpRetryCount :: Lens' RetryPolicy Natural
- pattern MaxMessageSize :: (Num a, Eq a) => a
Producer Kit
data ProducerKit Source
The basic input required to construct a Kinesis producer.
makeProducerKit :: KinesisKit -> StreamName -> ProducerKit Source
Create a ProducerKit with default settings.
pkKinesisKit :: Lens' ProducerKit KinesisKit Source
A lens for _pkKinesisKit.
pkStreamName :: Lens' ProducerKit StreamName Source
A lens for _pkStreamName.
pkBatchPolicy :: Lens' ProducerKit BatchPolicy Source
A lens for _pkBatchPolicy.
pkRetryPolicy :: Lens' ProducerKit RetryPolicy Source
A lens for _pkRetryPolicy.
pkMessageQueueBounds :: Lens' ProducerKit Natural Source
A lens for _pkMessageQueueBounds.
pkMaxConcurrency :: Lens' ProducerKit Natural Source
A lens for _pkMaxConcurrency.
pkCleanupTimeout :: Lens' ProducerKit (Maybe Natural) Source
A lens for _pkCleanupTimeout.
pkQueueImplementation :: Setter' ProducerKit QueueImplementation Source
A lens for _pkQueueImplementation.
Queue Implementations
data QueueImplementation Source
A proxy object for specifying a concrete queue implementation. You may
provide your own, or use defaultQueueImplementation.
Constructors
| forall proxy q . BoundedCloseableQueue q MessageQueueItem => QueueImplementation (proxy q) |
defaultQueueImplementation :: QueueImplementation Source
The default QueueImplementation is based on TBMChan.
Policies
defaultBatchPolicy :: BatchPolicy Source
The default batching policy sends 200 records per PutRecordsEndpoint
request.
bpBatchSize :: Lens' BatchPolicy Natural Source
The number of records to send in a single request. This is only used
when the endpoint is set to PutRecordsEndpoint.
data RetryPolicy Source
The producer will attempt to re-send records which failed according to a user-specified policy. This policy applies to failures which occur in the process of sending a message to Kinesis, not those which occur in the course of enqueuing a message.
Instances
defaultRetryPolicy :: RetryPolicy Source
The default retry policy will attempt 5 retries for a message.
rpRetryCount :: Lens' RetryPolicy Natural Source
The number of times to retry sending a message after it has first failed.
Constants
pattern MaxMessageSize :: (Num a, Eq a) => a Source
The maximum size in bytes of a message.