kinesis

Apr 26, 2016

Changes in this version

type AddTagsToStreamInput

+ func (s *AddTagsToStreamInput) Validate() error

type CreateStreamInput

+ func (s *CreateStreamInput) Validate() error

type DecreaseStreamRetentionPeriodInput

+ func (s *DecreaseStreamRetentionPeriodInput) Validate() error

type DeleteStreamInput

+ func (s *DeleteStreamInput) Validate() error

type DescribeStreamInput

+ func (s *DescribeStreamInput) Validate() error

type DisableEnhancedMonitoringInput

+ func (s *DisableEnhancedMonitoringInput) Validate() error

type EnableEnhancedMonitoringInput

+ func (s *EnableEnhancedMonitoringInput) Validate() error

type GetRecordsInput

+ func (s *GetRecordsInput) Validate() error

type GetShardIteratorInput

+ func (s *GetShardIteratorInput) Validate() error

type IncreaseStreamRetentionPeriodInput

+ func (s *IncreaseStreamRetentionPeriodInput) Validate() error

type ListStreamsInput

+ func (s *ListStreamsInput) Validate() error

type ListTagsForStreamInput

+ func (s *ListTagsForStreamInput) Validate() error

type MergeShardsInput

+ func (s *MergeShardsInput) Validate() error

type PutRecordInput

+ func (s *PutRecordInput) Validate() error

type PutRecordsInput

+ func (s *PutRecordsInput) Validate() error

type PutRecordsRequestEntry

+ func (s *PutRecordsRequestEntry) Validate() error

type RemoveTagsFromStreamInput

+ func (s *RemoveTagsFromStreamInput) Validate() error

type SplitShardInput

+ func (s *SplitShardInput) Validate() error

Apr 19, 2016

Changes in this version

+ const MetricsNameAll

+ const MetricsNameIncomingBytes

+ const MetricsNameIncomingRecords

+ const MetricsNameIteratorAgeMilliseconds

+ const MetricsNameOutgoingBytes

+ const MetricsNameOutgoingRecords

+ const MetricsNameReadProvisionedThroughputExceeded

+ const MetricsNameWriteProvisionedThroughputExceeded

+ const ShardIteratorTypeAtTimestamp

+ type DisableEnhancedMonitoringInput struct

+ ShardLevelMetrics []*string

+ StreamName *string

+ func (s DisableEnhancedMonitoringInput) GoString() string

+ func (s DisableEnhancedMonitoringInput) String() string

+ type EnableEnhancedMonitoringInput struct

+ ShardLevelMetrics []*string

+ StreamName *string

+ func (s EnableEnhancedMonitoringInput) GoString() string

+ func (s EnableEnhancedMonitoringInput) String() string

+ type EnhancedMetrics struct

+ ShardLevelMetrics []*string

+ func (s EnhancedMetrics) GoString() string

+ func (s EnhancedMetrics) String() string

+ type EnhancedMonitoringOutput struct

+ CurrentShardLevelMetrics []*string

+ DesiredShardLevelMetrics []*string

+ StreamName *string

+ func (s EnhancedMonitoringOutput) GoString() string

+ func (s EnhancedMonitoringOutput) String() string

type GetShardIteratorInput

+ Timestamp *time.Time

type Kinesis

+ func (c *Kinesis) DisableEnhancedMonitoring(input *DisableEnhancedMonitoringInput) (*EnhancedMonitoringOutput, error)

+ func (c *Kinesis) DisableEnhancedMonitoringRequest(input *DisableEnhancedMonitoringInput) (req *request.Request, output *EnhancedMonitoringOutput)

+ func (c *Kinesis) EnableEnhancedMonitoring(input *EnableEnhancedMonitoringInput) (*EnhancedMonitoringOutput, error)

+ func (c *Kinesis) EnableEnhancedMonitoringRequest(input *EnableEnhancedMonitoringInput) (req *request.Request, output *EnhancedMonitoringOutput)

type StreamDescription

+ EnhancedMonitoring []*EnhancedMetrics

Nov 10, 2015

Changes in this version

type Kinesis

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

Oct 29, 2015

Changes in this version

+ const ServiceName

Oct 7, 2015

Changes in this version

+ type DecreaseStreamRetentionPeriodInput struct

+ RetentionPeriodHours *int64

+ StreamName *string

+ func (s DecreaseStreamRetentionPeriodInput) GoString() string

+ func (s DecreaseStreamRetentionPeriodInput) String() string

+ type DecreaseStreamRetentionPeriodOutput struct

+ func (s DecreaseStreamRetentionPeriodOutput) GoString() string

