| 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.Internal
Contents
Description
- type MessageQueueItem = (ShardState, Record)
- type MessageQueue = TBQueue MessageQueueItem
- type StreamState = Carousel ShardState
- updateStreamState :: ConsumerKit -> StreamState -> IO StreamState
- replenishMessages :: ConsumerKit -> MessageQueue -> TVar StreamState -> IO Int
- module Aws.Kinesis.Client.Consumer.Internal.Kit
- module Aws.Kinesis.Client.Consumer.Internal.ShardState
- module Aws.Kinesis.Client.Consumer.Internal.SavedStreamState
Types
type MessageQueueItem = (ShardState, Record) Source
type StreamState = Carousel ShardState Source
Operations
updateStreamState :: ConsumerKit -> StreamState -> IO StreamState Source
This requests new information from Kinesis and reconciles that with an existing carousel of shard states.
replenishMessages :: ConsumerKit -> MessageQueue -> TVar StreamState -> IO Int Source
Waits for a message queue to be emptied and fills it up again.