| BatchPolicy | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| BoundedCloseableQueue | Aws.Kinesis.Client.Internal.Queue |
| bpBatchSize | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| chunkedSourceFromQueue | Aws.Kinesis.Client.Internal.Queue.Chunk |
| ChunkingPolicy | |
| 1 (Type/Class) | Aws.Kinesis.Client.Internal.Queue.Chunk |
| 2 (Data Constructor) | Aws.Kinesis.Client.Internal.Queue.Chunk |
| ckBatchSize | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer, Aws.Kinesis.Client.Consumer.Kit |
| ckIteratorType | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer, Aws.Kinesis.Client.Consumer.Kit |
| ckKinesisKit | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer, Aws.Kinesis.Client.Consumer.Kit |
| ckSavedStreamState | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer, Aws.Kinesis.Client.Consumer.Kit |
| ckStreamName | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer, Aws.Kinesis.Client.Consumer.Kit |
| closeQueue | Aws.Kinesis.Client.Internal.Queue |
| ConsumerKit | |
| 1 (Type/Class) | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer, Aws.Kinesis.Client.Consumer.Kit |
| 2 (Data Constructor) | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer |
| consumerSource | Aws.Kinesis.Client.Consumer |
| consumerStreamState | Aws.Kinesis.Client.Consumer |
| defaultBatchPolicy | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| defaultQueueImplementation | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| defaultRetryPolicy | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| isClosedAndEmptyQueue | Aws.Kinesis.Client.Internal.Queue |
| isClosedQueue | Aws.Kinesis.Client.Internal.Queue |
| isEmptyQueue | Aws.Kinesis.Client.Internal.Queue |
| KinesisConsumer | Aws.Kinesis.Client.Consumer |
| 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 |
| makeConsumerKit | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer, Aws.Kinesis.Client.Consumer.Kit |
| makeProducerKit | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| makeShardState | Aws.Kinesis.Client.Consumer.Internal.ShardState, Aws.Kinesis.Client.Consumer.Internal |
| managedKinesisConsumer | Aws.Kinesis.Client.Consumer |
| managedKinesisProducer | Aws.Kinesis.Client.Producer |
| MaxMessageSize | Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| Message | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer |
| MessageQueue | Aws.Kinesis.Client.Consumer.Internal |
| MessageQueueItem | |
| 1 (Type/Class) | Aws.Kinesis.Client.Consumer.Internal |
| 2 (Type/Class) | Aws.Kinesis.Client.Producer.Internal |
| 3 (Data Constructor) | Aws.Kinesis.Client.Producer.Internal |
| messageQueueItemIsEligible | Aws.Kinesis.Client.Producer.Internal |
| MessageTooLarge | Aws.Kinesis.Client.Producer |
| mqiMessage | Aws.Kinesis.Client.Producer.Internal |
| mqiPartitionKey | Aws.Kinesis.Client.Producer.Internal |
| mqiRemainingAttempts | Aws.Kinesis.Client.Producer.Internal |
| newQueue | Aws.Kinesis.Client.Internal.Queue |
| pkBatchPolicy | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| pkCleanupTimeout | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| pkKinesisKit | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| pkMaxConcurrency | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| pkMessageQueueBounds | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| pkQueueImplementation | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| pkRetryPolicy | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| pkStreamName | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| ProducerCleanupTimedOut | |
| 1 (Type/Class) | Aws.Kinesis.Client.Producer |
| 2 (Data Constructor) | Aws.Kinesis.Client.Producer |
| ProducerKit | |
| 1 (Type/Class) | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| 2 (Data Constructor) | Aws.Kinesis.Client.Producer.Internal |
| ProducerQueueClosed | Aws.Kinesis.Client.Producer |
| ProducerQueueFull | Aws.Kinesis.Client.Producer |
| ProducerWorkerDied | |
| 1 (Type/Class) | Aws.Kinesis.Client.Producer |
| 2 (Data Constructor) | Aws.Kinesis.Client.Producer |
| QueueImplementation | |
| 1 (Type/Class) | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| 2 (Data Constructor) | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| readConsumer | Aws.Kinesis.Client.Consumer |
| readQueue | Aws.Kinesis.Client.Internal.Queue |
| replenishMessages | Aws.Kinesis.Client.Consumer.Internal |
| RetryPolicy | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| rpRetryCount | Aws.Kinesis.Client.Producer.Internal, Aws.Kinesis.Client.Producer.Kit, Aws.Kinesis.Client.Producer |
| runKinesis | Aws.Kinesis.Client.Common |
| SavedStreamState | Aws.Kinesis.Client.Consumer.Internal.SavedStreamState, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer, Aws.Kinesis.Client.Consumer.Kit |
| shardIsOpen | Aws.Kinesis.Client.Common |
| ShardState | Aws.Kinesis.Client.Consumer.Internal.ShardState, Aws.Kinesis.Client.Consumer.Internal |
| ssIterator | Aws.Kinesis.Client.Consumer.Internal.ShardState, Aws.Kinesis.Client.Consumer.Internal |
| ssLastSequenceNumber | Aws.Kinesis.Client.Consumer.Internal.ShardState, Aws.Kinesis.Client.Consumer.Internal |
| ssShardId | Aws.Kinesis.Client.Consumer.Internal.ShardState, Aws.Kinesis.Client.Consumer.Internal |
| streamOpenShardSource | Aws.Kinesis.Client.Common |
| streamShardSource | Aws.Kinesis.Client.Common |
| StreamState | Aws.Kinesis.Client.Consumer.Internal |
| takeQueueTimeout | Aws.Kinesis.Client.Internal.Queue |
| tryReadConsumer | Aws.Kinesis.Client.Consumer |
| tryWriteQueue | Aws.Kinesis.Client.Internal.Queue |
| updateStreamState | Aws.Kinesis.Client.Consumer.Internal |
| withKinesisConsumer | Aws.Kinesis.Client.Consumer |
| withKinesisProducer | Aws.Kinesis.Client.Producer |
| writeProducer | Aws.Kinesis.Client.Producer |
| WriteProducerException | Aws.Kinesis.Client.Producer |
| writeQueue | Aws.Kinesis.Client.Internal.Queue |
| _ckBatchSize | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer |
| _ckIteratorType | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer |
| _ckKinesisKit | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer |
| _ckSavedStreamState | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer |
| _ckStreamName | Aws.Kinesis.Client.Consumer.Internal.Kit, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer |
| _cpMaxChunkSize | Aws.Kinesis.Client.Internal.Queue.Chunk |
| _cpMinChunkingInterval | Aws.Kinesis.Client.Internal.Queue.Chunk |
| _kkConfiguration | Aws.Kinesis.Client.Common |
| _kkKinesisConfiguration | Aws.Kinesis.Client.Common |
| _kkManager | Aws.Kinesis.Client.Common |
| _mqiMessage | Aws.Kinesis.Client.Producer.Internal |
| _mqiPartitionKey | Aws.Kinesis.Client.Producer.Internal |
| _mqiRemainingAttempts | Aws.Kinesis.Client.Producer.Internal |
| _pkBatchPolicy | Aws.Kinesis.Client.Producer.Internal |
| _pkCleanupTimeout | Aws.Kinesis.Client.Producer.Internal |
| _pkKinesisKit | Aws.Kinesis.Client.Producer.Internal |
| _pkMaxConcurrency | Aws.Kinesis.Client.Producer.Internal |
| _pkMessageQueueBounds | Aws.Kinesis.Client.Producer.Internal |
| _pkQueueImplementation | Aws.Kinesis.Client.Producer.Internal |
| _pkRetryPolicy | Aws.Kinesis.Client.Producer.Internal |
| _pkStreamName | Aws.Kinesis.Client.Producer.Internal |
| _SavedStreamState | Aws.Kinesis.Client.Consumer.Internal.SavedStreamState, Aws.Kinesis.Client.Consumer.Internal, Aws.Kinesis.Client.Consumer.Kit |