Versions in this module Expand all Collapse all v0 v0.2.0 May 23, 2026 Changes in this version + func Register(r *source.Registry, opts ...Option) error + type Option func(*Source) + func WithDBPath(path string) Option + func WithDiscoverWindow(d time.Duration) Option + type Source struct + func New(opts ...Option) *Source + func (s *Source) Discover(ctx context.Context) ([]source.SessionHandle, error) + func (s *Source) Name() string + func (s *Source) Parse(ctx context.Context, h source.SessionHandle, c source.Cursor) (source.SourceUpdate, source.Cursor, error)
Go to main page