kinesisstub

package
v0.0.0-...-eb62eed Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 9, 2020 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddTagsToStreamFuture 

type AddTagsToStreamFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*AddTagsToStreamFuture) Get 

func (r *AddTagsToStreamFuture) Get(ctx workflow.Context) (*kinesis.AddTagsToStreamOutput, error)

type Client 

type Client interface {
	AddTagsToStream(ctx workflow.Context, input *kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)
	AddTagsToStreamAsync(ctx workflow.Context, input *kinesis.AddTagsToStreamInput) *AddTagsToStreamFuture

	CreateStream(ctx workflow.Context, input *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)
	CreateStreamAsync(ctx workflow.Context, input *kinesis.CreateStreamInput) *CreateStreamFuture

	DecreaseStreamRetentionPeriod(ctx workflow.Context, input *kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)
	DecreaseStreamRetentionPeriodAsync(ctx workflow.Context, input *kinesis.DecreaseStreamRetentionPeriodInput) *DecreaseStreamRetentionPeriodFuture

	DeleteStream(ctx workflow.Context, input *kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)
	DeleteStreamAsync(ctx workflow.Context, input *kinesis.DeleteStreamInput) *DeleteStreamFuture

	DeregisterStreamConsumer(ctx workflow.Context, input *kinesis.DeregisterStreamConsumerInput) (*kinesis.DeregisterStreamConsumerOutput, error)
	DeregisterStreamConsumerAsync(ctx workflow.Context, input *kinesis.DeregisterStreamConsumerInput) *DeregisterStreamConsumerFuture

	DescribeLimits(ctx workflow.Context, input *kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error)
	DescribeLimitsAsync(ctx workflow.Context, input *kinesis.DescribeLimitsInput) *DescribeLimitsFuture

	DescribeStream(ctx workflow.Context, input *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
	DescribeStreamAsync(ctx workflow.Context, input *kinesis.DescribeStreamInput) *DescribeStreamFuture

	DescribeStreamConsumer(ctx workflow.Context, input *kinesis.DescribeStreamConsumerInput) (*kinesis.DescribeStreamConsumerOutput, error)
	DescribeStreamConsumerAsync(ctx workflow.Context, input *kinesis.DescribeStreamConsumerInput) *DescribeStreamConsumerFuture

	DescribeStreamSummary(ctx workflow.Context, input *kinesis.DescribeStreamSummaryInput) (*kinesis.DescribeStreamSummaryOutput, error)
	DescribeStreamSummaryAsync(ctx workflow.Context, input *kinesis.DescribeStreamSummaryInput) *DescribeStreamSummaryFuture

	DisableEnhancedMonitoring(ctx workflow.Context, input *kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
	DisableEnhancedMonitoringAsync(ctx workflow.Context, input *kinesis.DisableEnhancedMonitoringInput) *DisableEnhancedMonitoringFuture

	EnableEnhancedMonitoring(ctx workflow.Context, input *kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
	EnableEnhancedMonitoringAsync(ctx workflow.Context, input *kinesis.EnableEnhancedMonitoringInput) *EnableEnhancedMonitoringFuture

	GetRecords(ctx workflow.Context, input *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)
	GetRecordsAsync(ctx workflow.Context, input *kinesis.GetRecordsInput) *GetRecordsFuture

	GetShardIterator(ctx workflow.Context, input *kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)
	GetShardIteratorAsync(ctx workflow.Context, input *kinesis.GetShardIteratorInput) *GetShardIteratorFuture

	IncreaseStreamRetentionPeriod(ctx workflow.Context, input *kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)
	IncreaseStreamRetentionPeriodAsync(ctx workflow.Context, input *kinesis.IncreaseStreamRetentionPeriodInput) *IncreaseStreamRetentionPeriodFuture

	ListShards(ctx workflow.Context, input *kinesis.ListShardsInput) (*kinesis.ListShardsOutput, error)
	ListShardsAsync(ctx workflow.Context, input *kinesis.ListShardsInput) *ListShardsFuture

	ListStreamConsumers(ctx workflow.Context, input *kinesis.ListStreamConsumersInput) (*kinesis.ListStreamConsumersOutput, error)
	ListStreamConsumersAsync(ctx workflow.Context, input *kinesis.ListStreamConsumersInput) *ListStreamConsumersFuture

	ListStreams(ctx workflow.Context, input *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)
	ListStreamsAsync(ctx workflow.Context, input *kinesis.ListStreamsInput) *ListStreamsFuture

	ListTagsForStream(ctx workflow.Context, input *kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)
	ListTagsForStreamAsync(ctx workflow.Context, input *kinesis.ListTagsForStreamInput) *ListTagsForStreamFuture

	MergeShards(ctx workflow.Context, input *kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)
	MergeShardsAsync(ctx workflow.Context, input *kinesis.MergeShardsInput) *MergeShardsFuture

	PutRecord(ctx workflow.Context, input *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)
	PutRecordAsync(ctx workflow.Context, input *kinesis.PutRecordInput) *PutRecordFuture

	PutRecords(ctx workflow.Context, input *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)
	PutRecordsAsync(ctx workflow.Context, input *kinesis.PutRecordsInput) *PutRecordsFuture

	RegisterStreamConsumer(ctx workflow.Context, input *kinesis.RegisterStreamConsumerInput) (*kinesis.RegisterStreamConsumerOutput, error)
	RegisterStreamConsumerAsync(ctx workflow.Context, input *kinesis.RegisterStreamConsumerInput) *RegisterStreamConsumerFuture

	RemoveTagsFromStream(ctx workflow.Context, input *kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)
	RemoveTagsFromStreamAsync(ctx workflow.Context, input *kinesis.RemoveTagsFromStreamInput) *RemoveTagsFromStreamFuture

	SplitShard(ctx workflow.Context, input *kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)
	SplitShardAsync(ctx workflow.Context, input *kinesis.SplitShardInput) *SplitShardFuture

	StartStreamEncryption(ctx workflow.Context, input *kinesis.StartStreamEncryptionInput) (*kinesis.StartStreamEncryptionOutput, error)
	StartStreamEncryptionAsync(ctx workflow.Context, input *kinesis.StartStreamEncryptionInput) *StartStreamEncryptionFuture

	StopStreamEncryption(ctx workflow.Context, input *kinesis.StopStreamEncryptionInput) (*kinesis.StopStreamEncryptionOutput, error)
	StopStreamEncryptionAsync(ctx workflow.Context, input *kinesis.StopStreamEncryptionInput) *StopStreamEncryptionFuture

	SubscribeToShard(ctx workflow.Context, input *kinesis.SubscribeToShardInput) (*kinesis.SubscribeToShardOutput, error)
	SubscribeToShardAsync(ctx workflow.Context, input *kinesis.SubscribeToShardInput) *SubscribeToShardFuture

	UpdateShardCount(ctx workflow.Context, input *kinesis.UpdateShardCountInput) (*kinesis.UpdateShardCountOutput, error)
	UpdateShardCountAsync(ctx workflow.Context, input *kinesis.UpdateShardCountInput) *UpdateShardCountFuture

	WaitUntilStreamExists(ctx workflow.Context, input *kinesis.DescribeStreamInput) error
	WaitUntilStreamExistsAsync(ctx workflow.Context, input *kinesis.DescribeStreamInput) *clients.VoidFuture

	WaitUntilStreamNotExists(ctx workflow.Context, input *kinesis.DescribeStreamInput) error
	WaitUntilStreamNotExistsAsync(ctx workflow.Context, input *kinesis.DescribeStreamInput) *clients.VoidFuture
}

func NewClient 

func NewClient() Client

type CreateStreamFuture 

type CreateStreamFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*CreateStreamFuture) Get 

func (r *CreateStreamFuture) Get(ctx workflow.Context) (*kinesis.CreateStreamOutput, error)

type DecreaseStreamRetentionPeriodFuture 

type DecreaseStreamRetentionPeriodFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DecreaseStreamRetentionPeriodFuture) Get 

func (r *DecreaseStreamRetentionPeriodFuture) Get(ctx workflow.Context) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

type DeleteStreamFuture 

type DeleteStreamFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DeleteStreamFuture) Get 

