Versions in this module Expand all Collapse all v0 v0.2.0 Aug 28, 2026 v0.1.0 May 12, 2026 Changes in this version + type Config struct + Client *kinesis.Client + Decode Decoder[T] + OnDecodeError func(raw []byte, shardID, sequenceNumber string, err error) + OnGetRecordsError func(streamName, shardID string, err error) + PollInterval time.Duration + RecordsPerCall int32 + StartTimestamp *time.Time + StartingPosition types.ShardIteratorType + StreamName string + type Decoder func([]byte) (T, error) + func JSONDecoder[T any]() Decoder[T] + type Source struct + func NewSource[T any](cfg Config[T]) (*Source[T], error) + func (s *Source[T]) Close() error + func (s *Source[T]) Name() string + func (s *Source[T]) Read(ctx context.Context, out chan<- source.Record[T]) error
Go to main page