stream

Documentation

Overview

Yury Kozyrev (urakozz) MIT License

Index

• type StreamSubscriber
  • func NewStreamSubscriber(dynamoSvc dynamodbiface.DynamoDBAPI, ...) *StreamSubscriber
  • func (r *StreamSubscriber) GetStreamData() (<-chan *dynamodbstreams.Record, <-chan error)
  • func (r *StreamSubscriber) GetStreamDataAsync() (<-chan *dynamodbstreams.Record, <-chan error)
  • func (r *StreamSubscriber) SetKeepOrder(b bool)
  • func (r *StreamSubscriber) SetLimit(v int64)
  • func (r *StreamSubscriber) SetShardIteratorType(s string)

Types

type StreamSubscriber

type StreamSubscriber struct {
	ShardIteratorType *string
	Limit             *int64
	KeepOrder         *bool
	// contains filtered or unexported fields
}

func NewStreamSubscriber

func NewStreamSubscriber(
	dynamoSvc dynamodbiface.DynamoDBAPI,
	streamSvc dynamodbstreamsiface.DynamoDBStreamsAPI,
	table string) *StreamSubscriber

func (*StreamSubscriber) GetStreamData

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

func (*StreamSubscriber) GetStreamDataAsync

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

func (*StreamSubscriber) SetKeepOrder

func (r *StreamSubscriber) SetKeepOrder(b bool)

func (*StreamSubscriber) SetLimit

func (r *StreamSubscriber) SetLimit(v int64)

func (*StreamSubscriber) SetShardIteratorType

func (r *StreamSubscriber) SetShardIteratorType(s string)