Versions in this module Expand all Collapse all v0 v0.2.0 Jul 17, 2026 Changes in this version + var ErrDrained = errors.New("source: drained") + type InMemory struct + func NewInMemory(records []domain.Record) *InMemory + func (s *InMemory) Close() error + func (s *InMemory) Next(ctx context.Context) (domain.Record, error) + type Source interface + Close func() error + Next func(ctx context.Context) (domain.Record, error)
Go to main page