func (r *DeleteStreamFuture) Get(ctx workflow.Context) (*kinesis.DeleteStreamOutput, error)

type DeregisterStreamConsumerFuture 

type DeregisterStreamConsumerFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DeregisterStreamConsumerFuture) Get 

func (r *DeregisterStreamConsumerFuture) Get(ctx workflow.Context) (*kinesis.DeregisterStreamConsumerOutput, error)

type DescribeLimitsFuture 

type DescribeLimitsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeLimitsFuture) Get 

func (r *DescribeLimitsFuture) Get(ctx workflow.Context) (*kinesis.DescribeLimitsOutput, error)

type DescribeStreamConsumerFuture 

type DescribeStreamConsumerFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeStreamConsumerFuture) Get 

func (r *DescribeStreamConsumerFuture) Get(ctx workflow.Context) (*kinesis.DescribeStreamConsumerOutput, error)

type DescribeStreamFuture 

type DescribeStreamFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeStreamFuture) Get 

func (r *DescribeStreamFuture) Get(ctx workflow.Context) (*kinesis.DescribeStreamOutput, error)

type DescribeStreamSummaryFuture 

type DescribeStreamSummaryFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeStreamSummaryFuture) Get 

func (r *DescribeStreamSummaryFuture) Get(ctx workflow.Context) (*kinesis.DescribeStreamSummaryOutput, error)

