Versions in this module Expand all Collapse all v1 v1.0.1 May 10, 2021 v1.0.0 May 9, 2021 Changes in this version + var ErrWatcherStopped = errors.New("watcher stopped") + type ChangeSet struct + Checksum string + Data []byte + Format string + Source string + Timestamp time.Time + func (c *ChangeSet) Sum() string + type Option func(o *Options) + func WithEncoder(e encoder.Encoder) Option + type Options struct + Context context.Context + Encoder encoder.Encoder + func NewOptions(opts ...Option) Options + type Source interface + Read func() (*ChangeSet, error) + String func() string + Watch func() (Watcher, error) + Write func(*ChangeSet) error + type Watcher interface + Next func() (*ChangeSet, error) + Stop func() error + func NewNoopWatcher() (Watcher, error) Incompatible versions in this module v2.3.0+incompatible May 9, 2021
Go to main page