Documentation ¶
Index ¶
- type Checkpointer
- func (m *Checkpointer) Begin() error
- func (m *Checkpointer) DoneC() chan<- k.Record
- func (m *Checkpointer) End()
- func (m *Checkpointer) GetStartSequence(shardID string) string
- func (m *Checkpointer) Release(shardID string) error
- func (m *Checkpointer) Sync()
- func (m *Checkpointer) TryAcquire(shardID string) error
- type Kinesis
- func (m *Kinesis) AddTagsToStream(_a0 *kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)
- func (m *Kinesis) AddTagsToStreamRequest(_a0 *kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)
- func (m *Kinesis) CreateStream(_a0 *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)
- func (m *Kinesis) CreateStreamRequest(_a0 *kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)
- func (m *Kinesis) DecreaseStreamRetentionPeriod(_a0 *kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)
- func (m *Kinesis) DecreaseStreamRetentionPeriodRequest(_a0 *kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput)
- func (m *Kinesis) DeleteStream(_a0 *kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)
- func (m *Kinesis) DeleteStreamRequest(_a0 *kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)
- func (m *Kinesis) DescribeStream(_a0 *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
- func (m *Kinesis) DescribeStreamPages(_a0 *kinesis.DescribeStreamInput, ...) error
- func (m *Kinesis) DescribeStreamRequest(_a0 *kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)
- func (m *Kinesis) DisableEnhancedMonitoring(_a0 *kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
- func (m *Kinesis) DisableEnhancedMonitoringRequest(_a0 *kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)
- func (m *Kinesis) EnableEnhancedMonitoring(_a0 *kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
- func (m *Kinesis) EnableEnhancedMonitoringRequest(_a0 *kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)
- func (m *Kinesis) GetRecords(_a0 *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)
- func (m *Kinesis) GetRecordsRequest(_a0 *kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)
- func (m *Kinesis) GetShardIterator(_a0 *kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)
- func (m *Kinesis) GetShardIteratorRequest(_a0 *kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)
- func (m *Kinesis) IncreaseStreamRetentionPeriod(_a0 *kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)
- func (m *Kinesis) IncreaseStreamRetentionPeriodRequest(_a0 *kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput)
- func (m *Kinesis) ListStreams(_a0 *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)
- func (m *Kinesis) ListStreamsPages(_a0 *kinesis.ListStreamsInput, _a1 func(*kinesis.ListStreamsOutput, bool) bool) error
- func (m *Kinesis) ListStreamsRequest(_a0 *kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)
- func (m *Kinesis) ListTagsForStream(_a0 *kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)
- func (m *Kinesis) ListTagsForStreamRequest(_a0 *kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)
- func (m *Kinesis) MergeShards(_a0 *kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)
- func (m *Kinesis) MergeShardsRequest(_a0 *kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)
- func (m *Kinesis) PutRecord(_a0 *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)
- func (m *Kinesis) PutRecordRequest(_a0 *kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)
- func (m *Kinesis) PutRecords(_a0 *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)
- func (m *Kinesis) PutRecordsRequest(_a0 *kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)
- func (m *Kinesis) RemoveTagsFromStream(_a0 *kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)
- func (m *Kinesis) RemoveTagsFromStreamRequest(_a0 *kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)
- func (m *Kinesis) SplitShard(_a0 *kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)
- func (m *Kinesis) SplitShardRequest(_a0 *kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)
- type Kinesumer
- type Provisioner
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Checkpointer ¶
func (*Checkpointer) Begin ¶
func (m *Checkpointer) Begin() error
func (*Checkpointer) DoneC ¶
func (m *Checkpointer) DoneC() chan<- k.Record
func (*Checkpointer) End ¶
func (m *Checkpointer) End()
func (*Checkpointer) GetStartSequence ¶
func (m *Checkpointer) GetStartSequence(shardID string) string
func (*Checkpointer) Release ¶
func (m *Checkpointer) Release(shardID string) error
func (*Checkpointer) Sync ¶
func (m *Checkpointer) Sync()
func (*Checkpointer) TryAcquire ¶
func (m *Checkpointer) TryAcquire(shardID string) error
type Kinesis ¶
func (*Kinesis) AddTagsToStream ¶
func (m *Kinesis) AddTagsToStream(_a0 *kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)
func (*Kinesis) AddTagsToStreamRequest ¶
func (m *Kinesis) AddTagsToStreamRequest(_a0 *kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)
func (*Kinesis) CreateStream ¶
func (m *Kinesis) CreateStream(_a0 *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)
func (*Kinesis) CreateStreamRequest ¶
func (m *Kinesis) CreateStreamRequest(_a0 *kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)
func (*Kinesis) DecreaseStreamRetentionPeriod ¶
func (m *Kinesis) DecreaseStreamRetentionPeriod(_a0 *kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)
func (*Kinesis) DecreaseStreamRetentionPeriodRequest ¶
func (m *Kinesis) DecreaseStreamRetentionPeriodRequest(_a0 *kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput)
func (*Kinesis) DeleteStream ¶
func (m *Kinesis) DeleteStream(_a0 *kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)
func (*Kinesis) DeleteStreamRequest ¶
func (m *Kinesis) DeleteStreamRequest(_a0 *kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)
func (*Kinesis) DescribeStream ¶
func (m *Kinesis) DescribeStream(_a0 *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
func (*Kinesis) DescribeStreamPages ¶
func (m *Kinesis) DescribeStreamPages(_a0 *kinesis.DescribeStreamInput, _a1 func(*kinesis.DescribeStreamOutput, bool) bool) error
func (*Kinesis) DescribeStreamRequest ¶
func (m *Kinesis) DescribeStreamRequest(_a0 *kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)
func (*Kinesis) DisableEnhancedMonitoring ¶
func (m *Kinesis) DisableEnhancedMonitoring(_a0 *kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
func (*Kinesis) DisableEnhancedMonitoringRequest ¶
func (m *Kinesis) DisableEnhancedMonitoringRequest(_a0 *kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)
func (*Kinesis) EnableEnhancedMonitoring ¶
func (m *Kinesis) EnableEnhancedMonitoring(_a0 *kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
func (*Kinesis) EnableEnhancedMonitoringRequest ¶
func (m *Kinesis) EnableEnhancedMonitoringRequest(_a0 *kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)
func (*Kinesis) GetRecords ¶
func (m *Kinesis) GetRecords(_a0 *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)
func (*Kinesis) GetRecordsRequest ¶
func (m *Kinesis) GetRecordsRequest(_a0 *kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)
func (*Kinesis) GetShardIterator ¶
func (m *Kinesis) GetShardIterator(_a0 *kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)
func (*Kinesis) GetShardIteratorRequest ¶
func (m *Kinesis) GetShardIteratorRequest(_a0 *kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)
func (*Kinesis) IncreaseStreamRetentionPeriod ¶
func (m *Kinesis) IncreaseStreamRetentionPeriod(_a0 *kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)
func (*Kinesis) IncreaseStreamRetentionPeriodRequest ¶
func (m *Kinesis) IncreaseStreamRetentionPeriodRequest(_a0 *kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput)
func (*Kinesis) ListStreams ¶
func (m *Kinesis) ListStreams(_a0 *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)
func (*Kinesis) ListStreamsPages ¶
func (m *Kinesis) ListStreamsPages(_a0 *kinesis.ListStreamsInput, _a1 func(*kinesis.ListStreamsOutput, bool) bool) error
func (*Kinesis) ListStreamsRequest ¶
func (m *Kinesis) ListStreamsRequest(_a0 *kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)
func (*Kinesis) ListTagsForStream ¶
func (m *Kinesis) ListTagsForStream(_a0 *kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)
func (*Kinesis) ListTagsForStreamRequest ¶
func (m *Kinesis) ListTagsForStreamRequest(_a0 *kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)
func (*Kinesis) MergeShards ¶
func (m *Kinesis) MergeShards(_a0 *kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)
func (*Kinesis) MergeShardsRequest ¶
func (m *Kinesis) MergeShardsRequest(_a0 *kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)
func (*Kinesis) PutRecord ¶
func (m *Kinesis) PutRecord(_a0 *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)
func (*Kinesis) PutRecordRequest ¶
func (m *Kinesis) PutRecordRequest(_a0 *kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)
func (*Kinesis) PutRecords ¶
func (m *Kinesis) PutRecords(_a0 *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)
func (*Kinesis) PutRecordsRequest ¶
func (m *Kinesis) PutRecordsRequest(_a0 *kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)
func (*Kinesis) RemoveTagsFromStream ¶
func (m *Kinesis) RemoveTagsFromStream(_a0 *kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)
func (*Kinesis) RemoveTagsFromStreamRequest ¶
func (m *Kinesis) RemoveTagsFromStreamRequest(_a0 *kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)
func (*Kinesis) SplitShard ¶
func (m *Kinesis) SplitShard(_a0 *kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)
func (*Kinesis) SplitShardRequest ¶
func (m *Kinesis) SplitShardRequest(_a0 *kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)
type Provisioner ¶
func (*Provisioner) Heartbeat ¶
func (m *Provisioner) Heartbeat(shardID string) error
func (*Provisioner) Release ¶
func (m *Provisioner) Release(shardID string) error
func (*Provisioner) TTL ¶
func (m *Provisioner) TTL() time.Duration
func (*Provisioner) TryAcquire ¶
func (m *Provisioner) TryAcquire(shardID string) error
Click to show internal directories.
Click to hide internal directories.