Versions in this module Expand all Collapse all v0 v0.1.0 May 12, 2026 Changes in this version + type Record struct + Ack func() error + EventID string + EventTime time.Time + PartitionKey string + Value T + type Source interface + Close func() error + Name func() string + Read func(ctx context.Context, out chan<- Record[T]) error
Go to main page