Versions in this module Expand all Collapse all v1 v1.0.1 Jul 4, 2024 v1.0.0 Jul 4, 2024 Changes in this version + const ConsumerStatusActive + const ConsumerStatusCreating + const ConsumerStatusDeleting + const EncryptionTypeKms + const EncryptionTypeNone + const EndpointsID + const ErrCodeAccessDeniedException + const ErrCodeExpiredIteratorException + const ErrCodeExpiredNextTokenException + const ErrCodeInternalFailureException + const ErrCodeInvalidArgumentException + const ErrCodeKMSAccessDeniedException + const ErrCodeKMSDisabledException + const ErrCodeKMSInvalidStateException + const ErrCodeKMSNotFoundException + const ErrCodeKMSOptInRequired + const ErrCodeKMSThrottlingException + const ErrCodeLimitExceededException + const ErrCodeProvisionedThroughputExceededException + const ErrCodeResourceInUseException + const ErrCodeResourceNotFoundException + const ErrCodeValidationException + const MetricsNameAll + const MetricsNameIncomingBytes + const MetricsNameIncomingRecords + const MetricsNameIteratorAgeMilliseconds + const MetricsNameOutgoingBytes + const MetricsNameOutgoingRecords + const MetricsNameReadProvisionedThroughputExceeded + const MetricsNameWriteProvisionedThroughputExceeded + const ScalingTypeUniformScaling + const ServiceID + const ServiceName + const ShardFilterTypeAfterShardId + const ShardFilterTypeAtLatest + const ShardFilterTypeAtTimestamp + const ShardFilterTypeAtTrimHorizon + const ShardFilterTypeFromTimestamp + const ShardFilterTypeFromTrimHorizon + const ShardIteratorTypeAfterSequenceNumber + const ShardIteratorTypeAtSequenceNumber + const ShardIteratorTypeAtTimestamp + const ShardIteratorTypeLatest + const ShardIteratorTypeTrimHorizon + const StreamModeOnDemand + const StreamModeProvisioned + const StreamStatusActive + const StreamStatusCreating + const StreamStatusDeleting + const StreamStatusUpdating + func ConsumerStatus_Values() []string + func EncryptionType_Values() []string + func MetricsName_Values() []string + func ScalingType_Values() []string + func ShardFilterType_Values() []string + func ShardIteratorType_Values() []string + func StreamMode_Values() []string + func StreamStatus_Values() []string + type AccessDeniedException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *AccessDeniedException) Code() string + func (s *AccessDeniedException) Error() string + func (s *AccessDeniedException) Message() string + func (s *AccessDeniedException) OrigErr() error + func (s *AccessDeniedException) RequestID() string + func (s *AccessDeniedException) StatusCode() int + func (s AccessDeniedException) GoString() string + func (s AccessDeniedException) String() string + type AddTagsToStreamInput struct + StreamARN *string + StreamName *string + Tags map[string]*string + func (s *AddTagsToStreamInput) SetStreamARN(v string) *AddTagsToStreamInput + func (s *AddTagsToStreamInput) SetStreamName(v string) *AddTagsToStreamInput + func (s *AddTagsToStreamInput) SetTags(v map[string]*string) *AddTagsToStreamInput + func (s *AddTagsToStreamInput) Validate() error + func (s AddTagsToStreamInput) GoString() string + func (s AddTagsToStreamInput) String() string + type AddTagsToStreamOutput struct + func (s AddTagsToStreamOutput) GoString() string + func (s AddTagsToStreamOutput) String() string + type ChildShard struct + HashKeyRange *HashKeyRange + ParentShards []*string + ShardId *string + func (s *ChildShard) SetHashKeyRange(v *HashKeyRange) *ChildShard + func (s *ChildShard) SetParentShards(v []*string) *ChildShard + func (s *ChildShard) SetShardId(v string) *ChildShard + func (s ChildShard) GoString() string + func (s ChildShard) String() string + type Consumer struct + ConsumerARN *string + ConsumerCreationTimestamp *time.Time + ConsumerName *string + ConsumerStatus *string + func (s *Consumer) SetConsumerARN(v string) *Consumer + func (s *Consumer) SetConsumerCreationTimestamp(v time.Time) *Consumer + func (s *Consumer) SetConsumerName(v string) *Consumer + func (s *Consumer) SetConsumerStatus(v string) *Consumer + func (s Consumer) GoString() string + func (s Consumer) String() string + type ConsumerDescription struct + ConsumerARN *string + ConsumerCreationTimestamp *time.Time + ConsumerName *string + ConsumerStatus *string + StreamARN *string + func (s *ConsumerDescription) SetConsumerARN(v string) *ConsumerDescription + func (s *ConsumerDescription) SetConsumerCreationTimestamp(v time.Time) *ConsumerDescription + func (s *ConsumerDescription) SetConsumerName(v string) *ConsumerDescription + func (s *ConsumerDescription) SetConsumerStatus(v string) *ConsumerDescription + func (s *ConsumerDescription) SetStreamARN(v string) *ConsumerDescription + func (s ConsumerDescription) GoString() string + func (s ConsumerDescription) String() string + type CreateStreamInput struct + ShardCount *int64 + StreamModeDetails *StreamModeDetails + StreamName *string + func (s *CreateStreamInput) SetShardCount(v int64) *CreateStreamInput + func (s *CreateStreamInput) SetStreamModeDetails(v *StreamModeDetails) *CreateStreamInput + func (s *CreateStreamInput) SetStreamName(v string) *CreateStreamInput + func (s *CreateStreamInput) Validate() error + func (s CreateStreamInput) GoString() string + func (s CreateStreamInput) String() string + type CreateStreamOutput struct + func (s CreateStreamOutput) GoString() string + func (s CreateStreamOutput) String() string + type DecreaseStreamRetentionPeriodInput struct + RetentionPeriodHours *int64 + StreamARN *string + StreamName *string + func (s *DecreaseStreamRetentionPeriodInput) SetRetentionPeriodHours(v int64) *DecreaseStreamRetentionPeriodInput + func (s *DecreaseStreamRetentionPeriodInput) SetStreamARN(v string) *DecreaseStreamRetentionPeriodInput + func (s *DecreaseStreamRetentionPeriodInput) SetStreamName(v string) *DecreaseStreamRetentionPeriodInput + func (s *DecreaseStreamRetentionPeriodInput) Validate() error + func (s DecreaseStreamRetentionPeriodInput) GoString() string + func (s DecreaseStreamRetentionPeriodInput) String() string + type DecreaseStreamRetentionPeriodOutput struct + func (s DecreaseStreamRetentionPeriodOutput) GoString() string + func (s DecreaseStreamRetentionPeriodOutput) String() string + type DeleteStreamInput struct + EnforceConsumerDeletion *bool + StreamARN *string + StreamName *string + func (s *DeleteStreamInput) SetEnforceConsumerDeletion(v bool) *DeleteStreamInput + func (s *DeleteStreamInput) SetStreamARN(v string) *DeleteStreamInput + func (s *DeleteStreamInput) SetStreamName(v string) *DeleteStreamInput + func (s *DeleteStreamInput) Validate() error + func (s DeleteStreamInput) GoString() string + func (s DeleteStreamInput) String() string + type DeleteStreamOutput struct + func (s DeleteStreamOutput) GoString() string + func (s DeleteStreamOutput) String() string + type DeregisterStreamConsumerInput struct + ConsumerARN *string + ConsumerName *string + StreamARN *string + func (s *DeregisterStreamConsumerInput) SetConsumerARN(v string) *DeregisterStreamConsumerInput + func (s *DeregisterStreamConsumerInput) SetConsumerName(v string) *DeregisterStreamConsumerInput + func (s *DeregisterStreamConsumerInput) SetStreamARN(v string) *DeregisterStreamConsumerInput + func (s *DeregisterStreamConsumerInput) Validate() error + func (s DeregisterStreamConsumerInput) GoString() string + func (s DeregisterStreamConsumerInput) String() string + type DeregisterStreamConsumerOutput struct + func (s DeregisterStreamConsumerOutput) GoString() string + func (s DeregisterStreamConsumerOutput) String() string + type DescribeLimitsInput struct + func (s DescribeLimitsInput) GoString() string + func (s DescribeLimitsInput) String() string + type DescribeLimitsOutput struct + OnDemandStreamCount *int64 + OnDemandStreamCountLimit *int64 + OpenShardCount *int64 + ShardLimit *int64 + func (s *DescribeLimitsOutput) SetOnDemandStreamCount(v int64) *DescribeLimitsOutput + func (s *DescribeLimitsOutput) SetOnDemandStreamCountLimit(v int64) *DescribeLimitsOutput + func (s *DescribeLimitsOutput) SetOpenShardCount(v int64) *DescribeLimitsOutput + func (s *DescribeLimitsOutput) SetShardLimit(v int64) *DescribeLimitsOutput + func (s DescribeLimitsOutput) GoString() string + func (s DescribeLimitsOutput) String() string + type DescribeStreamConsumerInput struct + ConsumerARN *string + ConsumerName *string + StreamARN *string + func (s *DescribeStreamConsumerInput) SetConsumerARN(v string) *DescribeStreamConsumerInput + func (s *DescribeStreamConsumerInput) SetConsumerName(v string) *DescribeStreamConsumerInput + func (s *DescribeStreamConsumerInput) SetStreamARN(v string) *DescribeStreamConsumerInput + func (s *DescribeStreamConsumerInput) Validate() error + func (s DescribeStreamConsumerInput) GoString() string + func (s DescribeStreamConsumerInput) String() string + type DescribeStreamConsumerOutput struct + ConsumerDescription *ConsumerDescription + func (s *DescribeStreamConsumerOutput) SetConsumerDescription(v *ConsumerDescription) *DescribeStreamConsumerOutput + func (s DescribeStreamConsumerOutput) GoString() string + func (s DescribeStreamConsumerOutput) String() string + type DescribeStreamInput struct + ExclusiveStartShardId *string + Limit *int64 + StreamARN *string + StreamName *string + func (s *DescribeStreamInput) SetExclusiveStartShardId(v string) *DescribeStreamInput + func (s *DescribeStreamInput) SetLimit(v int64) *DescribeStreamInput + func (s *DescribeStreamInput) SetStreamARN(v string) *DescribeStreamInput + func (s *DescribeStreamInput) SetStreamName(v string) *DescribeStreamInput + func (s *DescribeStreamInput) Validate() error + func (s DescribeStreamInput) GoString() string + func (s DescribeStreamInput) String() string + type DescribeStreamOutput struct + StreamDescription *StreamDescription + func (s *DescribeStreamOutput) SetStreamDescription(v *StreamDescription) *DescribeStreamOutput + func (s DescribeStreamOutput) GoString() string + func (s DescribeStreamOutput) String() string + type DescribeStreamSummaryInput struct + StreamARN *string + StreamName *string + func (s *DescribeStreamSummaryInput) SetStreamARN(v string) *DescribeStreamSummaryInput + func (s *DescribeStreamSummaryInput) SetStreamName(v string) *DescribeStreamSummaryInput + func (s *DescribeStreamSummaryInput) Validate() error + func (s DescribeStreamSummaryInput) GoString() string + func (s DescribeStreamSummaryInput) String() string + type DescribeStreamSummaryOutput struct + StreamDescriptionSummary *StreamDescriptionSummary + func (s *DescribeStreamSummaryOutput) SetStreamDescriptionSummary(v *StreamDescriptionSummary) *DescribeStreamSummaryOutput + func (s DescribeStreamSummaryOutput) GoString() string + func (s DescribeStreamSummaryOutput) String() string + type DisableEnhancedMonitoringInput struct + ShardLevelMetrics []*string + StreamARN *string + StreamName *string + func (s *DisableEnhancedMonitoringInput) SetShardLevelMetrics(v []*string) *DisableEnhancedMonitoringInput + func (s *DisableEnhancedMonitoringInput) SetStreamARN(v string) *DisableEnhancedMonitoringInput + func (s *DisableEnhancedMonitoringInput) SetStreamName(v string) *DisableEnhancedMonitoringInput + func (s *DisableEnhancedMonitoringInput) Validate() error + func (s DisableEnhancedMonitoringInput) GoString() string + func (s DisableEnhancedMonitoringInput) String() string + type EnableEnhancedMonitoringInput struct + ShardLevelMetrics []*string + StreamARN *string + StreamName *string + func (s *EnableEnhancedMonitoringInput) SetShardLevelMetrics(v []*string) *EnableEnhancedMonitoringInput + func (s *EnableEnhancedMonitoringInput) SetStreamARN(v string) *EnableEnhancedMonitoringInput + func (s *EnableEnhancedMonitoringInput) SetStreamName(v string) *EnableEnhancedMonitoringInput + func (s *EnableEnhancedMonitoringInput) Validate() error + func (s EnableEnhancedMonitoringInput) GoString() string + func (s EnableEnhancedMonitoringInput) String() string + type EnhancedMetrics struct + ShardLevelMetrics []*string + func (s *EnhancedMetrics) SetShardLevelMetrics(v []*string) *EnhancedMetrics + func (s EnhancedMetrics) GoString() string + func (s EnhancedMetrics) String() string + type EnhancedMonitoringOutput struct + CurrentShardLevelMetrics []*string + DesiredShardLevelMetrics []*string + StreamARN *string + StreamName *string + func (s *EnhancedMonitoringOutput) SetCurrentShardLevelMetrics(v []*string) *EnhancedMonitoringOutput + func (s *EnhancedMonitoringOutput) SetDesiredShardLevelMetrics(v []*string) *EnhancedMonitoringOutput + func (s *EnhancedMonitoringOutput) SetStreamARN(v string) *EnhancedMonitoringOutput + func (s *EnhancedMonitoringOutput) SetStreamName(v string) *EnhancedMonitoringOutput + func (s EnhancedMonitoringOutput) GoString() string + func (s EnhancedMonitoringOutput) String() string + type ExpiredIteratorException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ExpiredIteratorException) Code() string + func (s *ExpiredIteratorException) Error() string + func (s *ExpiredIteratorException) Message() string + func (s *ExpiredIteratorException) OrigErr() error + func (s *ExpiredIteratorException) RequestID() string + func (s *ExpiredIteratorException) StatusCode() int + func (s ExpiredIteratorException) GoString() string + func (s ExpiredIteratorException) String() string + type ExpiredNextTokenException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ExpiredNextTokenException) Code() string + func (s *ExpiredNextTokenException) Error() string + func (s *ExpiredNextTokenException) Message() string + func (s *ExpiredNextTokenException) OrigErr() error + func (s *ExpiredNextTokenException) RequestID() string + func (s *ExpiredNextTokenException) StatusCode() int + func (s ExpiredNextTokenException) GoString() string + func (s ExpiredNextTokenException) String() string + type GetRecordsInput struct + Limit *int64 + ShardIterator *string + StreamARN *string + func (s *GetRecordsInput) SetLimit(v int64) *GetRecordsInput + func (s *GetRecordsInput) SetShardIterator(v string) *GetRecordsInput + func (s *GetRecordsInput) SetStreamARN(v string) *GetRecordsInput + func (s *GetRecordsInput) Validate() error + func (s GetRecordsInput) GoString() string + func (s GetRecordsInput) String() string + type GetRecordsOutput struct + ChildShards []*ChildShard + MillisBehindLatest *int64 + NextShardIterator *string + Records []*Record + func (s *GetRecordsOutput) SetChildShards(v []*ChildShard) *GetRecordsOutput + func (s *GetRecordsOutput) SetMillisBehindLatest(v int64) *GetRecordsOutput + func (s *GetRecordsOutput) SetNextShardIterator(v string) *GetRecordsOutput + func (s *GetRecordsOutput) SetRecords(v []*Record) *GetRecordsOutput + func (s GetRecordsOutput) GoString() string + func (s GetRecordsOutput) String() string + type GetShardIteratorInput struct + ShardId *string + ShardIteratorType *string + StartingSequenceNumber *string + StreamARN *string + StreamName *string + Timestamp *time.Time + func (s *GetShardIteratorInput) SetShardId(v string) *GetShardIteratorInput + func (s *GetShardIteratorInput) SetShardIteratorType(v string) *GetShardIteratorInput + func (s *GetShardIteratorInput) SetStartingSequenceNumber(v string) *GetShardIteratorInput + func (s *GetShardIteratorInput) SetStreamARN(v string) *GetShardIteratorInput + func (s *GetShardIteratorInput) SetStreamName(v string) *GetShardIteratorInput + func (s *GetShardIteratorInput) SetTimestamp(v time.Time) *GetShardIteratorInput + func (s *GetShardIteratorInput) Validate() error + func (s GetShardIteratorInput) GoString() string + func (s GetShardIteratorInput) String() string + type GetShardIteratorOutput struct + ShardIterator *string + func (s *GetShardIteratorOutput) SetShardIterator(v string) *GetShardIteratorOutput + func (s GetShardIteratorOutput) GoString() string + func (s GetShardIteratorOutput) String() string + type HashKeyRange struct + EndingHashKey *string + StartingHashKey *string + func (s *HashKeyRange) SetEndingHashKey(v string) *HashKeyRange + func (s *HashKeyRange) SetStartingHashKey(v string) *HashKeyRange + func (s HashKeyRange) GoString() string + func (s HashKeyRange) String() string + type IncreaseStreamRetentionPeriodInput struct + RetentionPeriodHours *int64 + StreamARN *string + StreamName *string + func (s *IncreaseStreamRetentionPeriodInput) SetRetentionPeriodHours(v int64) *IncreaseStreamRetentionPeriodInput + func (s *IncreaseStreamRetentionPeriodInput) SetStreamARN(v string) *IncreaseStreamRetentionPeriodInput + func (s *IncreaseStreamRetentionPeriodInput) SetStreamName(v string) *IncreaseStreamRetentionPeriodInput + func (s *IncreaseStreamRetentionPeriodInput) Validate() error + func (s IncreaseStreamRetentionPeriodInput) GoString() string + func (s IncreaseStreamRetentionPeriodInput) String() string + type IncreaseStreamRetentionPeriodOutput struct + func (s IncreaseStreamRetentionPeriodOutput) GoString() string + func (s IncreaseStreamRetentionPeriodOutput) String() string + type InternalFailureException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *InternalFailureException) Code() string + func (s *InternalFailureException) Error() string + func (s *InternalFailureException) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *InternalFailureException) Message() string + func (s *InternalFailureException) OrigErr() error + func (s *InternalFailureException) RequestID() string + func (s *InternalFailureException) StatusCode() int + func (s *InternalFailureException) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s InternalFailureException) GoString() string + func (s InternalFailureException) String() string + type InvalidArgumentException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *InvalidArgumentException) Code() string + func (s *InvalidArgumentException) Error() string + func (s *InvalidArgumentException) Message() string + func (s *InvalidArgumentException) OrigErr() error + func (s *InvalidArgumentException) RequestID() string + func (s *InvalidArgumentException) StatusCode() int + func (s InvalidArgumentException) GoString() string + func (s InvalidArgumentException) String() string + type KMSAccessDeniedException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *KMSAccessDeniedException) Code() string + func (s *KMSAccessDeniedException) Error() string + func (s *KMSAccessDeniedException) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *KMSAccessDeniedException) Message() string + func (s *KMSAccessDeniedException) OrigErr() error + func (s *KMSAccessDeniedException) RequestID() string + func (s *KMSAccessDeniedException) StatusCode() int + func (s *KMSAccessDeniedException) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s KMSAccessDeniedException) GoString() string + func (s KMSAccessDeniedException) String() string + type KMSDisabledException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *KMSDisabledException) Code() string + func (s *KMSDisabledException) Error() string + func (s *KMSDisabledException) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *KMSDisabledException) Message() string + func (s *KMSDisabledException) OrigErr() error + func (s *KMSDisabledException) RequestID() string + func (s *KMSDisabledException) StatusCode() int + func (s *KMSDisabledException) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s KMSDisabledException) GoString() string + func (s KMSDisabledException) String() string + type KMSInvalidStateException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *KMSInvalidStateException) Code() string + func (s *KMSInvalidStateException) Error() string + func (s *KMSInvalidStateException) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *KMSInvalidStateException) Message() string + func (s *KMSInvalidStateException) OrigErr() error + func (s *KMSInvalidStateException) RequestID() string + func (s *KMSInvalidStateException) StatusCode() int + func (s *KMSInvalidStateException) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s KMSInvalidStateException) GoString() string + func (s KMSInvalidStateException) String() string + type KMSNotFoundException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *KMSNotFoundException) Code() string + func (s *KMSNotFoundException) Error() string + func (s *KMSNotFoundException) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *KMSNotFoundException) Message() string + func (s *KMSNotFoundException) OrigErr() error + func (s *KMSNotFoundException) RequestID() string + func (s *KMSNotFoundException) StatusCode() int + func (s *KMSNotFoundException) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s KMSNotFoundException) GoString() string + func (s KMSNotFoundException) String() string + type KMSOptInRequired struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *KMSOptInRequired) Code() string + func (s *KMSOptInRequired) Error() string + func (s *KMSOptInRequired) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *KMSOptInRequired) Message() string + func (s *KMSOptInRequired) OrigErr() error + func (s *KMSOptInRequired) RequestID() string + func (s *KMSOptInRequired) StatusCode() int + func (s *KMSOptInRequired) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s KMSOptInRequired) GoString() string + func (s KMSOptInRequired) String() string + type KMSThrottlingException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *KMSThrottlingException) Code() string + func (s *KMSThrottlingException) Error() string + func (s *KMSThrottlingException) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *KMSThrottlingException) Message() string + func (s *KMSThrottlingException) OrigErr() error + func (s *KMSThrottlingException) RequestID() string + func (s *KMSThrottlingException) StatusCode() int + func (s *KMSThrottlingException) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s KMSThrottlingException) GoString() string + func (s KMSThrottlingException) String() string + type Kinesis struct + func New(p client.ConfigProvider, cfgs ...*aws.Config) *Kinesis + func (c *Kinesis) AddTagsToStream(input *AddTagsToStreamInput) (*AddTagsToStreamOutput, error) + func (c *Kinesis) AddTagsToStreamRequest(input *AddTagsToStreamInput) (req *request.Request, output *AddTagsToStreamOutput) + func (c *Kinesis) AddTagsToStreamWithContext(ctx aws.Context, input *AddTagsToStreamInput, opts ...request.Option) (*AddTagsToStreamOutput, error) + func (c *Kinesis) CreateStream(input *CreateStreamInput) (*CreateStreamOutput, error) + func (c *Kinesis) CreateStreamRequest(input *CreateStreamInput) (req *request.Request, output *CreateStreamOutput) + func (c *Kinesis) CreateStreamWithContext(ctx aws.Context, input *CreateStreamInput, opts ...request.Option) (*CreateStreamOutput, error) + func (c *Kinesis) DecreaseStreamRetentionPeriod(input *DecreaseStreamRetentionPeriodInput) (*DecreaseStreamRetentionPeriodOutput, error) + func (c *Kinesis) DecreaseStreamRetentionPeriodRequest(input *DecreaseStreamRetentionPeriodInput) (req *request.Request, output *DecreaseStreamRetentionPeriodOutput) + func (c *Kinesis) DecreaseStreamRetentionPeriodWithContext(ctx aws.Context, input *DecreaseStreamRetentionPeriodInput, ...) (*DecreaseStreamRetentionPeriodOutput, error) + func (c *Kinesis) DeleteStream(input *DeleteStreamInput) (*DeleteStreamOutput, error) + func (c *Kinesis) DeleteStreamRequest(input *DeleteStreamInput) (req *request.Request, output *DeleteStreamOutput) + func (c *Kinesis) DeleteStreamWithContext(ctx aws.Context, input *DeleteStreamInput, opts ...request.Option) (*DeleteStreamOutput, error) + func (c *Kinesis) DeregisterStreamConsumer(input *DeregisterStreamConsumerInput) (*DeregisterStreamConsumerOutput, error) + func (c *Kinesis) DeregisterStreamConsumerRequest(input *DeregisterStreamConsumerInput) (req *request.Request, output *DeregisterStreamConsumerOutput) + func (c *Kinesis) DeregisterStreamConsumerWithContext(ctx aws.Context, input *DeregisterStreamConsumerInput, opts ...request.Option) (*DeregisterStreamConsumerOutput, error) + func (c *Kinesis) DescribeLimits(input *DescribeLimitsInput) (*DescribeLimitsOutput, error) + func (c *Kinesis) DescribeLimitsRequest(input *DescribeLimitsInput) (req *request.Request, output *DescribeLimitsOutput) + func (c *Kinesis) DescribeLimitsWithContext(ctx aws.Context, input *DescribeLimitsInput, opts ...request.Option) (*DescribeLimitsOutput, error) + func (c *Kinesis) DescribeStream(input *DescribeStreamInput) (*DescribeStreamOutput, error) + func (c *Kinesis) DescribeStreamConsumer(input *DescribeStreamConsumerInput) (*DescribeStreamConsumerOutput, error) + func (c *Kinesis) DescribeStreamConsumerRequest(input *DescribeStreamConsumerInput) (req *request.Request, output *DescribeStreamConsumerOutput) + func (c *Kinesis) DescribeStreamConsumerWithContext(ctx aws.Context, input *DescribeStreamConsumerInput, opts ...request.Option) (*DescribeStreamConsumerOutput, error) + func (c *Kinesis) DescribeStreamPages(input *DescribeStreamInput, fn func(*DescribeStreamOutput, bool) bool) error + func (c *Kinesis) DescribeStreamPagesWithContext(ctx aws.Context, input *DescribeStreamInput, ...) error + func (c *Kinesis) DescribeStreamRequest(input *DescribeStreamInput) (req *request.Request, output *DescribeStreamOutput) + func (c *Kinesis) DescribeStreamSummary(input *DescribeStreamSummaryInput) (*DescribeStreamSummaryOutput, error) + func (c *Kinesis) DescribeStreamSummaryRequest(input *DescribeStreamSummaryInput) (req *request.Request, output *DescribeStreamSummaryOutput) + func (c *Kinesis) DescribeStreamSummaryWithContext(ctx aws.Context, input *DescribeStreamSummaryInput, opts ...request.Option) (*DescribeStreamSummaryOutput, error) + func (c *Kinesis) DescribeStreamWithContext(ctx aws.Context, input *DescribeStreamInput, opts ...request.Option) (*DescribeStreamOutput, error) + func (c *Kinesis) DisableEnhancedMonitoring(input *DisableEnhancedMonitoringInput) (*EnhancedMonitoringOutput, error) + func (c *Kinesis) DisableEnhancedMonitoringRequest(input *DisableEnhancedMonitoringInput) (req *request.Request, output *EnhancedMonitoringOutput) + func (c *Kinesis) DisableEnhancedMonitoringWithContext(ctx aws.Context, input *DisableEnhancedMonitoringInput, opts ...request.Option) (*EnhancedMonitoringOutput, error) + func (c *Kinesis) EnableEnhancedMonitoring(input *EnableEnhancedMonitoringInput) (*EnhancedMonitoringOutput, error) + func (c *Kinesis) EnableEnhancedMonitoringRequest(input *EnableEnhancedMonitoringInput) (req *request.Request, output *EnhancedMonitoringOutput) + func (c *Kinesis) EnableEnhancedMonitoringWithContext(ctx aws.Context, input *EnableEnhancedMonitoringInput, opts ...request.Option) (*EnhancedMonitoringOutput, error) + func (c *Kinesis) GetRecords(input *GetRecordsInput) (*GetRecordsOutput, error) + func (c *Kinesis) GetRecordsRequest(input *GetRecordsInput) (req *request.Request, output *GetRecordsOutput) + func (c *Kinesis) GetRecordsWithContext(ctx aws.Context, input *GetRecordsInput, opts ...request.Option) (*GetRecordsOutput, error) + func (c *Kinesis) GetShardIterator(input *GetShardIteratorInput) (*GetShardIteratorOutput, error) + func (c *Kinesis) GetShardIteratorRequest(input *GetShardIteratorInput) (req *request.Request, output *GetShardIteratorOutput) + func (c *Kinesis) GetShardIteratorWithContext(ctx aws.Context, input *GetShardIteratorInput, opts ...request.Option) (*GetShardIteratorOutput, error) + func (c *Kinesis) IncreaseStreamRetentionPeriod(input *IncreaseStreamRetentionPeriodInput) (*IncreaseStreamRetentionPeriodOutput, error) + func (c *Kinesis) IncreaseStreamRetentionPeriodRequest(input *IncreaseStreamRetentionPeriodInput) (req *request.Request, output *IncreaseStreamRetentionPeriodOutput) + func (c *Kinesis) IncreaseStreamRetentionPeriodWithContext(ctx aws.Context, input *IncreaseStreamRetentionPeriodInput, ...) (*IncreaseStreamRetentionPeriodOutput, error) + func (c *Kinesis) ListShards(input *ListShardsInput) (*ListShardsOutput, error) + func (c *Kinesis) ListShardsRequest(input *ListShardsInput) (req *request.Request, output *ListShardsOutput) + func (c *Kinesis) ListShardsWithContext(ctx aws.Context, input *ListShardsInput, opts ...request.Option) (*ListShardsOutput, error) + func (c *Kinesis) ListStreamConsumers(input *ListStreamConsumersInput) (*ListStreamConsumersOutput, error) + func (c *Kinesis) ListStreamConsumersPages(input *ListStreamConsumersInput, ...) error + func (c *Kinesis) ListStreamConsumersPagesWithContext(ctx aws.Context, input *ListStreamConsumersInput, ...) error + func (c *Kinesis) ListStreamConsumersRequest(input *ListStreamConsumersInput) (req *request.Request, output *ListStreamConsumersOutput) + func (c *Kinesis) ListStreamConsumersWithContext(ctx aws.Context, input *ListStreamConsumersInput, opts ...request.Option) (*ListStreamConsumersOutput, error) + func (c *Kinesis) ListStreams(input *ListStreamsInput) (*ListStreamsOutput, error) + func (c *Kinesis) ListStreamsPages(input *ListStreamsInput, fn func(*ListStreamsOutput, bool) bool) error + func (c *Kinesis) ListStreamsPagesWithContext(ctx aws.Context, input *ListStreamsInput, ...) error + func (c *Kinesis) ListStreamsRequest(input *ListStreamsInput) (req *request.Request, output *ListStreamsOutput) + func (c *Kinesis) ListStreamsWithContext(ctx aws.Context, input *ListStreamsInput, opts ...request.Option) (*ListStreamsOutput, error) + func (c *Kinesis) ListTagsForStream(input *ListTagsForStreamInput) (*ListTagsForStreamOutput, error) + func (c *Kinesis) ListTagsForStreamRequest(input *ListTagsForStreamInput) (req *request.Request, output *ListTagsForStreamOutput) + func (c *Kinesis) ListTagsForStreamWithContext(ctx aws.Context, input *ListTagsForStreamInput, opts ...request.Option) (*ListTagsForStreamOutput, error) + func (c *Kinesis) MergeShards(input *MergeShardsInput) (*MergeShardsOutput, error) + func (c *Kinesis) MergeShardsRequest(input *MergeShardsInput) (req *request.Request, output *MergeShardsOutput) + func (c *Kinesis) MergeShardsWithContext(ctx aws.Context, input *MergeShardsInput, opts ...request.Option) (*MergeShardsOutput, error) + func (c *Kinesis) PutRecord(input *PutRecordInput) (*PutRecordOutput, error) + func (c *Kinesis) PutRecordRequest(input *PutRecordInput) (req *request.Request, output *PutRecordOutput) + func (c *Kinesis) PutRecordWithContext(ctx aws.Context, input *PutRecordInput, opts ...request.Option) (*PutRecordOutput, error) + func (c *Kinesis) PutRecords(input *PutRecordsInput) (*PutRecordsOutput, error) + func (c *Kinesis) PutRecordsRequest(input *PutRecordsInput) (req *request.Request, output *PutRecordsOutput) + func (c *Kinesis) PutRecordsWithContext(ctx aws.Context, input *PutRecordsInput, opts ...request.Option) (*PutRecordsOutput, error) + func (c *Kinesis) RegisterStreamConsumer(input *RegisterStreamConsumerInput) (*RegisterStreamConsumerOutput, error) + func (c *Kinesis) RegisterStreamConsumerRequest(input *RegisterStreamConsumerInput) (req *request.Request, output *RegisterStreamConsumerOutput) + func (c *Kinesis) RegisterStreamConsumerWithContext(ctx aws.Context, input *RegisterStreamConsumerInput, opts ...request.Option) (*RegisterStreamConsumerOutput, error) + func (c *Kinesis) RemoveTagsFromStream(input *RemoveTagsFromStreamInput) (*RemoveTagsFromStreamOutput, error) + func (c *Kinesis) RemoveTagsFromStreamRequest(input *RemoveTagsFromStreamInput) (req *request.Request, output *RemoveTagsFromStreamOutput) + func (c *Kinesis) RemoveTagsFromStreamWithContext(ctx aws.Context, input *RemoveTagsFromStreamInput, opts ...request.Option) (*RemoveTagsFromStreamOutput, error) + func (c *Kinesis) SplitShard(input *SplitShardInput) (*SplitShardOutput, error) + func (c *Kinesis) SplitShardRequest(input *SplitShardInput) (req *request.Request, output *SplitShardOutput) + func (c *Kinesis) SplitShardWithContext(ctx aws.Context, input *SplitShardInput, opts ...request.Option) (*SplitShardOutput, error) + func (c *Kinesis) StartStreamEncryption(input *StartStreamEncryptionInput) (*StartStreamEncryptionOutput, error) + func (c *Kinesis) StartStreamEncryptionRequest(input *StartStreamEncryptionInput) (req *request.Request, output *StartStreamEncryptionOutput) + func (c *Kinesis) StartStreamEncryptionWithContext(ctx aws.Context, input *StartStreamEncryptionInput, opts ...request.Option) (*StartStreamEncryptionOutput, error) + func (c *Kinesis) StopStreamEncryption(input *StopStreamEncryptionInput) (*StopStreamEncryptionOutput, error) + func (c *Kinesis) StopStreamEncryptionRequest(input *StopStreamEncryptionInput) (req *request.Request, output *StopStreamEncryptionOutput) + func (c *Kinesis) StopStreamEncryptionWithContext(ctx aws.Context, input *StopStreamEncryptionInput, opts ...request.Option) (*StopStreamEncryptionOutput, error) + func (c *Kinesis) SubscribeToShard(input *SubscribeToShardInput) (*SubscribeToShardOutput, error) + func (c *Kinesis) SubscribeToShardRequest(input *SubscribeToShardInput) (req *request.Request, output *SubscribeToShardOutput) + func (c *Kinesis) SubscribeToShardWithContext(ctx aws.Context, input *SubscribeToShardInput, opts ...request.Option) (*SubscribeToShardOutput, error) + func (c *Kinesis) UpdateShardCount(input *UpdateShardCountInput) (*UpdateShardCountOutput, error) + func (c *Kinesis) UpdateShardCountRequest(input *UpdateShardCountInput) (req *request.Request, output *UpdateShardCountOutput) + func (c *Kinesis) UpdateShardCountWithContext(ctx aws.Context, input *UpdateShardCountInput, opts ...request.Option) (*UpdateShardCountOutput, error) + func (c *Kinesis) UpdateStreamMode(input *UpdateStreamModeInput) (*UpdateStreamModeOutput, error) + func (c *Kinesis) UpdateStreamModeRequest(input *UpdateStreamModeInput) (req *request.Request, output *UpdateStreamModeOutput) + func (c *Kinesis) UpdateStreamModeWithContext(ctx aws.Context, input *UpdateStreamModeInput, opts ...request.Option) (*UpdateStreamModeOutput, error) + func (c *Kinesis) WaitUntilStreamExists(input *DescribeStreamInput) error + func (c *Kinesis) WaitUntilStreamExistsWithContext(ctx aws.Context, input *DescribeStreamInput, opts ...request.WaiterOption) error + func (c *Kinesis) WaitUntilStreamNotExists(input *DescribeStreamInput) error + func (c *Kinesis) WaitUntilStreamNotExistsWithContext(ctx aws.Context, input *DescribeStreamInput, opts ...request.WaiterOption) error + type LimitExceededException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *LimitExceededException) Code() string + func (s *LimitExceededException) Error() string + func (s *LimitExceededException) Message() string + func (s *LimitExceededException) OrigErr() error + func (s *LimitExceededException) RequestID() string + func (s *LimitExceededException) StatusCode() int + func (s LimitExceededException) GoString() string + func (s LimitExceededException) String() string + type ListShardsInput struct + ExclusiveStartShardId *string + MaxResults *int64 + NextToken *string + ShardFilter *ShardFilter + StreamARN *string + StreamCreationTimestamp *time.Time + StreamName *string + func (s *ListShardsInput) SetExclusiveStartShardId(v string) *ListShardsInput + func (s *ListShardsInput) SetMaxResults(v int64) *ListShardsInput + func (s *ListShardsInput) SetNextToken(v string) *ListShardsInput + func (s *ListShardsInput) SetShardFilter(v *ShardFilter) *ListShardsInput + func (s *ListShardsInput) SetStreamARN(v string) *ListShardsInput + func (s *ListShardsInput) SetStreamCreationTimestamp(v time.Time) *ListShardsInput + func (s *ListShardsInput) SetStreamName(v string) *ListShardsInput + func (s *ListShardsInput) Validate() error + func (s ListShardsInput) GoString() string + func (s ListShardsInput) String() string + type ListShardsOutput struct + NextToken *string + Shards []*Shard + func (s *ListShardsOutput) SetNextToken(v string) *ListShardsOutput + func (s *ListShardsOutput) SetShards(v []*Shard) *ListShardsOutput + func (s ListShardsOutput) GoString() string + func (s ListShardsOutput) String() string + type ListStreamConsumersInput struct + MaxResults *int64 + NextToken *string + StreamARN *string + StreamCreationTimestamp *time.Time + func (s *ListStreamConsumersInput) SetMaxResults(v int64) *ListStreamConsumersInput + func (s *ListStreamConsumersInput) SetNextToken(v string) *ListStreamConsumersInput + func (s *ListStreamConsumersInput) SetStreamARN(v string) *ListStreamConsumersInput + func (s *ListStreamConsumersInput) SetStreamCreationTimestamp(v time.Time) *ListStreamConsumersInput + func (s *ListStreamConsumersInput) Validate() error + func (s ListStreamConsumersInput) GoString() string + func (s ListStreamConsumersInput) String() string + type ListStreamConsumersOutput struct + Consumers []*Consumer + NextToken *string + func (s *ListStreamConsumersOutput) SetConsumers(v []*Consumer) *ListStreamConsumersOutput + func (s *ListStreamConsumersOutput) SetNextToken(v string) *ListStreamConsumersOutput + func (s ListStreamConsumersOutput) GoString() string + func (s ListStreamConsumersOutput) String() string + type ListStreamsInput struct + ExclusiveStartStreamName *string + Limit *int64 + NextToken *string + func (s *ListStreamsInput) SetExclusiveStartStreamName(v string) *ListStreamsInput + func (s *ListStreamsInput) SetLimit(v int64) *ListStreamsInput + func (s *ListStreamsInput) SetNextToken(v string) *ListStreamsInput + func (s *ListStreamsInput) Validate() error + func (s ListStreamsInput) GoString() string + func (s ListStreamsInput) String() string + type ListStreamsOutput struct + HasMoreStreams *bool + NextToken *string + StreamNames []*string + StreamSummaries []*StreamSummary + func (s *ListStreamsOutput) SetHasMoreStreams(v bool) *ListStreamsOutput + func (s *ListStreamsOutput) SetNextToken(v string) *ListStreamsOutput + func (s *ListStreamsOutput) SetStreamNames(v []*string) *ListStreamsOutput + func (s *ListStreamsOutput) SetStreamSummaries(v []*StreamSummary) *ListStreamsOutput + func (s ListStreamsOutput) GoString() string + func (s ListStreamsOutput) String() string + type ListTagsForStreamInput struct + ExclusiveStartTagKey *string + Limit *int64 + StreamARN *string + StreamName *string + func (s *ListTagsForStreamInput) SetExclusiveStartTagKey(v string) *ListTagsForStreamInput + func (s *ListTagsForStreamInput) SetLimit(v int64) *ListTagsForStreamInput + func (s *ListTagsForStreamInput) SetStreamARN(v string) *ListTagsForStreamInput + func (s *ListTagsForStreamInput) SetStreamName(v string) *ListTagsForStreamInput + func (s *ListTagsForStreamInput) Validate() error + func (s ListTagsForStreamInput) GoString() string + func (s ListTagsForStreamInput) String() string + type ListTagsForStreamOutput struct + HasMoreTags *bool + Tags []*Tag + func (s *ListTagsForStreamOutput) SetHasMoreTags(v bool) *ListTagsForStreamOutput + func (s *ListTagsForStreamOutput) SetTags(v []*Tag) *ListTagsForStreamOutput + func (s ListTagsForStreamOutput) GoString() string + func (s ListTagsForStreamOutput) String() string + type MergeShardsInput struct + AdjacentShardToMerge *string + ShardToMerge *string + StreamARN *string + StreamName *string + func (s *MergeShardsInput) SetAdjacentShardToMerge(v string) *MergeShardsInput + func (s *MergeShardsInput) SetShardToMerge(v string) *MergeShardsInput + func (s *MergeShardsInput) SetStreamARN(v string) *MergeShardsInput + func (s *MergeShardsInput) SetStreamName(v string) *MergeShardsInput + func (s *MergeShardsInput) Validate() error + func (s MergeShardsInput) GoString() string + func (s MergeShardsInput) String() string + type MergeShardsOutput struct + func (s MergeShardsOutput) GoString() string + func (s MergeShardsOutput) String() string + type ProvisionedThroughputExceededException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ProvisionedThroughputExceededException) Code() string + func (s *ProvisionedThroughputExceededException) Error() string + func (s *ProvisionedThroughputExceededException) Message() string + func (s *ProvisionedThroughputExceededException) OrigErr() error + func (s *ProvisionedThroughputExceededException) RequestID() string + func (s *ProvisionedThroughputExceededException) StatusCode() int + func (s ProvisionedThroughputExceededException) GoString() string + func (s ProvisionedThroughputExceededException) String() string + type PutRecordInput struct + Data []byte + ExplicitHashKey *string + PartitionKey *string + SequenceNumberForOrdering *string + StreamARN *string + StreamName *string + func (s *PutRecordInput) SetData(v []byte) *PutRecordInput + func (s *PutRecordInput) SetExplicitHashKey(v string) *PutRecordInput + func (s *PutRecordInput) SetPartitionKey(v string) *PutRecordInput + func (s *PutRecordInput) SetSequenceNumberForOrdering(v string) *PutRecordInput + func (s *PutRecordInput) SetStreamARN(v string) *PutRecordInput + func (s *PutRecordInput) SetStreamName(v string) *PutRecordInput + func (s *PutRecordInput) Validate() error + func (s PutRecordInput) GoString() string + func (s PutRecordInput) String() string + type PutRecordOutput struct + EncryptionType *string + SequenceNumber *string + ShardId *string + func (s *PutRecordOutput) SetEncryptionType(v string) *PutRecordOutput + func (s *PutRecordOutput) SetSequenceNumber(v string) *PutRecordOutput + func (s *PutRecordOutput) SetShardId(v string) *PutRecordOutput + func (s PutRecordOutput) GoString() string + func (s PutRecordOutput) String() string + type PutRecordsInput struct + Records []*PutRecordsRequestEntry + StreamARN *string + StreamName *string + func (s *PutRecordsInput) SetRecords(v []*PutRecordsRequestEntry) *PutRecordsInput + func (s *PutRecordsInput) SetStreamARN(v string) *PutRecordsInput + func (s *PutRecordsInput) SetStreamName(v string) *PutRecordsInput + func (s *PutRecordsInput) Validate() error + func (s PutRecordsInput) GoString() string + func (s PutRecordsInput) String() string + type PutRecordsOutput struct + EncryptionType *string + FailedRecordCount *int64 + Records []*PutRecordsResultEntry + func (s *PutRecordsOutput) SetEncryptionType(v string) *PutRecordsOutput + func (s *PutRecordsOutput) SetFailedRecordCount(v int64) *PutRecordsOutput + func (s *PutRecordsOutput) SetRecords(v []*PutRecordsResultEntry) *PutRecordsOutput + func (s PutRecordsOutput) GoString() string + func (s PutRecordsOutput) String() string + type PutRecordsRequestEntry struct + Data []byte + ExplicitHashKey *string + PartitionKey *string + func (s *PutRecordsRequestEntry) SetData(v []byte) *PutRecordsRequestEntry + func (s *PutRecordsRequestEntry) SetExplicitHashKey(v string) *PutRecordsRequestEntry + func (s *PutRecordsRequestEntry) SetPartitionKey(v string) *PutRecordsRequestEntry + func (s *PutRecordsRequestEntry) Validate() error + func (s PutRecordsRequestEntry) GoString() string + func (s PutRecordsRequestEntry) String() string + type PutRecordsResultEntry struct + ErrorCode *string + ErrorMessage *string + SequenceNumber *string + ShardId *string + func (s *PutRecordsResultEntry) SetErrorCode(v string) *PutRecordsResultEntry + func (s *PutRecordsResultEntry) SetErrorMessage(v string) *PutRecordsResultEntry + func (s *PutRecordsResultEntry) SetSequenceNumber(v string) *PutRecordsResultEntry + func (s *PutRecordsResultEntry) SetShardId(v string) *PutRecordsResultEntry + func (s PutRecordsResultEntry) GoString() string + func (s PutRecordsResultEntry) String() string + type Record struct + ApproximateArrivalTimestamp *time.Time + Data []byte + EncryptionType *string + PartitionKey *string + SequenceNumber *string + func (s *Record) SetApproximateArrivalTimestamp(v time.Time) *Record + func (s *Record) SetData(v []byte) *Record + func (s *Record) SetEncryptionType(v string) *Record + func (s *Record) SetPartitionKey(v string) *Record + func (s *Record) SetSequenceNumber(v string) *Record + func (s Record) GoString() string + func (s Record) String() string + type RegisterStreamConsumerInput struct + ConsumerName *string + StreamARN *string + func (s *RegisterStreamConsumerInput) SetConsumerName(v string) *RegisterStreamConsumerInput + func (s *RegisterStreamConsumerInput) SetStreamARN(v string) *RegisterStreamConsumerInput + func (s *RegisterStreamConsumerInput) Validate() error + func (s RegisterStreamConsumerInput) GoString() string + func (s RegisterStreamConsumerInput) String() string + type RegisterStreamConsumerOutput struct + Consumer *Consumer + func (s *RegisterStreamConsumerOutput) SetConsumer(v *Consumer) *RegisterStreamConsumerOutput + func (s RegisterStreamConsumerOutput) GoString() string + func (s RegisterStreamConsumerOutput) String() string + type RemoveTagsFromStreamInput struct + StreamARN *string + StreamName *string + TagKeys []*string + func (s *RemoveTagsFromStreamInput) SetStreamARN(v string) *RemoveTagsFromStreamInput + func (s *RemoveTagsFromStreamInput) SetStreamName(v string) *RemoveTagsFromStreamInput + func (s *RemoveTagsFromStreamInput) SetTagKeys(v []*string) *RemoveTagsFromStreamInput + func (s *RemoveTagsFromStreamInput) Validate() error + func (s RemoveTagsFromStreamInput) GoString() string + func (s RemoveTagsFromStreamInput) String() string + type RemoveTagsFromStreamOutput struct + func (s RemoveTagsFromStreamOutput) GoString() string + func (s RemoveTagsFromStreamOutput) String() string + type ResourceInUseException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ResourceInUseException) Code() string + func (s *ResourceInUseException) Error() string + func (s *ResourceInUseException) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *ResourceInUseException) Message() string + func (s *ResourceInUseException) OrigErr() error + func (s *ResourceInUseException) RequestID() string + func (s *ResourceInUseException) StatusCode() int + func (s *ResourceInUseException) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s ResourceInUseException) GoString() string + func (s ResourceInUseException) String() string + type ResourceNotFoundException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ResourceNotFoundException) Code() string + func (s *ResourceNotFoundException) Error() string + func (s *ResourceNotFoundException) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *ResourceNotFoundException) Message() string + func (s *ResourceNotFoundException) OrigErr() error + func (s *ResourceNotFoundException) RequestID() string + func (s *ResourceNotFoundException) StatusCode() int + func (s *ResourceNotFoundException) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s ResourceNotFoundException) GoString() string + func (s ResourceNotFoundException) String() string + type SequenceNumberRange struct + EndingSequenceNumber *string + StartingSequenceNumber *string + func (s *SequenceNumberRange) SetEndingSequenceNumber(v string) *SequenceNumberRange + func (s *SequenceNumberRange) SetStartingSequenceNumber(v string) *SequenceNumberRange + func (s SequenceNumberRange) GoString() string + func (s SequenceNumberRange) String() string + type Shard struct + AdjacentParentShardId *string + HashKeyRange *HashKeyRange + ParentShardId *string + SequenceNumberRange *SequenceNumberRange + ShardId *string + func (s *Shard) SetAdjacentParentShardId(v string) *Shard + func (s *Shard) SetHashKeyRange(v *HashKeyRange) *Shard + func (s *Shard) SetParentShardId(v string) *Shard + func (s *Shard) SetSequenceNumberRange(v *SequenceNumberRange) *Shard + func (s *Shard) SetShardId(v string) *Shard + func (s Shard) GoString() string + func (s Shard) String() string + type ShardFilter struct + ShardId *string + Timestamp *time.Time + Type *string + func (s *ShardFilter) SetShardId(v string) *ShardFilter + func (s *ShardFilter) SetTimestamp(v time.Time) *ShardFilter + func (s *ShardFilter) SetType(v string) *ShardFilter + func (s *ShardFilter) Validate() error + func (s ShardFilter) GoString() string + func (s ShardFilter) String() string + type SplitShardInput struct + NewStartingHashKey *string + ShardToSplit *string + StreamARN *string + StreamName *string + func (s *SplitShardInput) SetNewStartingHashKey(v string) *SplitShardInput + func (s *SplitShardInput) SetShardToSplit(v string) *SplitShardInput + func (s *SplitShardInput) SetStreamARN(v string) *SplitShardInput + func (s *SplitShardInput) SetStreamName(v string) *SplitShardInput + func (s *SplitShardInput) Validate() error + func (s SplitShardInput) GoString() string + func (s SplitShardInput) String() string + type SplitShardOutput struct + func (s SplitShardOutput) GoString() string + func (s SplitShardOutput) String() string + type StartStreamEncryptionInput struct + EncryptionType *string + KeyId *string + StreamARN *string + StreamName *string + func (s *StartStreamEncryptionInput) SetEncryptionType(v string) *StartStreamEncryptionInput + func (s *StartStreamEncryptionInput) SetKeyId(v string) *StartStreamEncryptionInput + func (s *StartStreamEncryptionInput) SetStreamARN(v string) *StartStreamEncryptionInput + func (s *StartStreamEncryptionInput) SetStreamName(v string) *StartStreamEncryptionInput + func (s *StartStreamEncryptionInput) Validate() error + func (s StartStreamEncryptionInput) GoString() string + func (s StartStreamEncryptionInput) String() string + type StartStreamEncryptionOutput struct + func (s StartStreamEncryptionOutput) GoString() string + func (s StartStreamEncryptionOutput) String() string + type StartingPosition struct + SequenceNumber *string + Timestamp *time.Time + Type *string + func (s *StartingPosition) SetSequenceNumber(v string) *StartingPosition + func (s *StartingPosition) SetTimestamp(v time.Time) *StartingPosition + func (s *StartingPosition) SetType(v string) *StartingPosition + func (s *StartingPosition) Validate() error + func (s StartingPosition) GoString() string + func (s StartingPosition) String() string + type StopStreamEncryptionInput struct + EncryptionType *string + KeyId *string + StreamARN *string + StreamName *string + func (s *StopStreamEncryptionInput) SetEncryptionType(v string) *StopStreamEncryptionInput + func (s *StopStreamEncryptionInput) SetKeyId(v string) *StopStreamEncryptionInput + func (s *StopStreamEncryptionInput) SetStreamARN(v string) *StopStreamEncryptionInput + func (s *StopStreamEncryptionInput) SetStreamName(v string) *StopStreamEncryptionInput + func (s *StopStreamEncryptionInput) Validate() error + func (s StopStreamEncryptionInput) GoString() string + func (s StopStreamEncryptionInput) String() string + type StopStreamEncryptionOutput struct + func (s StopStreamEncryptionOutput) GoString() string + func (s StopStreamEncryptionOutput) String() string + type StreamDescription struct + EncryptionType *string + EnhancedMonitoring []*EnhancedMetrics + HasMoreShards *bool + KeyId *string + RetentionPeriodHours *int64 + Shards []*Shard + StreamARN *string + StreamCreationTimestamp *time.Time + StreamModeDetails *StreamModeDetails + StreamName *string + StreamStatus *string + func (s *StreamDescription) SetEncryptionType(v string) *StreamDescription + func (s *StreamDescription) SetEnhancedMonitoring(v []*EnhancedMetrics) *StreamDescription + func (s *StreamDescription) SetHasMoreShards(v bool) *StreamDescription + func (s *StreamDescription) SetKeyId(v string) *StreamDescription + func (s *StreamDescription) SetRetentionPeriodHours(v int64) *StreamDescription + func (s *StreamDescription) SetShards(v []*Shard) *StreamDescription + func (s *StreamDescription) SetStreamARN(v string) *StreamDescription + func (s *StreamDescription) SetStreamCreationTimestamp(v time.Time) *StreamDescription + func (s *StreamDescription) SetStreamModeDetails(v *StreamModeDetails) *StreamDescription + func (s *StreamDescription) SetStreamName(v string) *StreamDescription + func (s *StreamDescription) SetStreamStatus(v string) *StreamDescription + func (s StreamDescription) GoString() string + func (s StreamDescription) String() string + type StreamDescriptionSummary struct + ConsumerCount *int64 + EncryptionType *string + EnhancedMonitoring []*EnhancedMetrics + KeyId *string + OpenShardCount *int64 + RetentionPeriodHours *int64 + StreamARN *string + StreamCreationTimestamp *time.Time + StreamModeDetails *StreamModeDetails + StreamName *string + StreamStatus *string + func (s *StreamDescriptionSummary) SetConsumerCount(v int64) *StreamDescriptionSummary + func (s *StreamDescriptionSummary) SetEncryptionType(v string) *StreamDescriptionSummary + func (s *StreamDescriptionSummary) SetEnhancedMonitoring(v []*EnhancedMetrics) *StreamDescriptionSummary + func (s *StreamDescriptionSummary) SetKeyId(v string) *StreamDescriptionSummary + func (s *StreamDescriptionSummary) SetOpenShardCount(v int64) *StreamDescriptionSummary + func (s *StreamDescriptionSummary) SetRetentionPeriodHours(v int64) *StreamDescriptionSummary + func (s *StreamDescriptionSummary) SetStreamARN(v string) *StreamDescriptionSummary + func (s *StreamDescriptionSummary) SetStreamCreationTimestamp(v time.Time) *StreamDescriptionSummary + func (s *StreamDescriptionSummary) SetStreamModeDetails(v *StreamModeDetails) *StreamDescriptionSummary + func (s *StreamDescriptionSummary) SetStreamName(v string) *StreamDescriptionSummary + func (s *StreamDescriptionSummary) SetStreamStatus(v string) *StreamDescriptionSummary + func (s StreamDescriptionSummary) GoString() string + func (s StreamDescriptionSummary) String() string + type StreamModeDetails struct + StreamMode *string + func (s *StreamModeDetails) SetStreamMode(v string) *StreamModeDetails + func (s *StreamModeDetails) Validate() error + func (s StreamModeDetails) GoString() string + func (s StreamModeDetails) String() string + type StreamSummary struct + StreamARN *string + StreamCreationTimestamp *time.Time + StreamModeDetails *StreamModeDetails + StreamName *string + StreamStatus *string + func (s *StreamSummary) SetStreamARN(v string) *StreamSummary + func (s *StreamSummary) SetStreamCreationTimestamp(v time.Time) *StreamSummary + func (s *StreamSummary) SetStreamModeDetails(v *StreamModeDetails) *StreamSummary + func (s *StreamSummary) SetStreamName(v string) *StreamSummary + func (s *StreamSummary) SetStreamStatus(v string) *StreamSummary + func (s StreamSummary) GoString() string + func (s StreamSummary) String() string + type SubscribeToShardEvent struct + ChildShards []*ChildShard + ContinuationSequenceNumber *string + MillisBehindLatest *int64 + Records []*Record + func (s *SubscribeToShardEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *SubscribeToShardEvent) SetChildShards(v []*ChildShard) *SubscribeToShardEvent + func (s *SubscribeToShardEvent) SetContinuationSequenceNumber(v string) *SubscribeToShardEvent + func (s *SubscribeToShardEvent) SetMillisBehindLatest(v int64) *SubscribeToShardEvent + func (s *SubscribeToShardEvent) SetRecords(v []*Record) *SubscribeToShardEvent + func (s *SubscribeToShardEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s SubscribeToShardEvent) GoString() string + func (s SubscribeToShardEvent) String() string + type SubscribeToShardEventStream struct + Reader SubscribeToShardEventStreamReader + StreamCloser io.Closer + func NewSubscribeToShardEventStream(opts ...func(*SubscribeToShardEventStream)) *SubscribeToShardEventStream + func (es *SubscribeToShardEventStream) Close() (err error) + func (es *SubscribeToShardEventStream) Err() error + func (es *SubscribeToShardEventStream) Events() <-chan SubscribeToShardEventStreamEvent + type SubscribeToShardEventStreamEvent interface + type SubscribeToShardEventStreamReader interface + Close func() error + Err func() error + Events func() <-chan SubscribeToShardEventStreamEvent + type SubscribeToShardEventStreamUnknownEvent struct + Message eventstream.Message + Type string + func (e *SubscribeToShardEventStreamUnknownEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (e *SubscribeToShardEventStreamUnknownEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + type SubscribeToShardInput struct + ConsumerARN *string + ShardId *string + StartingPosition *StartingPosition + func (s *SubscribeToShardInput) SetConsumerARN(v string) *SubscribeToShardInput + func (s *SubscribeToShardInput) SetShardId(v string) *SubscribeToShardInput + func (s *SubscribeToShardInput) SetStartingPosition(v *StartingPosition) *SubscribeToShardInput + func (s *SubscribeToShardInput) Validate() error + func (s SubscribeToShardInput) GoString() string + func (s SubscribeToShardInput) String() string + type SubscribeToShardOutput struct + EventStream *SubscribeToShardEventStream + func (s *SubscribeToShardOutput) GetEventStream() *SubscribeToShardEventStream + func (s *SubscribeToShardOutput) GetStream() *SubscribeToShardEventStream + func (s *SubscribeToShardOutput) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *SubscribeToShardOutput) SetEventStream(v *SubscribeToShardEventStream) *SubscribeToShardOutput + func (s *SubscribeToShardOutput) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s SubscribeToShardOutput) GoString() string + func (s SubscribeToShardOutput) String() string + type Tag struct + Key *string + Value *string + func (s *Tag) SetKey(v string) *Tag + func (s *Tag) SetValue(v string) *Tag + func (s Tag) GoString() string + func (s Tag) String() string + type UpdateShardCountInput struct + ScalingType *string + StreamARN *string + StreamName *string + TargetShardCount *int64 + func (s *UpdateShardCountInput) SetScalingType(v string) *UpdateShardCountInput + func (s *UpdateShardCountInput) SetStreamARN(v string) *UpdateShardCountInput + func (s *UpdateShardCountInput) SetStreamName(v string) *UpdateShardCountInput + func (s *UpdateShardCountInput) SetTargetShardCount(v int64) *UpdateShardCountInput + func (s *UpdateShardCountInput) Validate() error + func (s UpdateShardCountInput) GoString() string + func (s UpdateShardCountInput) String() string + type UpdateShardCountOutput struct + CurrentShardCount *int64 + StreamARN *string + StreamName *string + TargetShardCount *int64 + func (s *UpdateShardCountOutput) SetCurrentShardCount(v int64) *UpdateShardCountOutput + func (s *UpdateShardCountOutput) SetStreamARN(v string) *UpdateShardCountOutput + func (s *UpdateShardCountOutput) SetStreamName(v string) *UpdateShardCountOutput + func (s *UpdateShardCountOutput) SetTargetShardCount(v int64) *UpdateShardCountOutput + func (s UpdateShardCountOutput) GoString() string + func (s UpdateShardCountOutput) String() string + type UpdateStreamModeInput struct + StreamARN *string + StreamModeDetails *StreamModeDetails + func (s *UpdateStreamModeInput) SetStreamARN(v string) *UpdateStreamModeInput + func (s *UpdateStreamModeInput) SetStreamModeDetails(v *StreamModeDetails) *UpdateStreamModeInput + func (s *UpdateStreamModeInput) Validate() error + func (s UpdateStreamModeInput) GoString() string + func (s UpdateStreamModeInput) String() string + type UpdateStreamModeOutput struct + func (s UpdateStreamModeOutput) GoString() string + func (s UpdateStreamModeOutput) String() string + type ValidationException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ValidationException) Code() string + func (s *ValidationException) Error() string + func (s *ValidationException) Message() string + func (s *ValidationException) OrigErr() error + func (s *ValidationException) RequestID() string + func (s *ValidationException) StatusCode() int + func (s ValidationException) GoString() string + func (s ValidationException) String() string
Go to main page