firehosestub

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Nov 30, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client interface {
	CreateDeliveryStream(ctx workflow.Context, input *firehose.CreateDeliveryStreamInput) (*firehose.CreateDeliveryStreamOutput, error)
	CreateDeliveryStreamAsync(ctx workflow.Context, input *firehose.CreateDeliveryStreamInput) *CreateDeliveryStreamFuture

	DeleteDeliveryStream(ctx workflow.Context, input *firehose.DeleteDeliveryStreamInput) (*firehose.DeleteDeliveryStreamOutput, error)
	DeleteDeliveryStreamAsync(ctx workflow.Context, input *firehose.DeleteDeliveryStreamInput) *DeleteDeliveryStreamFuture

	DescribeDeliveryStream(ctx workflow.Context, input *firehose.DescribeDeliveryStreamInput) (*firehose.DescribeDeliveryStreamOutput, error)
	DescribeDeliveryStreamAsync(ctx workflow.Context, input *firehose.DescribeDeliveryStreamInput) *DescribeDeliveryStreamFuture

	ListDeliveryStreams(ctx workflow.Context, input *firehose.ListDeliveryStreamsInput) (*firehose.ListDeliveryStreamsOutput, error)
	ListDeliveryStreamsAsync(ctx workflow.Context, input *firehose.ListDeliveryStreamsInput) *ListDeliveryStreamsFuture

	ListTagsForDeliveryStream(ctx workflow.Context, input *firehose.ListTagsForDeliveryStreamInput) (*firehose.ListTagsForDeliveryStreamOutput, error)
	ListTagsForDeliveryStreamAsync(ctx workflow.Context, input *firehose.ListTagsForDeliveryStreamInput) *ListTagsForDeliveryStreamFuture

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

	PutRecordBatch(ctx workflow.Context, input *firehose.PutRecordBatchInput) (*firehose.PutRecordBatchOutput, error)
	PutRecordBatchAsync(ctx workflow.Context, input *firehose.PutRecordBatchInput) *PutRecordBatchFuture

	StartDeliveryStreamEncryption(ctx workflow.Context, input *firehose.StartDeliveryStreamEncryptionInput) (*firehose.StartDeliveryStreamEncryptionOutput, error)
	StartDeliveryStreamEncryptionAsync(ctx workflow.Context, input *firehose.StartDeliveryStreamEncryptionInput) *StartDeliveryStreamEncryptionFuture

	StopDeliveryStreamEncryption(ctx workflow.Context, input *firehose.StopDeliveryStreamEncryptionInput) (*firehose.StopDeliveryStreamEncryptionOutput, error)
	StopDeliveryStreamEncryptionAsync(ctx workflow.Context, input *firehose.StopDeliveryStreamEncryptionInput) *StopDeliveryStreamEncryptionFuture

	TagDeliveryStream(ctx workflow.Context, input *firehose.TagDeliveryStreamInput) (*firehose.TagDeliveryStreamOutput, error)
	TagDeliveryStreamAsync(ctx workflow.Context, input *firehose.TagDeliveryStreamInput) *TagDeliveryStreamFuture

	UntagDeliveryStream(ctx workflow.Context, input *firehose.UntagDeliveryStreamInput) (*firehose.UntagDeliveryStreamOutput, error)
	UntagDeliveryStreamAsync(ctx workflow.Context, input *firehose.UntagDeliveryStreamInput) *UntagDeliveryStreamFuture

	UpdateDestination(ctx workflow.Context, input *firehose.UpdateDestinationInput) (*firehose.UpdateDestinationOutput, error)
	UpdateDestinationAsync(ctx workflow.Context, input *firehose.UpdateDestinationInput) *UpdateDestinationFuture
}

func NewClient 

func NewClient() Client

type CreateDeliveryStreamFuture 

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

func (*CreateDeliveryStreamFuture) Get 

func (r *CreateDeliveryStreamFuture) Get(ctx workflow.Context) (*firehose.CreateDeliveryStreamOutput, error)

type DeleteDeliveryStreamFuture 

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

func (*DeleteDeliveryStreamFuture) Get 

func (r *DeleteDeliveryStreamFuture) Get(ctx workflow.Context) (*firehose.DeleteDeliveryStreamOutput, error)

type DescribeDeliveryStreamFuture 

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

func (*DescribeDeliveryStreamFuture) Get 

func (r *DescribeDeliveryStreamFuture) Get(ctx workflow.Context) (*firehose.DescribeDeliveryStreamOutput, error)

type ListDeliveryStreamsFuture 

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

func (*ListDeliveryStreamsFuture) Get 

func (r *ListDeliveryStreamsFuture) Get(ctx workflow.Context) (*firehose.ListDeliveryStreamsOutput, error)

type ListTagsForDeliveryStreamFuture 

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

func (*ListTagsForDeliveryStreamFuture) Get 

func (r *ListTagsForDeliveryStreamFuture) Get(ctx workflow.Context) (*firehose.ListTagsForDeliveryStreamOutput, error)

type PutRecordBatchFuture 

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

func (*PutRecordBatchFuture) Get 

func (r *PutRecordBatchFuture) Get(ctx workflow.Context) (*firehose.PutRecordBatchOutput, error)

type PutRecordFuture 

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

func (*PutRecordFuture) Get 

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

type StartDeliveryStreamEncryptionFuture 

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

func (*StartDeliveryStreamEncryptionFuture) Get 

func (r *StartDeliveryStreamEncryptionFuture) Get(ctx workflow.Context) (*firehose.StartDeliveryStreamEncryptionOutput, error)

type StopDeliveryStreamEncryptionFuture 

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

func (*StopDeliveryStreamEncryptionFuture) Get 

func (r *StopDeliveryStreamEncryptionFuture) Get(ctx workflow.Context) (*firehose.StopDeliveryStreamEncryptionOutput, error)

type TagDeliveryStreamFuture 

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

func (*TagDeliveryStreamFuture) Get 

func (r *TagDeliveryStreamFuture) Get(ctx workflow.Context) (*firehose.TagDeliveryStreamOutput, error)

type UntagDeliveryStreamFuture 

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

func (*UntagDeliveryStreamFuture) Get 

func (r *UntagDeliveryStreamFuture) Get(ctx workflow.Context) (*firehose.UntagDeliveryStreamOutput, error)

type UpdateDestinationFuture 

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

func (*UpdateDestinationFuture) Get 

func (r *UpdateDestinationFuture) Get(ctx workflow.Context) (*firehose.UpdateDestinationOutput, 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.