Contents
Index
aws-kinesis-client-0.1.0.1: A producer & consumer client library for AWS Kinesis
Index
BatchPolicy
Aws.Kinesis.Client.Producer
bpBatchSize
Aws.Kinesis.Client.Producer
bpEndpoint
Aws.Kinesis.Client.Producer
ckBatchSize
Aws.Kinesis.Client.Consumer
ckKinesisKit
Aws.Kinesis.Client.Consumer
ckStreamName
Aws.Kinesis.Client.Consumer
ConsumerError
Aws.Kinesis.Client.Consumer
ConsumerKit
1 (Type/Class)
Aws.Kinesis.Client.Consumer
2 (Data Constructor)
Aws.Kinesis.Client.Consumer
consumerSource
Aws.Kinesis.Client.Consumer
defaultBatchPolicy
Aws.Kinesis.Client.Producer
handleError
Aws.Kinesis.Client.Common
InvalidConcurrentConsumerCount
Aws.Kinesis.Client.Producer
KinesisConsumer
Aws.Kinesis.Client.Consumer
KinesisError
1 (Data Constructor)
Aws.Kinesis.Client.Consumer
2 (Data Constructor)
Aws.Kinesis.Client.Producer
KinesisKit
1 (Type/Class)
Aws.Kinesis.Client.Common
2 (Data Constructor)
Aws.Kinesis.Client.Common
KinesisProducer
Aws.Kinesis.Client.Producer
kkConfiguration
Aws.Kinesis.Client.Common
kkKinesisConfiguration
Aws.Kinesis.Client.Common
kkManager
Aws.Kinesis.Client.Common
managedKinesisConsumer
Aws.Kinesis.Client.Consumer
managedKinesisProducer
Aws.Kinesis.Client.Producer
mapEnvironment
Aws.Kinesis.Client.Common
mapError
Aws.Kinesis.Client.Common
Message
Aws.Kinesis.Client.Producer
MessageNotEnqueued
Aws.Kinesis.Client.Producer
MonadConsumer
Aws.Kinesis.Client.Consumer
MonadKinesis
Aws.Kinesis.Client.Common
MonadProducer
Aws.Kinesis.Client.Producer
NoShards
Aws.Kinesis.Client.Consumer
pkBatchPolicy
Aws.Kinesis.Client.Producer
pkKinesisKit
Aws.Kinesis.Client.Producer
pkMaxConcurrency
Aws.Kinesis.Client.Producer
pkMessageQueueBounds
Aws.Kinesis.Client.Producer
pkStreamName
Aws.Kinesis.Client.Producer
ProducerError
Aws.Kinesis.Client.Producer
ProducerKit
1 (Type/Class)
Aws.Kinesis.Client.Producer
2 (Data Constructor)
Aws.Kinesis.Client.Producer
PutRecordEndpoint
Aws.Kinesis.Client.Producer
PutRecordsEndpoint
Aws.Kinesis.Client.Producer
readConsumer
Aws.Kinesis.Client.Consumer
RecordEndpoint
Aws.Kinesis.Client.Producer
runKinesis
Aws.Kinesis.Client.Common
shardIsOpen
Aws.Kinesis.Client.Common
streamOpenShardSource
Aws.Kinesis.Client.Common
streamShardSource
Aws.Kinesis.Client.Common
tryReadConsumer
Aws.Kinesis.Client.Consumer
withKinesisConsumer
Aws.Kinesis.Client.Consumer
withKinesisProducer
Aws.Kinesis.Client.Producer
writeProducer
Aws.Kinesis.Client.Producer
_ckBatchSize
Aws.Kinesis.Client.Consumer
_ckIteratorType
Aws.Kinesis.Client.Consumer
_ckKinesisKit
Aws.Kinesis.Client.Consumer
_ckStreamName
Aws.Kinesis.Client.Consumer
_InvalidConcurrentConsumerCount
Aws.Kinesis.Client.Producer
_KinesisError
Aws.Kinesis.Client.Producer
_kkConfiguration
Aws.Kinesis.Client.Common
_kkKinesisConfiguration
Aws.Kinesis.Client.Common
_kkManager
Aws.Kinesis.Client.Common
_MessageNotEnqueued
Aws.Kinesis.Client.Producer
_pkBatchPolicy
Aws.Kinesis.Client.Producer
_pkKinesisKit
Aws.Kinesis.Client.Producer
_pkMaxConcurrency
Aws.Kinesis.Client.Producer
_pkMessageQueueBounds
Aws.Kinesis.Client.Producer
_pkStreamName
Aws.Kinesis.Client.Producer