source

type ChangeSet struct {
	Data     []byte
	CheckSum string
	Format   string
	//Source    string
	Timestamp time.Time
}

type Option func(*Options)

type Options struct {
	Encoder encoder.Encoder
	Context context.Context
}

type Source interface {
	Read() (*ChangeSet, error)
	Write(*ChangeSet) (*ChangeSet, error)
	Watcher() (Watcher, error)
	Path() string
}

type Watcher interface {
	Next() (*ChangeSet, error)
	Stop() error
}