[−][src]Crate rusoto_kinesis
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 |
| Consumer | An object that represents the details of the consumer you registered. |
| ConsumerDescription | An object that represents the details of a registered consumer. |
| CreateStreamInput | Represents the input for |
| DecreaseStreamRetentionPeriodInput | Represents the input for DecreaseStreamRetentionPeriod. |
| DeleteStreamInput | Represents the input for DeleteStream. |
| DeregisterStreamConsumerInput | |
| DescribeLimitsInput | |
| DescribeLimitsOutput | |
| DescribeStreamConsumerInput | |
| DescribeStreamConsumerOutput | |
| 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. |
| 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 |
| 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. |
| InternalFailureException | |
| 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 |
| ListStreamsOutput | Represents the output for |
| ListTagsForStreamInput | Represents the input for |
| ListTagsForStreamOutput | Represents the output for |
| MergeShardsInput | Represents the input for |
| 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 |
| 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. |
| RegisterStreamConsumerInput | |
| RegisterStreamConsumerOutput | |
| RemoveTagsFromStreamInput | Represents the input for |
| ResourceInUseException | The resource is not available for this operation. For successful operation, the resource must be in the |
| 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. |
| SplitShardInput | Represents the input for |
| 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 to your consumer. |
| SubscribeToShardEventStream | |
| 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 |
| UpdateShardCountError | Errors returned by UpdateShardCount |
Traits
| Kinesis | Trait representing the capabilities of the Kinesis API. Kinesis clients implement this trait. |