Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Click to show internal directories.
Click to hide internal directories.