kinesis

package

Go to main page

Versions in this module

v0

v0.4.0

May 26, 2018

v0.3.0

Mar 8, 2018

Changes in this version

+ const ErrCodeExpiredNextTokenException

type AddTagsToStreamRequest

+ Copy func(*AddTagsToStreamInput) AddTagsToStreamRequest

type CreateStreamRequest

+ Copy func(*CreateStreamInput) CreateStreamRequest

type DecreaseStreamRetentionPeriodRequest

+ Copy func(*DecreaseStreamRetentionPeriodInput) DecreaseStreamRetentionPeriodRequest

type DeleteStreamRequest

+ Copy func(*DeleteStreamInput) DeleteStreamRequest

type DescribeLimitsRequest

+ Copy func(*DescribeLimitsInput) DescribeLimitsRequest

+ type DescribeStreamPager struct

+ func (p *DescribeStreamPager) CurrentPage() *DescribeStreamOutput

type DescribeStreamRequest

+ Copy func(*DescribeStreamInput) DescribeStreamRequest

+ func (p *DescribeStreamRequest) Paginate(opts ...aws.Option) DescribeStreamPager

type DescribeStreamSummaryRequest

+ Copy func(*DescribeStreamSummaryInput) DescribeStreamSummaryRequest

type DisableEnhancedMonitoringRequest

+ Copy func(*DisableEnhancedMonitoringInput) DisableEnhancedMonitoringRequest

type EnableEnhancedMonitoringRequest

+ Copy func(*EnableEnhancedMonitoringInput) EnableEnhancedMonitoringRequest

type EncryptionType

+ func (enum EncryptionType) MarshalValue() (string, error)

+ func (enum EncryptionType) MarshalValueBuf(b []byte) ([]byte, error)

type GetRecordsRequest

+ Copy func(*GetRecordsInput) GetRecordsRequest

type GetShardIteratorRequest

+ Copy func(*GetShardIteratorInput) GetShardIteratorRequest

type IncreaseStreamRetentionPeriodRequest

+ Copy func(*IncreaseStreamRetentionPeriodInput) IncreaseStreamRetentionPeriodRequest

type Kinesis

+ func (c *Kinesis) ListShardsRequest(input *ListShardsInput) ListShardsRequest

+ type ListShardsInput struct

+ ExclusiveStartShardId *string

+ MaxResults *int64

+ NextToken *string

+ StreamCreationTimestamp *time.Time

+ StreamName *string

+ 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) GoString() string

+ func (s ListShardsOutput) SDKResponseMetadata() aws.Response

+ func (s ListShardsOutput) String() string

+ type ListShardsRequest struct

+ Copy func(*ListShardsInput) ListShardsRequest

+ Input *ListShardsInput

+ func (r ListShardsRequest) Send() (*ListShardsOutput, error)

+ type ListStreamsPager struct

+ func (p *ListStreamsPager) CurrentPage() *ListStreamsOutput

type ListStreamsRequest

+ Copy func(*ListStreamsInput) ListStreamsRequest

+ func (p *ListStreamsRequest) Paginate(opts ...aws.Option) ListStreamsPager

type ListTagsForStreamRequest

+ Copy func(*ListTagsForStreamInput) ListTagsForStreamRequest

type MergeShardsRequest

+ Copy func(*MergeShardsInput) MergeShardsRequest

type MetricsName

+ func (enum MetricsName) MarshalValue() (string, error)

+ func (enum MetricsName) MarshalValueBuf(b []byte) ([]byte, error)

type PutRecordRequest

+ Copy func(*PutRecordInput) PutRecordRequest

type PutRecordsRequest

+ Copy func(*PutRecordsInput) PutRecordsRequest

type RemoveTagsFromStreamRequest

+ Copy func(*RemoveTagsFromStreamInput) RemoveTagsFromStreamRequest

type ScalingType

+ func (enum ScalingType) MarshalValue() (string, error)