+ func (s DecreaseStreamRetentionPeriodOutput) String() string

+ type IncreaseStreamRetentionPeriodInput struct

+ RetentionPeriodHours *int64

+ StreamName *string

+ func (s IncreaseStreamRetentionPeriodInput) GoString() string

+ func (s IncreaseStreamRetentionPeriodInput) String() string

+ type IncreaseStreamRetentionPeriodOutput struct

+ func (s IncreaseStreamRetentionPeriodOutput) GoString() string

+ func (s IncreaseStreamRetentionPeriodOutput) String() string

type Kinesis

+ func (c *Kinesis) DecreaseStreamRetentionPeriod(input *DecreaseStreamRetentionPeriodInput) (*DecreaseStreamRetentionPeriodOutput, error)

+ func (c *Kinesis) DecreaseStreamRetentionPeriodRequest(input *DecreaseStreamRetentionPeriodInput) (req *request.Request, output *DecreaseStreamRetentionPeriodOutput)

+ func (c *Kinesis) IncreaseStreamRetentionPeriod(input *IncreaseStreamRetentionPeriodInput) (*IncreaseStreamRetentionPeriodOutput, error)

+ func (c *Kinesis) IncreaseStreamRetentionPeriodRequest(input *IncreaseStreamRetentionPeriodInput) (req *request.Request, output *IncreaseStreamRetentionPeriodOutput)

type StreamDescription

+ RetentionPeriodHours *int64

Sep 10, 2015

Changes in this version

type Record

+ ApproximateArrivalTimestamp *time.Time

Sep 3, 2015

Changes in this version

type DescribeStreamInput

+ ExclusiveStartShardId *string

type GetShardIteratorInput

+ ShardId *string

type PutRecordOutput

+ ShardId *string

type PutRecordsResultEntry

+ ShardId *string

type Shard

+ AdjacentParentShardId *string

+ ParentShardId *string

+ ShardId *string

Jul 28, 2015

Changes in this version

+ const ShardIteratorTypeAfterSequenceNumber

+ const ShardIteratorTypeAtSequenceNumber

+ const ShardIteratorTypeLatest

+ const ShardIteratorTypeTrimHorizon

+ const StreamStatusActive

+ const StreamStatusCreating

+ const StreamStatusDeleting

+ const StreamStatusUpdating

Jul 7, 2015

Changes in this version

type AddTagsToStreamInput

+ func (s AddTagsToStreamInput) GoString() string

+ func (s AddTagsToStreamInput) String() string

type AddTagsToStreamOutput

+ func (s AddTagsToStreamOutput) GoString() string

+ func (s AddTagsToStreamOutput) String() string

type CreateStreamInput

+ func (s CreateStreamInput) GoString() string

+ func (s CreateStreamInput) String() string

type CreateStreamOutput

+ func (s CreateStreamOutput) GoString() string

+ func (s CreateStreamOutput) String() string

type DeleteStreamInput

+ func (s DeleteStreamInput) GoString() string

+ func (s DeleteStreamInput) String() string

type DeleteStreamOutput

+ func (s DeleteStreamOutput) GoString() string

+ func (s DeleteStreamOutput) String() string

type DescribeStreamInput

+ func (s DescribeStreamInput) GoString() string

+ func (s DescribeStreamInput) String() string

type DescribeStreamOutput

+ func (s DescribeStreamOutput) GoString() string

+ func (s DescribeStreamOutput) String() string

type GetRecordsInput

+ func (s GetRecordsInput) GoString() string

+ func (s GetRecordsInput) String() string

type GetRecordsOutput

+ func (s GetRecordsOutput) GoString() string

+ func (s GetRecordsOutput) String() string

type GetShardIteratorInput

+ func (s GetShardIteratorInput) GoString() string

+ func (s GetShardIteratorInput) String() string

type GetShardIteratorOutput

+ func (s GetShardIteratorOutput) GoString() string

+ func (s GetShardIteratorOutput) String() string

type HashKeyRange

+ func (s HashKeyRange) GoString() string

+ func (s HashKeyRange) String() string

type ListStreamsInput

+ func (s ListStreamsInput) GoString() string

+ func (s ListStreamsInput) String() string

type ListStreamsOutput

+ func (s ListStreamsOutput) GoString() string

+ func (s ListStreamsOutput) String() string

type ListTagsForStreamInput

+ func (s ListTagsForStreamInput) GoString() string

+ func (s ListTagsForStreamInput) String() string

type ListTagsForStreamOutput

+ func (s ListTagsForStreamOutput) GoString() string

+ func (s ListTagsForStreamOutput) String() string

type MergeShardsInput

