stream

Documentation

Index

• type Subscriber
  • func NewStreamSubscriber(dynamoSvc *dynamodb.Client, streamSvc *dynamodbstreams.Client, table string) *Subscriber
  • func (r *Subscriber) GetStreamData() (<-chan dynamodbstreams.Record, <-chan error)
  • func (r *Subscriber) GetStreamDataAsync() (<-chan dynamodbstreams.Record, <-chan error)

Types

type Subscriber

type Subscriber struct {
	ShardIteratorType dynamodbstreams.ShardIteratorType
	Limit             *int64
	// contains filtered or unexported fields
}

func NewStreamSubscriber

func NewStreamSubscriber(
	dynamoSvc *dynamodb.Client,
	streamSvc *dynamodbstreams.Client,
	table string,
) *Subscriber

func (*Subscriber) GetStreamData

func (r *Subscriber) GetStreamData() (<-chan dynamodbstreams.Record, <-chan error)

func (*Subscriber) GetStreamDataAsync

func (r *Subscriber) GetStreamDataAsync() (<-chan dynamodbstreams.Record, <-chan error)