+ func (enum ScalingType) MarshalValueBuf(b []byte) ([]byte, error)

type ShardIteratorType

+ func (enum ShardIteratorType) MarshalValue() (string, error)

+ func (enum ShardIteratorType) MarshalValueBuf(b []byte) ([]byte, error)

type SplitShardRequest

+ Copy func(*SplitShardInput) SplitShardRequest

type StartStreamEncryptionRequest

+ Copy func(*StartStreamEncryptionInput) StartStreamEncryptionRequest

type StopStreamEncryptionRequest

+ Copy func(*StopStreamEncryptionInput) StopStreamEncryptionRequest

type StreamStatus

+ func (enum StreamStatus) MarshalValue() (string, error)

+ func (enum StreamStatus) MarshalValueBuf(b []byte) ([]byte, error)

type UpdateShardCountRequest

+ Copy func(*UpdateShardCountInput) UpdateShardCountRequest

v0.2.0

Jan 15, 2018

Changes in this version

+ type DescribeStreamSummaryInput struct

+ StreamName *string

+ 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) SDKResponseMetadata() aws.Response

+ func (s DescribeStreamSummaryOutput) String() string

+ type DescribeStreamSummaryRequest struct

+ Input *DescribeStreamSummaryInput

+ func (r DescribeStreamSummaryRequest) Send() (*DescribeStreamSummaryOutput, error)

type Kinesis

+ func (c *Kinesis) DescribeStreamSummaryRequest(input *DescribeStreamSummaryInput) DescribeStreamSummaryRequest

+ type StreamDescriptionSummary struct

+ EncryptionType EncryptionType

+ EnhancedMonitoring []EnhancedMetrics

+ KeyId *string

+ OpenShardCount *int64

+ RetentionPeriodHours *int64

+ StreamARN *string

+ StreamCreationTimestamp *time.Time

+ StreamName *string

+ StreamStatus StreamStatus

+ func (s *StreamDescriptionSummary) SetEncryptionType(v EncryptionType) *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) SetStreamName(v string) *StreamDescriptionSummary

+ func (s *StreamDescriptionSummary) SetStreamStatus(v StreamStatus) *StreamDescriptionSummary

+ func (s StreamDescriptionSummary) GoString() string

+ func (s StreamDescriptionSummary) String() string

v0.1.0

Dec 21, 2017

Changes in this version

+ const EndpointsID

+ const ErrCodeExpiredIteratorException

+ const ErrCodeInvalidArgumentException

+ const ErrCodeKMSAccessDeniedException

+ const ErrCodeKMSDisabledException

+ const ErrCodeKMSInvalidStateException

+ const ErrCodeKMSNotFoundException

+ const ErrCodeKMSOptInRequired

+ const ErrCodeKMSThrottlingException

+ const ErrCodeLimitExceededException

+ const ErrCodeProvisionedThroughputExceededException

+ const ErrCodeResourceInUseException

+ const ErrCodeResourceNotFoundException

+ const ServiceName

+ type AddTagsToStreamInput struct

+ StreamName *string

+ Tags map[string]string

+ 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) SDKResponseMetadata() aws.Response

+ func (s AddTagsToStreamOutput) String() string

+ type AddTagsToStreamRequest struct

+ Input *AddTagsToStreamInput

+ func (r AddTagsToStreamRequest) Send() (*AddTagsToStreamOutput, error)

+ type CreateStreamInput struct

+ ShardCount *int64

+ StreamName *string

+ func (s *CreateStreamInput) SetShardCount(v int64) *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) SDKResponseMetadata() aws.Response

+ func (s CreateStreamOutput) String() string

+ type CreateStreamRequest struct

+ Input *CreateStreamInput

+ func (r CreateStreamRequest) Send() (*CreateStreamOutput, error)

+ type DecreaseStreamRetentionPeriodInput struct

+ RetentionPeriodHours *int64

+ StreamName *string

