Crate rusoto_kinesis[−][src]
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 |
CreateStreamInput |
Represents the input for |
DecreaseStreamRetentionPeriodInput |
Represents the input for DecreaseStreamRetentionPeriod. |
DeleteStreamInput |
Represents the input for DeleteStream. |
DescribeLimitsInput | |
DescribeLimitsOutput | |
DescribeStreamInput |
Represents the input for |
DescribeStreamOutput |
Represents the output for |
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. |
GetRecordsInput |
Represents the input for GetRecords. |
GetRecordsOutput |
Represents the output for GetRecords. |
GetShardIteratorInput |
Represents the input for |
GetShardIteratorOutput |
Represents the output for |
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. |
KinesisClient |
A client for the Kinesis API. |
ListShardsInput | |
ListShardsOutput | |
ListStreamsInput |
Represents the input for |
ListStreamsOutput |
Represents the output for |
ListTagsForStreamInput |
Represents the input for |
ListTagsForStreamOutput |
Represents the output for |
MergeShardsInput |
Represents the input for |
PutRecordInput |
Represents the input for |
PutRecordOutput |
Represents the output for |
PutRecordsInput |
A |
PutRecordsOutput |
|
PutRecordsRequestEntry |
Represents the output for |
PutRecordsResultEntry |
Represents the result of an individual record from a |
Record |
The unit of data of the Kinesis data stream, which is composed of a sequence number, a partition key, and a data blob. |
RemoveTagsFromStreamInput |
Represents the input for |
SequenceNumberRange |
The range of possible sequence numbers for the shard. |
Shard |
A uniquely identified group of data records in a Kinesis data stream. |
SplitShardInput |
Represents the input for |
StartStreamEncryptionInput | |
StopStreamEncryptionInput | |
StreamDescription |
Represents the output for DescribeStream. |
StreamDescriptionSummary |
Represents the output for DescribeStreamSummary |
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 |
DescribeLimitsError |
Errors returned by DescribeLimits |
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 |
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 |
RemoveTagsFromStreamError |
Errors returned by RemoveTagsFromStream |
SplitShardError |
Errors returned by SplitShard |
StartStreamEncryptionError |
Errors returned by StartStreamEncryption |
StopStreamEncryptionError |
Errors returned by StopStreamEncryption |
UpdateShardCountError |
Errors returned by UpdateShardCount |
Traits
Kinesis |
Trait representing the capabilities of the Kinesis API. Kinesis clients implement this trait. |