Aws.Kinesis.Client.Internal.Queue.Chunk

Documentation

data ChunkingPolicy

A policy for chunking the contents of the message queue.

Constructors

ChunkingPolicy

Fields

_cpMaxChunkSize :: !Natural

The largest chunk size that is permitted.

_cpMinChunkingInterval :: !Natural

The time in microseconds after which a chunk should be committed, even if the maximum chunk size has not yet been reached.

chunkedSourceFromQueue :: BoundedCloseableQueue q α => ChunkingPolicy -> q -> Source IO [α]

A Source that reads chunks off a bounded STM queue according some ChunkingPolicy.