+ func (s *DecreaseStreamRetentionPeriodInput) SetRetentionPeriodHours(v int64) *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) SDKResponseMetadata() aws.Response

+ func (s DecreaseStreamRetentionPeriodOutput) String() string

+ type DecreaseStreamRetentionPeriodRequest struct

+ Input *DecreaseStreamRetentionPeriodInput

+ func (r DecreaseStreamRetentionPeriodRequest) Send() (*DecreaseStreamRetentionPeriodOutput, error)

+ type DeleteStreamInput struct

+ StreamName *string

+ 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) SDKResponseMetadata() aws.Response

+ func (s DeleteStreamOutput) String() string

+ type DeleteStreamRequest struct

+ Input *DeleteStreamInput

+ func (r DeleteStreamRequest) Send() (*DeleteStreamOutput, error)

+ type DescribeLimitsInput struct

+ func (s DescribeLimitsInput) GoString() string

+ func (s DescribeLimitsInput) String() string

+ type DescribeLimitsOutput struct

+ OpenShardCount *int64

+ ShardLimit *int64

+ func (s *DescribeLimitsOutput) SetOpenShardCount(v int64) *DescribeLimitsOutput

+ func (s *DescribeLimitsOutput) SetShardLimit(v int64) *DescribeLimitsOutput

+ func (s DescribeLimitsOutput) GoString() string

+ func (s DescribeLimitsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeLimitsOutput) String() string

+ type DescribeLimitsRequest struct

+ Input *DescribeLimitsInput

+ func (r DescribeLimitsRequest) Send() (*DescribeLimitsOutput, error)

+ type DescribeStreamInput struct

+ ExclusiveStartShardId *string

+ Limit *int64

+ StreamName *string

+ func (s *DescribeStreamInput) SetExclusiveStartShardId(v string) *DescribeStreamInput

+ func (s *DescribeStreamInput) SetLimit(v int64) *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) SDKResponseMetadata() aws.Response

+ func (s DescribeStreamOutput) String() string

+ type DescribeStreamRequest struct

+ Input *DescribeStreamInput

+ func (r DescribeStreamRequest) Send() (*DescribeStreamOutput, error)

+ type DisableEnhancedMonitoringInput struct

+ ShardLevelMetrics []MetricsName

+ StreamName *string

+ func (s *DisableEnhancedMonitoringInput) SetShardLevelMetrics(v []MetricsName) *DisableEnhancedMonitoringInput

+ func (s *DisableEnhancedMonitoringInput) SetStreamName(v string) *DisableEnhancedMonitoringInput

+ func (s *DisableEnhancedMonitoringInput) Validate() error

+ func (s DisableEnhancedMonitoringInput) GoString() string

+ func (s DisableEnhancedMonitoringInput) String() string

+ type DisableEnhancedMonitoringRequest struct

+ Input *DisableEnhancedMonitoringInput

+ func (r DisableEnhancedMonitoringRequest) Send() (*EnableEnhancedMonitoringOutput, error)

+ type EnableEnhancedMonitoringInput struct

+ ShardLevelMetrics []MetricsName

+ StreamName *string

+ func (s *EnableEnhancedMonitoringInput) SetShardLevelMetrics(v []MetricsName) *EnableEnhancedMonitoringInput

+ func (s *EnableEnhancedMonitoringInput) SetStreamName(v string) *EnableEnhancedMonitoringInput

+ func (s *EnableEnhancedMonitoringInput) Validate() error

+ func (s EnableEnhancedMonitoringInput) GoString() string

+ func (s EnableEnhancedMonitoringInput) String() string

+ type EnableEnhancedMonitoringOutput struct

+ CurrentShardLevelMetrics []MetricsName

+ DesiredShardLevelMetrics []MetricsName

+ StreamName *string

+ func (s *EnableEnhancedMonitoringOutput) SetCurrentShardLevelMetrics(v []MetricsName) *EnableEnhancedMonitoringOutput

