subscriber

Documentation

Index

• type StreamSubscriber
  • func NewStreamSubscriber(dynamoSvc *dynamodb.Client, streamSvc *dynamodbstreams.Client, table string) *StreamSubscriber
  • func (r *StreamSubscriber) GetStreamData() (<-chan *types.Record, <-chan error)
  • func (r *StreamSubscriber) GetStreamDataAsync() (<-chan *types.Record, <-chan error)
  • func (r *StreamSubscriber) SetLimit(v int32)
  • func (r *StreamSubscriber) SetShardIteratorType(s types.ShardIteratorType)

Types

type StreamSubscriber

type StreamSubscriber struct {
	ShardIteratorType types.ShardIteratorType
	Limit             *int32
	// contains filtered or unexported fields
}

func NewStreamSubscriber

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

func (*StreamSubscriber) GetStreamData

func (r *StreamSubscriber) GetStreamData() (<-chan *types.Record, <-chan error)

func (*StreamSubscriber) GetStreamDataAsync

func (r *StreamSubscriber) GetStreamDataAsync() (<-chan *types.Record, <-chan error)

func (*StreamSubscriber) SetLimit

func (r *StreamSubscriber) SetLimit(v int32)

func (*StreamSubscriber) SetShardIteratorType

func (r *StreamSubscriber) SetShardIteratorType(s types.ShardIteratorType)