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.Common

Contents

Description

 

Synopsis

Documentation

data KinesisKit Source

The KinesisKit contains what is necessary to make a request to Kinesis.

Constructors

KinesisKit 

Fields

_kkConfiguration :: !Configuration
 
_kkKinesisConfiguration :: !(KinesisConfiguration NormalQuery)
 
_kkManager :: !Manager
 

kkConfiguration :: Lens' KinesisKit Configuration Source

A lens for _kkConfiguration.

kkKinesisConfiguration :: Lens' KinesisKit (KinesisConfiguration NormalQuery) Source

A lens for _kkKinesisConfiguration.

kkManager :: Lens' KinesisKit Manager Source

A lens for _kkManager.

runKinesis :: (ServiceConfiguration req ~ KinesisConfiguration, Transaction req resp) => KinesisKit -> req -> IO resp Source

Run a Kinesis request.

Fetching Shards

streamShardSource :: MonadIO m => KinesisKit -> StreamName -> Source m Shard Source

A Source of shards for a stream.

streamOpenShardSource :: MonadIO m => KinesisKit -> StreamName -> Source m Shard Source

A Source of open shards for a stream.

shardIsOpen :: Shard -> Bool Source