+ func (s *EnableEnhancedMonitoringOutput) SetDesiredShardLevelMetrics(v []MetricsName) *EnableEnhancedMonitoringOutput

+ func (s *EnableEnhancedMonitoringOutput) SetStreamName(v string) *EnableEnhancedMonitoringOutput

+ func (s EnableEnhancedMonitoringOutput) GoString() string

+ func (s EnableEnhancedMonitoringOutput) SDKResponseMetadata() aws.Response

+ func (s EnableEnhancedMonitoringOutput) String() string

+ type EnableEnhancedMonitoringRequest struct

+ Input *EnableEnhancedMonitoringInput

+ func (r EnableEnhancedMonitoringRequest) Send() (*EnableEnhancedMonitoringOutput, error)

+ type EncryptionType string

+ const EncryptionTypeKms

+ const EncryptionTypeNone

+ type EnhancedMetrics struct

+ ShardLevelMetrics []MetricsName

+ func (s *EnhancedMetrics) SetShardLevelMetrics(v []MetricsName) *EnhancedMetrics

+ func (s EnhancedMetrics) GoString() string

+ func (s EnhancedMetrics) String() string

+ type GetRecordsInput struct

+ Limit *int64

+ ShardIterator *string

+ func (s *GetRecordsInput) SetLimit(v int64) *GetRecordsInput

+ func (s *GetRecordsInput) SetShardIterator(v string) *GetRecordsInput

+ func (s *GetRecordsInput) Validate() error

+ func (s GetRecordsInput) GoString() string

+ func (s GetRecordsInput) String() string

+ type GetRecordsOutput struct

+ MillisBehindLatest *int64

+ NextShardIterator *string

+ Records []Record

+ 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) SDKResponseMetadata() aws.Response

+ func (s GetRecordsOutput) String() string

+ type GetRecordsRequest struct

+ Input *GetRecordsInput

+ func (r GetRecordsRequest) Send() (*GetRecordsOutput, error)

+ type GetShardIteratorInput struct

+ ShardId *string

+ ShardIteratorType ShardIteratorType

+ StartingSequenceNumber *string

+ StreamName *string

+ Timestamp *time.Time

+ func (s *GetShardIteratorInput) SetShardId(v string) *GetShardIteratorInput

+ func (s *GetShardIteratorInput) SetShardIteratorType(v ShardIteratorType) *GetShardIteratorInput

+ func (s *GetShardIteratorInput) SetStartingSequenceNumber(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) SDKResponseMetadata() aws.Response

+ func (s GetShardIteratorOutput) String() string

+ type GetShardIteratorRequest struct

+ Input *GetShardIteratorInput

+ func (r GetShardIteratorRequest) Send() (*GetShardIteratorOutput, error)

+ 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

+ StreamName *string

+ func (s *IncreaseStreamRetentionPeriodInput) SetRetentionPeriodHours(v int64) *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) SDKResponseMetadata() aws.Response

+ func (s IncreaseStreamRetentionPeriodOutput) String() string

+ type IncreaseStreamRetentionPeriodRequest struct

+ Input *IncreaseStreamRetentionPeriodInput

+ func (r IncreaseStreamRetentionPeriodRequest) Send() (*IncreaseStreamRetentionPeriodOutput, error)

+ type Kinesis struct

+ func New(config aws.Config) *Kinesis

+ func (c *Kinesis) AddTagsToStreamRequest(input *AddTagsToStreamInput) AddTagsToStreamRequest

+ func (c *Kinesis) CreateStreamRequest(input *CreateStreamInput) CreateStreamRequest

+ func (c *Kinesis) DecreaseStreamRetentionPeriodRequest(input *DecreaseStreamRetentionPeriodInput) DecreaseStreamRetentionPeriodRequest

+ func (c *Kinesis) DeleteStreamRequest(input *DeleteStreamInput) DeleteStreamRequest

+ func (c *Kinesis) DescribeLimitsRequest(input *DescribeLimitsInput) DescribeLimitsRequest

