[][src]Crate rusoto_kinesis

Amazon Kinesis Data Streams Service API Reference

Amazon Kinesis Data Streams is a managed service that scales elastically for real-time processing of streaming big data.

If you're using the service, you're probably looking for KinesisClient and Kinesis.

Structs

AddTagsToStreamInput

Represents the input for AddTagsToStream.

ChildShard
Consumer

An object that represents the details of the consumer you registered. This type of object is returned by RegisterStreamConsumer.

ConsumerDescription

An object that represents the details of a registered consumer. This type of object is returned by DescribeStreamConsumer.

CreateStreamInput

Represents the input for CreateStream.

DecreaseStreamRetentionPeriodInput

Represents the input for DecreaseStreamRetentionPeriod.

DeleteStreamInput

Represents the input for DeleteStream.

DeregisterStreamConsumerInput
DescribeLimitsInput
DescribeLimitsOutput
DescribeStreamConsumerInput
DescribeStreamConsumerOutput
DescribeStreamInput

Represents the input for DescribeStream.

DescribeStreamOutput

Represents the output for DescribeStream.

DescribeStreamSummaryInput
DescribeStreamSummaryOutput
DisableEnhancedMonitoringInput

Represents the input for DisableEnhancedMonitoring.

EnableEnhancedMonitoringInput

Represents the input for EnableEnhancedMonitoring.

EnhancedMetrics

Represents enhanced metrics types.

EnhancedMonitoringOutput

Represents the output for EnableEnhancedMonitoring and DisableEnhancedMonitoring.

ExpiredIteratorException

The provided iterator exceeds the maximum age allowed.

ExpiredNextTokenException

The pagination token passed to the operation is expired.

GetRecordsInput

Represents the input for GetRecords.

GetRecordsOutput

Represents the output for GetRecords.

GetShardIteratorInput

Represents the input for GetShardIterator.

GetShardIteratorOutput

Represents the output for GetShardIterator.

HashKeyRange

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

IncreaseStreamRetentionPeriodInput

Represents the input for IncreaseStreamRetentionPeriod.

InternalFailureException

The processing of the request failed because of an unknown error, exception, or failure.

InvalidArgumentException

A specified parameter exceeds its restrictions, is not supported, or can't be used. For more information, see the returned message.

KMSAccessDeniedException

The ciphertext references a key that doesn't exist or that you don't have access to.

KMSDisabledException

The request was rejected because the specified customer master key (CMK) isn't enabled.

KMSInvalidStateException

The request was rejected because the state of the specified resource isn't valid for this request. For more information, see How Key State Affects Use of a Customer Master Key in the AWS Key Management Service Developer Guide.

KMSNotFoundException

The request was rejected because the specified entity or resource can't be found.

KMSOptInRequired

The AWS access key ID needs a subscription for the service.

KMSThrottlingException

The request was denied due to request throttling. For more information about throttling, see Limits in the AWS Key Management Service Developer Guide.

KinesisClient

A client for the Kinesis API.

LimitExceededException

The requested resource exceeds the maximum number allowed, or the number of concurrent stream requests exceeds the maximum number allowed.

ListShardsInput
ListShardsOutput
ListStreamConsumersInput
ListStreamConsumersOutput
ListStreamsInput

Represents the input for ListStreams.

ListStreamsOutput

Represents the output for ListStreams.

ListTagsForStreamInput

Represents the input for ListTagsForStream.

ListTagsForStreamOutput

Represents the output for ListTagsForStream.

MergeShardsInput

Represents the input for MergeShards.

ProvisionedThroughputExceededException

The request rate for the stream is too high, or the requested data is too large for the available throughput. Reduce the frequency or size of your requests. For more information, see Streams Limits in the Amazon Kinesis Data Streams Developer Guide, and Error Retries and Exponential Backoff in AWS in the AWS General Reference.

PutRecordInput

Represents the input for PutRecord.

PutRecordOutput

Represents the output for PutRecord.

PutRecordsInput

A PutRecords request.

PutRecordsOutput

PutRecords results.

PutRecordsRequestEntry

Represents the output for PutRecords.

PutRecordsResultEntry

Represents the result of an individual record from a PutRecords request. A record that is successfully added to a stream includes SequenceNumber and ShardId in the result. A record that fails to be added to the stream includes ErrorCode and ErrorMessage in the result.

Record

The unit of data of the Kinesis data stream, which is composed of a sequence number, a partition key, and a data blob.

RegisterStreamConsumerInput
RegisterStreamConsumerOutput
RemoveTagsFromStreamInput

Represents the input for RemoveTagsFromStream.

ResourceInUseException

The resource is not available for this operation. For successful operation, the resource must be in the ACTIVE state.

ResourceNotFoundException

The requested resource could not be found. The stream might not be specified correctly.

SequenceNumberRange

The range of possible sequence numbers for the shard.

Shard

A uniquely identified group of data records in a Kinesis data stream.

ShardFilter
SplitShardInput

Represents the input for SplitShard.

StartStreamEncryptionInput
StartingPosition

StopStreamEncryptionInput
StreamDescription

Represents the output for DescribeStream.

StreamDescriptionSummary

Represents the output for DescribeStreamSummary

SubscribeToShardEvent

After you call SubscribeToShard, Kinesis Data Streams sends events of this type over an HTTP/2 connection to your consumer.

SubscribeToShardInput
SubscribeToShardOutput
Tag

Metadata assigned to the stream, consisting of a key-value pair.

UpdateShardCountInput
UpdateShardCountOutput

Enums

AddTagsToStreamError

Errors returned by AddTagsToStream

CreateStreamError

Errors returned by CreateStream

DecreaseStreamRetentionPeriodError

Errors returned by DecreaseStreamRetentionPeriod

DeleteStreamError

Errors returned by DeleteStream

DeregisterStreamConsumerError

Errors returned by DeregisterStreamConsumer

DescribeLimitsError

Errors returned by DescribeLimits

DescribeStreamConsumerError

Errors returned by DescribeStreamConsumer

DescribeStreamError

Errors returned by DescribeStream

DescribeStreamSummaryError

Errors returned by DescribeStreamSummary

DisableEnhancedMonitoringError

Errors returned by DisableEnhancedMonitoring

EnableEnhancedMonitoringError

Errors returned by EnableEnhancedMonitoring

GetRecordsError

Errors returned by GetRecords

GetShardIteratorError

Errors returned by GetShardIterator

IncreaseStreamRetentionPeriodError

Errors returned by IncreaseStreamRetentionPeriod

ListShardsError

Errors returned by ListShards

ListStreamConsumersError

Errors returned by ListStreamConsumers

ListStreamsError

Errors returned by ListStreams

ListTagsForStreamError

Errors returned by ListTagsForStream

MergeShardsError

Errors returned by MergeShards

PutRecordError

Errors returned by PutRecord

PutRecordsError

Errors returned by PutRecords

RegisterStreamConsumerError

Errors returned by RegisterStreamConsumer

RemoveTagsFromStreamError

Errors returned by RemoveTagsFromStream

SplitShardError

Errors returned by SplitShard

StartStreamEncryptionError

Errors returned by StartStreamEncryption

StopStreamEncryptionError

Errors returned by StopStreamEncryption

SubscribeToShardError

Errors returned by SubscribeToShard

SubscribeToShardEventStreamItem

This is a tagged union for all of the types of events an enhanced fan-out consumer can receive over HTTP/2 after a call to SubscribeToShard.

UpdateShardCountError

Errors returned by UpdateShardCount

Traits

Kinesis

Trait representing the capabilities of the Kinesis API. Kinesis clients implement this trait.