kinesis

package

Go to main page

Versions in this module

v1

v1.0.6

Dec 17, 2015

v1.0.5

Dec 15, 2015

v1.0.4

Dec 8, 2015

v1.0.3

Dec 4, 2015

v1.0.2

Nov 24, 2015

v1.0.0

Nov 19, 2015

v0

v0.10.4

Nov 12, 2015

v0.10.3

Nov 10, 2015

Changes in this version

type Kinesis

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

v0.10.2

Nov 3, 2015

v0.10.1

Nov 2, 2015

v0.10.0

Oct 29, 2015

Changes in this version

+ const ServiceName

v0.9.17

Oct 26, 2015

v0.9.16

Oct 22, 2015

v0.9.15

Oct 15, 2015

v0.9.14

Oct 8, 2015

v0.9.13

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

v0.9.12

Oct 6, 2015

v0.9.11

Oct 1, 2015

v0.9.10

Sep 29, 2015

v0.9.9

Sep 17, 2015

v0.9.8

Sep 16, 2015

v0.9.7

Sep 15, 2015

v0.9.6

Sep 10, 2015

Changes in this version

type Record

+ ApproximateArrivalTimestamp *time.Time

v0.9.5

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

v0.7.4

Aug 12, 2015

v0.7.3

Aug 6, 2015

v0.7.2

Aug 4, 2015

v0.7.1

Jul 30, 2015

v0.7.0

Jul 28, 2015

Changes in this version

+ const ShardIteratorTypeAfterSequenceNumber

+ const ShardIteratorTypeAtSequenceNumber

+ const ShardIteratorTypeLatest

+ const ShardIteratorTypeTrimHorizon

+ const StreamStatusActive

+ const StreamStatusCreating

+ const StreamStatusDeleting

+ const StreamStatusUpdating

v0.6.8

Jul 23, 2015

v0.6.7

Jul 14, 2015

v0.6.6

Jul 9, 2015

v0.6.5

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

v0.6.4

Jun 24, 2015

v0.6.3

Jun 18, 2015

v0.6.2

Jun 11, 2015

v0.6.1

Jun 4, 2015

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

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