+ 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) DescribeStreamRequest

+ func (c *Kinesis) DisableEnhancedMonitoringRequest(input *DisableEnhancedMonitoringInput) DisableEnhancedMonitoringRequest

+ func (c *Kinesis) EnableEnhancedMonitoringRequest(input *EnableEnhancedMonitoringInput) EnableEnhancedMonitoringRequest

+ func (c *Kinesis) GetRecordsRequest(input *GetRecordsInput) GetRecordsRequest

+ func (c *Kinesis) GetShardIteratorRequest(input *GetShardIteratorInput) GetShardIteratorRequest

+ func (c *Kinesis) IncreaseStreamRetentionPeriodRequest(input *IncreaseStreamRetentionPeriodInput) IncreaseStreamRetentionPeriodRequest

+ 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) ListStreamsRequest

+ func (c *Kinesis) ListTagsForStreamRequest(input *ListTagsForStreamInput) ListTagsForStreamRequest

+ func (c *Kinesis) MergeShardsRequest(input *MergeShardsInput) MergeShardsRequest

+ func (c *Kinesis) PutRecordRequest(input *PutRecordInput) PutRecordRequest

+ func (c *Kinesis) PutRecordsRequest(input *PutRecordsInput) PutRecordsRequest

+ func (c *Kinesis) RemoveTagsFromStreamRequest(input *RemoveTagsFromStreamInput) RemoveTagsFromStreamRequest

+ func (c *Kinesis) SplitShardRequest(input *SplitShardInput) SplitShardRequest

+ func (c *Kinesis) StartStreamEncryptionRequest(input *StartStreamEncryptionInput) StartStreamEncryptionRequest

+ func (c *Kinesis) StopStreamEncryptionRequest(input *StopStreamEncryptionInput) StopStreamEncryptionRequest

+ func (c *Kinesis) UpdateShardCountRequest(input *UpdateShardCountInput) UpdateShardCountRequest

+ func (c *Kinesis) WaitUntilStreamExists(input *DescribeStreamInput) error

+ func (c *Kinesis) WaitUntilStreamExistsWithContext(ctx aws.Context, input *DescribeStreamInput, opts ...aws.WaiterOption) error

+ func (c *Kinesis) WaitUntilStreamNotExists(input *DescribeStreamInput) error

+ func (c *Kinesis) WaitUntilStreamNotExistsWithContext(ctx aws.Context, input *DescribeStreamInput, opts ...aws.WaiterOption) error

+ type ListStreamsInput struct

+ ExclusiveStartStreamName *string

+ Limit *int64

+ func (s *ListStreamsInput) SetExclusiveStartStreamName(v string) *ListStreamsInput

+ func (s *ListStreamsInput) SetLimit(v int64) *ListStreamsInput

+ func (s *ListStreamsInput) Validate() error

+ func (s ListStreamsInput) GoString() string

+ func (s ListStreamsInput) String() string

+ type ListStreamsOutput struct

+ HasMoreStreams *bool

+ StreamNames []string

+ func (s *ListStreamsOutput) SetHasMoreStreams(v bool) *ListStreamsOutput

+ func (s *ListStreamsOutput) SetStreamNames(v []string) *ListStreamsOutput

+ func (s ListStreamsOutput) GoString() string

+ func (s ListStreamsOutput) SDKResponseMetadata() aws.Response

+ func (s ListStreamsOutput) String() string

+ type ListStreamsRequest struct

+ Input *ListStreamsInput

+ func (r ListStreamsRequest) Send() (*ListStreamsOutput, error)

+ type ListTagsForStreamInput struct

+ ExclusiveStartTagKey *string

+ Limit *int64

+ StreamName *string

+ func (s *ListTagsForStreamInput) SetExclusiveStartTagKey(v string) *ListTagsForStreamInput

+ func (s *ListTagsForStreamInput) SetLimit(v int64) *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) SDKResponseMetadata() aws.Response

+ func (s ListTagsForStreamOutput) String() string

