Versions in this module Expand all Collapse all v0 v0.6.0 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
Go to main page