Versions in this module Expand all Collapse all v0 v0.2.0 Aug 22, 2026 Changes in this version + var ErrWatch = errors.New("yaml: this watch could not be opened") type Source + func (s Source) Watched() *WatchedSource + type WatchedSource struct + func (w *WatchedSource) Bind(addrs *ferry.AddressSet) (ferry.OpenFunc, error) + func (w *WatchedSource) Watching() (ferry.Notifier, error) v0.1.0 Aug 12, 2026 Changes in this version + const ExtensionKey + func Extension() ferry.KeyExtension + type Option interface + func Durable() Option + type Sink struct + func NewSink(path string, opts ...Option) Sink + func (s Sink) Bind(addrs *ferry.AddressSet) (ferry.OpenWriterFunc, error) + type Source struct + func NewSource(path string, opts ...SourceOption) Source + func (s Source) Bind(addrs *ferry.AddressSet) (ferry.OpenFunc, error) + type SourceOption interface + func Watch(ctx context.Context, every time.Duration, onChange func(context.Context)) SourceOption
Go to main page