+ type ListTagsForStreamRequest struct

+ Input *ListTagsForStreamInput

+ func (r ListTagsForStreamRequest) Send() (*ListTagsForStreamOutput, error)

+ type MergeShardsInput struct

+ AdjacentShardToMerge *string

+ ShardToMerge *string

+ StreamName *string

+ func (s *MergeShardsInput) SetAdjacentShardToMerge(v string) *MergeShardsInput

+ func (s *MergeShardsInput) SetShardToMerge(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) SDKResponseMetadata() aws.Response

+ func (s MergeShardsOutput) String() string

+ type MergeShardsRequest struct

+ Input *MergeShardsInput

+ func (r MergeShardsRequest) Send() (*MergeShardsOutput, error)

+ type MetricsName string

+ const MetricsNameAll

+ const MetricsNameIncomingBytes

+ const MetricsNameIncomingRecords

+ const MetricsNameIteratorAgeMilliseconds

+ const MetricsNameOutgoingBytes

+ const MetricsNameOutgoingRecords

+ const MetricsNameReadProvisionedThroughputExceeded

+ const MetricsNameWriteProvisionedThroughputExceeded

+ type PutRecordInput struct

+ Data []byte

+ ExplicitHashKey *string

+ PartitionKey *string

+ SequenceNumberForOrdering *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) SetStreamName(v string) *PutRecordInput

+ func (s *PutRecordInput) Validate() error

+ func (s PutRecordInput) GoString() string

+ func (s PutRecordInput) String() string

+ type PutRecordOutput struct

+ EncryptionType EncryptionType

+ SequenceNumber *string

+ ShardId *string

+ func (s *PutRecordOutput) SetEncryptionType(v EncryptionType) *PutRecordOutput

+ func (s *PutRecordOutput) SetSequenceNumber(v string) *PutRecordOutput

+ func (s *PutRecordOutput) SetShardId(v string) *PutRecordOutput

+ func (s PutRecordOutput) GoString() string

+ func (s PutRecordOutput) SDKResponseMetadata() aws.Response

+ func (s PutRecordOutput) String() string

+ type PutRecordRequest struct

+ Input *PutRecordInput

+ func (r PutRecordRequest) Send() (*PutRecordOutput, error)

+ type PutRecordsInput struct

+ Records []PutRecordsRequestEntry

+ StreamName *string

+ func (s *PutRecordsInput) SetRecords(v []PutRecordsRequestEntry) *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 EncryptionType

+ FailedRecordCount *int64

+ Records []PutRecordsResultEntry

+ func (s *PutRecordsOutput) SetEncryptionType(v EncryptionType) *PutRecordsOutput

+ func (s *PutRecordsOutput) SetFailedRecordCount(v int64) *PutRecordsOutput

+ func (s *PutRecordsOutput) SetRecords(v []PutRecordsResultEntry) *PutRecordsOutput

+ func (s PutRecordsOutput) GoString() string

+ func (s PutRecordsOutput) SDKResponseMetadata() aws.Response

+ func (s PutRecordsOutput) String() string

+ type PutRecordsRequest struct

+ Input *PutRecordsInput

+ func (r PutRecordsRequest) Send() (*PutRecordsOutput, error)

+ 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 EncryptionType

+ PartitionKey *string

+ SequenceNumber *string

+ func (s *Record) SetApproximateArrivalTimestamp(v time.Time) *Record

+ func (s *Record) SetData(v []byte) *Record

+ func (s *Record) SetEncryptionType(v EncryptionType) *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 RemoveTagsFromStreamInput struct

+ StreamName *string

+ TagKeys []string

+ 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) SDKResponseMetadata() aws.Response

+ func (s RemoveTagsFromStreamOutput) String() string

+ type RemoveTagsFromStreamRequest struct

+ Input *RemoveTagsFromStreamInput

+ func (r RemoveTagsFromStreamRequest) Send() (*RemoveTagsFromStreamOutput, error)

