Documentation ¶
Overview ¶
Yury Kozyrev (urakozz) MIT License
Index ¶
Constants ¶
View Source
const SleepTime = 1 * time.Second
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Click to show internal directories.
Click to hide internal directories.