# Packages
Package kinesisiface provides an interface to enable mocking the Amazon Kinesis service client for testing your code.
# Functions
ConsumerStatus_Values returns all elements of the ConsumerStatus enum.
EncryptionType_Values returns all elements of the EncryptionType enum.
MetricsName_Values returns all elements of the MetricsName enum.
New creates a new instance of the Kinesis client with a session.
NewSubscribeToShardEventStream initializes an SubscribeToShardEventStream.
ScalingType_Values returns all elements of the ScalingType enum.
ShardFilterType_Values returns all elements of the ShardFilterType enum.
ShardIteratorType_Values returns all elements of the ShardIteratorType enum.
StreamMode_Values returns all elements of the StreamMode enum.
StreamStatus_Values returns all elements of the StreamStatus enum.
# Constants
ConsumerStatusActive is a ConsumerStatus enum value.
ConsumerStatusCreating is a ConsumerStatus enum value.
ConsumerStatusDeleting is a ConsumerStatus enum value.
EncryptionTypeKms is a EncryptionType enum value.
EncryptionTypeNone is a EncryptionType enum value.
ID to lookup a service endpoint with.
ErrCodeAccessDeniedException for service response error code "AccessDeniedException".
ErrCodeExpiredIteratorException for service response error code "ExpiredIteratorException".
ErrCodeExpiredNextTokenException for service response error code "ExpiredNextTokenException".
ErrCodeInternalFailureException for service response error code "InternalFailureException".
ErrCodeInvalidArgumentException for service response error code "InvalidArgumentException".
ErrCodeKMSAccessDeniedException for service response error code "KMSAccessDeniedException".
ErrCodeKMSDisabledException for service response error code "KMSDisabledException".
ErrCodeKMSInvalidStateException for service response error code "KMSInvalidStateException".
ErrCodeKMSNotFoundException for service response error code "KMSNotFoundException".
ErrCodeKMSOptInRequired for service response error code "KMSOptInRequired".
ErrCodeKMSThrottlingException for service response error code "KMSThrottlingException".
ErrCodeLimitExceededException for service response error code "LimitExceededException".
ErrCodeProvisionedThroughputExceededException for service response error code "ProvisionedThroughputExceededException".
ErrCodeResourceInUseException for service response error code "ResourceInUseException".
ErrCodeResourceNotFoundException for service response error code "ResourceNotFoundException".
ErrCodeValidationException for service response error code "ValidationException".
MetricsNameAll is a MetricsName enum value.
MetricsNameIncomingBytes is a MetricsName enum value.
MetricsNameIncomingRecords is a MetricsName enum value.
MetricsNameIteratorAgeMilliseconds is a MetricsName enum value.
MetricsNameOutgoingBytes is a MetricsName enum value.
MetricsNameOutgoingRecords is a MetricsName enum value.
MetricsNameReadProvisionedThroughputExceeded is a MetricsName enum value.
MetricsNameWriteProvisionedThroughputExceeded is a MetricsName enum value.
ScalingTypeUniformScaling is a ScalingType enum value.
ServiceID is a unique identifier of a specific service.
Name of service.
ShardFilterTypeAfterShardId is a ShardFilterType enum value.
ShardFilterTypeAtLatest is a ShardFilterType enum value.
ShardFilterTypeAtTimestamp is a ShardFilterType enum value.
ShardFilterTypeAtTrimHorizon is a ShardFilterType enum value.
ShardFilterTypeFromTimestamp is a ShardFilterType enum value.
ShardFilterTypeFromTrimHorizon is a ShardFilterType enum value.
ShardIteratorTypeAfterSequenceNumber is a ShardIteratorType enum value.
ShardIteratorTypeAtSequenceNumber is a ShardIteratorType enum value.
ShardIteratorTypeAtTimestamp is a ShardIteratorType enum value.
ShardIteratorTypeLatest is a ShardIteratorType enum value.
ShardIteratorTypeTrimHorizon is a ShardIteratorType enum value.
StreamModeOnDemand is a StreamMode enum value.
StreamModeProvisioned is a StreamMode enum value.
StreamStatusActive is a StreamStatus enum value.
StreamStatusCreating is a StreamStatus enum value.
StreamStatusDeleting is a StreamStatus enum value.
StreamStatusUpdating is a StreamStatus enum value.
# Structs
Specifies that you do not have the permissions required to perform this operation.
Represents the input for AddTagsToStream.
Output parameter of the GetRecords API.
An object that represents the details of the consumer you registered.
An object that represents the details of a registered consumer.
Represents the input for CreateStream.
Represents the input for DecreaseStreamRetentionPeriod.
Represents the input for DeleteStream.
Represents the input for DescribeStream.
Represents the output for DescribeStream.
Represents the input for DisableEnhancedMonitoring.
Represents the input for EnableEnhancedMonitoring.
Represents enhanced metrics types.
Represents the output for EnableEnhancedMonitoring and DisableEnhancedMonitoring.
The provided iterator exceeds the maximum age allowed.
The pagination token passed to the operation is expired.
Represents the input for GetRecords.
Represents the output for GetRecords.
Represents the input for GetShardIterator.
Represents the output for GetShardIterator.
The range of possible hash key values for the shard, which is a set of ordered contiguous positive integers.
Represents the input for IncreaseStreamRetentionPeriod.
The processing of the request failed because of an unknown error, exception, or failure.
A specified parameter exceeds its restrictions, is not supported, or can't be used.
Kinesis provides the API operation methods for making requests to Amazon Kinesis.
The ciphertext references a key that doesn't exist or that you don't have access to.
The request was rejected because the specified customer master key (CMK) isn't enabled.
The request was rejected because the state of the specified resource isn't valid for this request.
The request was rejected because the specified entity or resource can't be found.
The Amazon Web Services access key ID needs a subscription for the service.
The request was denied due to request throttling.
The requested resource exceeds the maximum number allowed, or the number of concurrent stream requests exceeds the maximum number allowed.
Represents the input for ListStreams.
Represents the output for ListStreams.
Represents the input for ListTagsForStream.
Represents the output for ListTagsForStream.
Represents the input for MergeShards.
The request rate for the stream is too high, or the requested data is too large for the available throughput.
Represents the input for PutRecord.
Represents the output for PutRecord.
A PutRecords request.
PutRecords results.
Represents the output for PutRecords.
Represents the result of an individual record from a PutRecords request.
The unit of data of the Kinesis data stream, which is composed of a sequence number, a partition key, and a data blob.
Represents the input for RemoveTagsFromStream.
The resource is not available for this operation.
The requested resource could not be found.
The range of possible sequence numbers for the shard.
A uniquely identified group of data records in a Kinesis data stream.
The request parameter used to filter out the response of the ListShards API.
Represents the input for SplitShard.
The starting position in the data stream from which to start streaming.
Represents the output for DescribeStream.
Represents the output for DescribeStreamSummary.
Specifies the capacity mode to which you want to set your data stream.
The summary of a stream.
After you call SubscribeToShard, Kinesis Data Streams sends events of this type over an HTTP/2 connection to your consumer.
SubscribeToShardEventStream provides the event stream handling for the SubscribeToShard.
SubscribeToShardEventStreamUnknownEvent provides a failsafe event for the SubscribeToShardEventStream group of events when an unknown event is received.
Metadata assigned to the stream, consisting of a key-value pair.
Specifies that you tried to invoke this API for a data stream with the on-demand capacity mode.
# Interfaces
SubscribeToShardEventStreamEvent groups together all EventStream events writes for SubscribeToShardEventStream.
SubscribeToShardEventStreamReader provides the interface for reading to the stream.