+ type ScalingType string

+ const ScalingTypeUniformScaling

+ 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 ShardIteratorType string

+ const ShardIteratorTypeAfterSequenceNumber

+ const ShardIteratorTypeAtSequenceNumber

+ const ShardIteratorTypeAtTimestamp

+ const ShardIteratorTypeLatest

+ const ShardIteratorTypeTrimHorizon

+ type SplitShardInput struct

+ NewStartingHashKey *string

+ ShardToSplit *string

+ StreamName *string

+ func (s *SplitShardInput) SetNewStartingHashKey(v string) *SplitShardInput

+ func (s *SplitShardInput) SetShardToSplit(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) SDKResponseMetadata() aws.Response

+ func (s SplitShardOutput) String() string

+ type SplitShardRequest struct

+ Input *SplitShardInput

+ func (r SplitShardRequest) Send() (*SplitShardOutput, error)

+ type StartStreamEncryptionInput struct

+ EncryptionType EncryptionType

+ KeyId *string

+ StreamName *string

+ func (s *StartStreamEncryptionInput) SetEncryptionType(v EncryptionType) *StartStreamEncryptionInput

+ func (s *StartStreamEncryptionInput) SetKeyId(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) SDKResponseMetadata() aws.Response

+ func (s StartStreamEncryptionOutput) String() string

+ type StartStreamEncryptionRequest struct

+ Input *StartStreamEncryptionInput

+ func (r StartStreamEncryptionRequest) Send() (*StartStreamEncryptionOutput, error)

+ type StopStreamEncryptionInput struct

+ EncryptionType EncryptionType

+ KeyId *string

+ StreamName *string

+ func (s *StopStreamEncryptionInput) SetEncryptionType(v EncryptionType) *StopStreamEncryptionInput

+ func (s *StopStreamEncryptionInput) SetKeyId(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) SDKResponseMetadata() aws.Response

+ func (s StopStreamEncryptionOutput) String() string

+ type StopStreamEncryptionRequest struct

+ Input *StopStreamEncryptionInput

+ func (r StopStreamEncryptionRequest) Send() (*StopStreamEncryptionOutput, error)

+ type StreamDescription struct

+ EncryptionType EncryptionType

+ EnhancedMonitoring []EnhancedMetrics

+ HasMoreShards *bool

+ KeyId *string

+ RetentionPeriodHours *int64

+ Shards []Shard

+ StreamARN *string

+ StreamCreationTimestamp *time.Time

+ StreamName *string

+ StreamStatus StreamStatus

+ func (s *StreamDescription) SetEncryptionType(v EncryptionType) *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) SetStreamName(v string) *StreamDescription

+ func (s *StreamDescription) SetStreamStatus(v StreamStatus) *StreamDescription

+ func (s StreamDescription) GoString() string

+ func (s StreamDescription) String() string

+ type StreamStatus string

+ const StreamStatusActive

+ const StreamStatusCreating

+ const StreamStatusDeleting

+ const StreamStatusUpdating

+ 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 ScalingType

+ StreamName *string

+ TargetShardCount *int64

+ func (s *UpdateShardCountInput) SetScalingType(v ScalingType) *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

+ StreamName *string

+ TargetShardCount *int64

+ func (s *UpdateShardCountOutput) SetCurrentShardCount(v int64) *UpdateShardCountOutput

+ func (s *UpdateShardCountOutput) SetStreamName(v string) *UpdateShardCountOutput

+ func (s *UpdateShardCountOutput) SetTargetShardCount(v int64) *UpdateShardCountOutput

+ func (s UpdateShardCountOutput) GoString() string

+ func (s UpdateShardCountOutput) SDKResponseMetadata() aws.Response

+ func (s UpdateShardCountOutput) String() string

+ type UpdateShardCountRequest struct

+ Input *UpdateShardCountInput

+ func (r UpdateShardCountRequest) Send() (*UpdateShardCountOutput, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL