amazonka-kinesis-0.3.0: Amazon Kinesis SDK.

Safe HaskellNone
LanguageHaskell2010

Network.AWS.Kinesis.Types

Contents

Synopsis

Service

data Kinesis Source

Version 2013-12-02 of the Amazon Kinesis service.

Instances

AWSService Kinesis 
type Sg Kinesis = V4 
type Er Kinesis = JSONError 

Error

data JSONError :: *

Instances

Eq JSONError 
Show JSONError 
Generic JSONError 
FromJSON JSONError 
AWSErrorCode JSONError 
type Rep JSONError = D1 D1JSONError (C1 C1_0JSONError ((:*:) (S1 S1_0_0JSONError (Rec0 (Maybe Text))) ((:*:) (S1 S1_0_1JSONError (Rec0 ErrorCode)) (S1 S1_0_2JSONError (Rec0 Text))))) 

Shard

sAdjacentParentShardId :: Lens' Shard (Maybe Text) Source

The shard Id of the shard adjacent to the shard's parent.

sHashKeyRange :: Lens' Shard HashKeyRange Source

The range of possible hash key values for the shard, which is a set of ordered contiguous positive integers.

sParentShardId :: Lens' Shard (Maybe Text) Source

The shard Id of the shard's parent.

sSequenceNumberRange :: Lens' Shard SequenceNumberRange Source

The range of possible sequence numbers for the shard.

sShardId :: Lens' Shard Text Source

The unique identifier of the shard within the Amazon Kinesis stream.

Tag

tag Source

Arguments

:: Text

tagKey

-> Tag 

Tag constructor.

The fields accessible through corresponding lenses are:

tagKey :: Lens' Tag Text Source

A unique identifier for the tag. Maximum length: 128 characters. Valid characters: Unicode letters, digits, white space, _ . / = + - % @

tagValue :: Lens' Tag (Maybe Text) Source

An optional string, typically used to describe or define the tag. Maximum length: 256 characters. Valid characters: Unicode letters, digits, white space, _ . / = + - % @

StreamDescription

sdHasMoreShards :: Lens' StreamDescription Bool Source

If set to true, more shards in the stream are available to describe.

sdShards :: Lens' StreamDescription [Shard] Source

The shards that comprise the stream.

sdStreamARN :: Lens' StreamDescription Text Source

The Amazon Resource Name (ARN) for the stream being described.

sdStreamName :: Lens' StreamDescription Text Source

The name of the stream being described.

sdStreamStatus :: Lens' StreamDescription StreamStatus Source

The current status of the stream being described.

The stream status is one of the following states:

CREATING - The stream is being created. Amazon Kinesis immediately returns and sets StreamStatus to CREATING. DELETING - The stream is being deleted. The specified stream is in the DELETING state until Amazon Kinesis completes the deletion. ACTIVE - The stream exists and is ready for read and write operations or deletion. You should perform read and write operations only on an ACTIVE stream. UPDATING - Shards in the stream are being merged or split. Read and write operations continue to work while the stream is in the UPDATING state.

PutRecordsResultEntry

prreErrorCode :: Lens' PutRecordsResultEntry (Maybe Text) Source

The error code for an individual record result. ErrorCodes can be either ProvisionedThroughputExceededException or InternalFailure.

prreErrorMessage :: Lens' PutRecordsResultEntry (Maybe Text) Source

The error message for an individual record result. An ErrorCode value of ProvisionedThroughputExceededException has an error message that includes the account ID, stream name, and shard ID. An ErrorCode value of InternalFailure has the error message '"InternalService Failure"'.

prreSequenceNumber :: Lens' PutRecordsResultEntry (Maybe Text) Source

The sequence number for an individual record result.

prreShardId :: Lens' PutRecordsResultEntry (Maybe Text) Source

The shard ID for an individual record result.

PutRecordsRequestEntry

putRecordsRequestEntry Source

PutRecordsRequestEntry constructor.

The fields accessible through corresponding lenses are:

prreData :: Lens' PutRecordsRequestEntry Base64 Source

The data blob to put into the record, which is base64-encoded when the blob is serialized. The maximum size of the data blob (the payload before base64-encoding) is 50 kilobytes (KB)

prreExplicitHashKey :: Lens' PutRecordsRequestEntry (Maybe Text) Source

The hash value used to determine explicitly the shard that the data record is assigned to by overriding the partition key hash.

prrePartitionKey :: Lens' PutRecordsRequestEntry Text Source

Determines which shard in the stream the data record is assigned to. Partition keys are Unicode strings with a maximum length limit of 256 bytes. Amazon Kinesis uses the partition key as input to a hash function that maps the partition key and associated data to a specific shard. Specifically, an MD5 hash function is used to map partition keys to 128-bit integer values and to map associated data records to shards. As a result of this hashing mechanism, all data records with the same partition key map to the same shard within the stream.

StreamStatus

HashKeyRange

hashKeyRange Source

HashKeyRange constructor.

The fields accessible through corresponding lenses are:

hkrEndingHashKey :: Lens' HashKeyRange Text Source

The ending hash key of the hash key range.

hkrStartingHashKey :: Lens' HashKeyRange Text Source

The starting hash key of the hash key range.

Record

record Source

Record constructor.

The fields accessible through corresponding lenses are:

rData :: Lens' Record Base64 Source

The data blob. The data in the blob is both opaque and immutable to the Amazon Kinesis service, which does not inspect, interpret, or change the data in the blob in any way. The maximum size of the data blob (the payload before base64-encoding) is 50 kilobytes (KB)

rPartitionKey :: Lens' Record Text Source

Identifies which shard in the stream the data record is assigned to.

rSequenceNumber :: Lens' Record Text Source

The unique identifier for the record in the Amazon Kinesis stream.

SequenceNumberRange

snrEndingSequenceNumber :: Lens' SequenceNumberRange (Maybe Text) Source

The ending sequence number for the range. Shards that are in the OPEN state have an ending sequence number of null.

snrStartingSequenceNumber :: Lens' SequenceNumberRange Text Source

The starting sequence number for the range.

ShardIteratorType