type DisableEnhancedMonitoringFuture 

type DisableEnhancedMonitoringFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DisableEnhancedMonitoringFuture) Get 

func (r *DisableEnhancedMonitoringFuture) Get(ctx workflow.Context) (*kinesis.EnhancedMonitoringOutput, error)

type EnableEnhancedMonitoringFuture 

type EnableEnhancedMonitoringFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*EnableEnhancedMonitoringFuture) Get 

func (r *EnableEnhancedMonitoringFuture) Get(ctx workflow.Context) (*kinesis.EnhancedMonitoringOutput, error)

type GetRecordsFuture 

type GetRecordsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*GetRecordsFuture) Get 

func (r *GetRecordsFuture) Get(ctx workflow.Context) (*kinesis.GetRecordsOutput, error)

type GetShardIteratorFuture 

type GetShardIteratorFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*GetShardIteratorFuture) Get 

func (r *GetShardIteratorFuture) Get(ctx workflow.Context) (*kinesis.GetShardIteratorOutput, error)

type IncreaseStreamRetentionPeriodFuture 

type IncreaseStreamRetentionPeriodFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*IncreaseStreamRetentionPeriodFuture) Get 

func (r *IncreaseStreamRetentionPeriodFuture) Get(ctx workflow.Context) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

type ListShardsFuture 

type ListShardsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListShardsFuture) Get 

func (r *ListShardsFuture) Get(ctx workflow.Context) (*kinesis.ListShardsOutput, error)

type ListStreamConsumersFuture 

type ListStreamConsumersFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListStreamConsumersFuture) Get 

func (r *ListStreamConsumersFuture) Get(ctx workflow.Context) (*kinesis.ListStreamConsumersOutput, error)

type ListStreamsFuture 

type ListStreamsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListStreamsFuture) Get 

func (r *ListStreamsFuture) Get(ctx workflow.Context) (*kinesis.ListStreamsOutput, error)

type ListTagsForStreamFuture 

type ListTagsForStreamFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListTagsForStreamFuture) Get 

func (r *ListTagsForStreamFuture) Get(ctx workflow.Context) (*kinesis.ListTagsForStreamOutput, error)

type MergeShardsFuture 

type MergeShardsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*MergeShardsFuture) Get 

func (r *MergeShardsFuture) Get(ctx workflow.Context) (*kinesis.MergeShardsOutput, error)

type PutRecordFuture 

type PutRecordFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*PutRecordFuture) Get 

func (r *PutRecordFuture) Get(ctx workflow.Context) (*kinesis.PutRecordOutput, error)

type PutRecordsFuture 

type PutRecordsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*PutRecordsFuture) Get 

func (r *PutRecordsFuture) Get(ctx workflow.Context) (*kinesis.PutRecordsOutput, error)

type RegisterStreamConsumerFuture 

type RegisterStreamConsumerFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*RegisterStreamConsumerFuture) Get 

func (r *RegisterStreamConsumerFuture) Get(ctx workflow.Context) (*kinesis.RegisterStreamConsumerOutput, error)

type RemoveTagsFromStreamFuture 

type RemoveTagsFromStreamFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*RemoveTagsFromStreamFuture) Get 

func (r *RemoveTagsFromStreamFuture) Get(ctx workflow.Context) (*kinesis.RemoveTagsFromStreamOutput, error)

type SplitShardFuture 

type SplitShardFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*SplitShardFuture) Get 

func (r *SplitShardFuture) Get(ctx workflow.Context) (*kinesis.SplitShardOutput, error)

type StartStreamEncryptionFuture 

type StartStreamEncryptionFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*StartStreamEncryptionFuture) Get 

func (r *StartStreamEncryptionFuture) Get(ctx workflow.Context) (*kinesis.StartStreamEncryptionOutput, error)

type StopStreamEncryptionFuture 

type StopStreamEncryptionFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*StopStreamEncryptionFuture) Get 

func (r *StopStreamEncryptionFuture) Get(ctx workflow.Context) (*kinesis.StopStreamEncryptionOutput, error)

type SubscribeToShardFuture 

type SubscribeToShardFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*SubscribeToShardFuture) Get 

func (r *SubscribeToShardFuture) Get(ctx workflow.Context) (*kinesis.SubscribeToShardOutput, error)

type UpdateShardCountFuture 

type UpdateShardCountFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UpdateShardCountFuture) Get 

func (r *UpdateShardCountFuture) Get(ctx workflow.Context) (*kinesis.UpdateShardCountOutput, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.