watch

Documentation

Index

• Variables
• func RegisterCustomValueDiffer(differ diff.ValueDiffer)
• type Caller
• type Cloneable
• type Receiver
  • func NewCombinedReceiver(rr []Receiver) Receiver
• type WatchOption
  • func WithChangesOnly() WatchOption
  • func WithPath(path ...string) WatchOption
• type WatchOptions
• type Watchable
• type Watcher
  • func NewWatcher[T Cloneable](object Watchable[T]) Watcher

Variables

var CustomValueDiffers []diff.ValueDiffer

Functions

func RegisterCustomValueDiffer

func RegisterCustomValueDiffer(differ diff.ValueDiffer)

Types

type Caller

type Caller interface {
	Call(diff.Change) error
}

type Cloneable

type Cloneable interface {
	Get() any
	Empty()
}

type Receiver

type Receiver interface {
	Next() (any, error)
	Stop()
}

func NewCombinedReceiver

func NewCombinedReceiver(rr []Receiver) Receiver

type WatchOption

type WatchOption func(*WatchOptions)

func WithChangesOnly

func WithChangesOnly() WatchOption

func WithPath

func WithPath(path ...string) WatchOption

type WatchOptions

type WatchOptions struct {
	Path        []string
	ChangesOnly bool
}

type Watchable

type Watchable[T Cloneable] interface {
	Clone() T
	Cloneable
}

type Watcher

type Watcher interface {
	Reset()
	Flush()
	Watch(...WatchOption) (Receiver, error)
}

func NewWatcher

func NewWatcher[T Cloneable](object Watchable[T]) Watcher