dynamodbstreamsstub

Documentation

Index

• type Client
  • func NewClient() Client
• type DescribeStreamFuture
  • func (r *DescribeStreamFuture) Get(ctx workflow.Context) (*dynamodbstreams.DescribeStreamOutput, error)
• type GetRecordsFuture
  • func (r *GetRecordsFuture) Get(ctx workflow.Context) (*dynamodbstreams.GetRecordsOutput, error)
• type GetShardIteratorFuture
  • func (r *GetShardIteratorFuture) Get(ctx workflow.Context) (*dynamodbstreams.GetShardIteratorOutput, error)
• type ListStreamsFuture
  • func (r *ListStreamsFuture) Get(ctx workflow.Context) (*dynamodbstreams.ListStreamsOutput, error)

Types

type Client

type Client interface {
	DescribeStream(ctx workflow.Context, input *dynamodbstreams.DescribeStreamInput) (*dynamodbstreams.DescribeStreamOutput, error)
	DescribeStreamAsync(ctx workflow.Context, input *dynamodbstreams.DescribeStreamInput) *DescribeStreamFuture

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

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

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

func NewClient

func NewClient() Client

type DescribeStreamFuture

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

func (*DescribeStreamFuture) Get

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

type GetRecordsFuture

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

func (*GetRecordsFuture) Get

func (r *GetRecordsFuture) Get(ctx workflow.Context) (*dynamodbstreams.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) (*dynamodbstreams.GetShardIteratorOutput, error)

type ListStreamsFuture

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

func (*ListStreamsFuture) Get

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