+ func (s MergeShardsInput) GoString() string

+ func (s MergeShardsInput) String() string

type MergeShardsOutput

+ func (s MergeShardsOutput) GoString() string

+ func (s MergeShardsOutput) String() string

type PutRecordInput

+ func (s PutRecordInput) GoString() string

+ func (s PutRecordInput) String() string

type PutRecordOutput

+ func (s PutRecordOutput) GoString() string

+ func (s PutRecordOutput) String() string

type PutRecordsInput

+ func (s PutRecordsInput) GoString() string

+ func (s PutRecordsInput) String() string

type PutRecordsOutput

+ func (s PutRecordsOutput) GoString() string

+ func (s PutRecordsOutput) String() string

type PutRecordsRequestEntry

+ func (s PutRecordsRequestEntry) GoString() string

+ func (s PutRecordsRequestEntry) String() string

type PutRecordsResultEntry

+ func (s PutRecordsResultEntry) GoString() string

+ func (s PutRecordsResultEntry) String() string

type Record

+ func (s Record) GoString() string

+ func (s Record) String() string

type RemoveTagsFromStreamInput

+ func (s RemoveTagsFromStreamInput) GoString() string

+ func (s RemoveTagsFromStreamInput) String() string

type RemoveTagsFromStreamOutput

+ func (s RemoveTagsFromStreamOutput) GoString() string

+ func (s RemoveTagsFromStreamOutput) String() string

type SequenceNumberRange

+ func (s SequenceNumberRange) GoString() string

+ func (s SequenceNumberRange) String() string

type Shard

+ func (s Shard) GoString() string

+ func (s Shard) String() string

type SplitShardInput

+ func (s SplitShardInput) GoString() string

+ func (s SplitShardInput) String() string

type SplitShardOutput

+ func (s SplitShardOutput) GoString() string

+ func (s SplitShardOutput) String() string

type StreamDescription

+ func (s StreamDescription) GoString() string

+ func (s StreamDescription) String() string

type Tag

+ func (s Tag) GoString() string

+ func (s Tag) String() string

Jun 3, 2015

Changes in this version

+ type AddTagsToStreamInput struct

+ StreamName *string

+ Tags map[string]*string

+ type AddTagsToStreamOutput struct

+ type CreateStreamInput struct

+ ShardCount *int64

+ StreamName *string

+ type CreateStreamOutput struct

+ type DeleteStreamInput struct

+ StreamName *string

+ type DeleteStreamOutput struct

+ type DescribeStreamInput struct

+ ExclusiveStartShardID *string

+ Limit *int64

+ StreamName *string

+ type DescribeStreamOutput struct

+ StreamDescription *StreamDescription

+ type GetRecordsInput struct

+ Limit *int64

+ ShardIterator *string

+ type GetRecordsOutput struct

+ MillisBehindLatest *int64

+ NextShardIterator *string

+ Records []*Record

+ type GetShardIteratorInput struct

+ ShardID *string

+ ShardIteratorType *string

+ StartingSequenceNumber *string

+ StreamName *string

+ type GetShardIteratorOutput struct

+ ShardIterator *string

+ type HashKeyRange struct

+ EndingHashKey *string

+ StartingHashKey *string

+ type Kinesis struct

+ func New(config *aws.Config) *Kinesis

+ func (c *Kinesis) AddTagsToStream(input *AddTagsToStreamInput) (*AddTagsToStreamOutput, error)

+ func (c *Kinesis) AddTagsToStreamRequest(input *AddTagsToStreamInput) (req *aws.Request, output *AddTagsToStreamOutput)

+ func (c *Kinesis) CreateStream(input *CreateStreamInput) (*CreateStreamOutput, error)

+ func (c *Kinesis) CreateStreamRequest(input *CreateStreamInput) (req *aws.Request, output *CreateStreamOutput)

+ func (c *Kinesis) DeleteStream(input *DeleteStreamInput) (*DeleteStreamOutput, error)

+ func (c *Kinesis) DeleteStreamRequest(input *DeleteStreamInput) (req *aws.Request, output *DeleteStreamOutput)

+ func (c *Kinesis) DescribeStream(input *DescribeStreamInput) (*DescribeStreamOutput, error)

+ func (c *Kinesis) DescribeStreamPages(input *DescribeStreamInput, ...) error

+ func (c *Kinesis) DescribeStreamRequest(input *DescribeStreamInput) (req *aws.Request, output *DescribeStreamOutput)

+ func (c *Kinesis) GetRecords(input *GetRecordsInput) (*GetRecordsOutput, error)

+ func (c *Kinesis) GetRecordsRequest(input *GetRecordsInput) (req *aws.Request, output *GetRecordsOutput)

