aws-kinesis-client-0.4.0.2: A producer & consumer client library for AWS Kinesis

CopyrightCopyright © 2013-2015 PivotCloud, Inc.
LicenseApache-2.0
MaintainerJon Sterling <jsterling@alephcloud.com>
Stabilityexperimental
Safe HaskellNone
LanguageHaskell2010

Aws.Kinesis.Client.Internal.Queue.Chunk

Description

 

Synopsis

Documentation

data ChunkingPolicy Source

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 [α] Source

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