stream

Documentation

Overview

Yury Kozyrev (urakozz) MIT License

Index

• Constants
• type StreamSubscriber
  • func NewStreamSubscriber(dynamoSvc *dynamodb.DynamoDB, streamSvc *dynamodbstreams.DynamoDBStreams, ...) *StreamSubscriber
  • func (r *StreamSubscriber) GetStreamData() (<-chan *dynamodbstreams.Record, <-chan error)
  • func (r *StreamSubscriber) GetStreamDataAsync() (<-chan *dynamodbstreams.Record, <-chan error)
  • func (r *StreamSubscriber) SetLimit(v int64)
  • func (r *StreamSubscriber) SetShardIteratorType(s string)

Constants

const SleepTime = 1 * time.Second

Types

type StreamSubscriber

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

func NewStreamSubscriber

func NewStreamSubscriber(dynamoSvc *dynamodb.DynamoDB, streamSvc *dynamodbstreams.DynamoDBStreams, 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) SetLimit

func (r *StreamSubscriber) SetLimit(v int64)

func (*StreamSubscriber) SetShardIteratorType

func (r *StreamSubscriber) SetShardIteratorType(s string)