+ func (c *Kinesis) GetShardIterator(input *GetShardIteratorInput) (*GetShardIteratorOutput, error)

+ func (c *Kinesis) GetShardIteratorRequest(input *GetShardIteratorInput) (req *aws.Request, output *GetShardIteratorOutput)

+ func (c *Kinesis) ListStreams(input *ListStreamsInput) (*ListStreamsOutput, error)

+ func (c *Kinesis) ListStreamsPages(input *ListStreamsInput, ...) error

+ func (c *Kinesis) ListStreamsRequest(input *ListStreamsInput) (req *aws.Request, output *ListStreamsOutput)

+ func (c *Kinesis) ListTagsForStream(input *ListTagsForStreamInput) (*ListTagsForStreamOutput, error)

+ func (c *Kinesis) ListTagsForStreamRequest(input *ListTagsForStreamInput) (req *aws.Request, output *ListTagsForStreamOutput)

+ func (c *Kinesis) MergeShards(input *MergeShardsInput) (*MergeShardsOutput, error)

+ func (c *Kinesis) MergeShardsRequest(input *MergeShardsInput) (req *aws.Request, output *MergeShardsOutput)

+ func (c *Kinesis) PutRecord(input *PutRecordInput) (*PutRecordOutput, error)

+ func (c *Kinesis) PutRecordRequest(input *PutRecordInput) (req *aws.Request, output *PutRecordOutput)

+ func (c *Kinesis) PutRecords(input *PutRecordsInput) (*PutRecordsOutput, error)

+ func (c *Kinesis) PutRecordsRequest(input *PutRecordsInput) (req *aws.Request, output *PutRecordsOutput)

+ func (c *Kinesis) RemoveTagsFromStream(input *RemoveTagsFromStreamInput) (*RemoveTagsFromStreamOutput, error)

+ func (c *Kinesis) RemoveTagsFromStreamRequest(input *RemoveTagsFromStreamInput) (req *aws.Request, output *RemoveTagsFromStreamOutput)

+ func (c *Kinesis) SplitShard(input *SplitShardInput) (*SplitShardOutput, error)

+ func (c *Kinesis) SplitShardRequest(input *SplitShardInput) (req *aws.Request, output *SplitShardOutput)

+ type ListStreamsInput struct

+ ExclusiveStartStreamName *string

+ Limit *int64

+ type ListStreamsOutput struct

+ HasMoreStreams *bool

+ StreamNames []*string

+ type ListTagsForStreamInput struct

+ ExclusiveStartTagKey *string

+ Limit *int64

+ StreamName *string

+ type ListTagsForStreamOutput struct

+ HasMoreTags *bool

+ Tags []*Tag

+ type MergeShardsInput struct

+ AdjacentShardToMerge *string

+ ShardToMerge *string

+ StreamName *string

+ type MergeShardsOutput struct

+ type PutRecordInput struct

+ Data []byte

+ ExplicitHashKey *string

+ PartitionKey *string

+ SequenceNumberForOrdering *string

+ StreamName *string

+ type PutRecordOutput struct

+ SequenceNumber *string

+ ShardID *string

+ type PutRecordsInput struct

+ Records []*PutRecordsRequestEntry

+ StreamName *string

+ type PutRecordsOutput struct

+ FailedRecordCount *int64

+ Records []*PutRecordsResultEntry

+ type PutRecordsRequestEntry struct

+ Data []byte

+ ExplicitHashKey *string

+ PartitionKey *string

+ type PutRecordsResultEntry struct

+ ErrorCode *string

+ ErrorMessage *string

+ SequenceNumber *string

+ ShardID *string

+ type Record struct

+ Data []byte

+ PartitionKey *string

+ SequenceNumber *string

+ type RemoveTagsFromStreamInput struct

+ StreamName *string

+ TagKeys []*string

+ type RemoveTagsFromStreamOutput struct

+ type SequenceNumberRange struct

+ EndingSequenceNumber *string

+ StartingSequenceNumber *string

+ type Shard struct

+ AdjacentParentShardID *string

+ HashKeyRange *HashKeyRange

+ ParentShardID *string

+ SequenceNumberRange *SequenceNumberRange

+ ShardID *string

+ type SplitShardInput struct

+ NewStartingHashKey *string

+ ShardToSplit *string

+ StreamName *string

+ type SplitShardOutput struct

+ type StreamDescription struct

+ HasMoreShards *bool

+ Shards []*Shard

+ StreamARN *string

+ StreamName *string

+ StreamStatus *string

+ type Tag struct

+ Key *string

+ Value *string