watcher

Documentation

Index

• type Watcher
  • func New() *Watcher
  • func (w *Watcher) AfterTransaction(err error) error
  • func (w *Watcher) BeforeCommit(tx bolted.WriteTx) error
  • func (w *Watcher) Closed() error
  • func (w *Watcher) CreateMap(tx bolted.WriteTx, path string) error
  • func (w *Watcher) Delete(tx bolted.WriteTx, path string) error
  • func (w *Watcher) Opened(b *bolted.Bolted) error
  • func (w *Watcher) Put(tx bolted.WriteTx, path string, newValue []byte) error
  • func (w *Watcher) Start(c bolted.WriteTx) error
  • func (w *Watcher) WatchForChanges(ctx context.Context, path string, cb func(c bolted.ReadTx) error) error

Types

type Watcher

type Watcher struct {
	// contains filtered or unexported fields
}

func New

func New() *Watcher

func (*Watcher) AfterTransaction

func (w *Watcher) AfterTransaction(err error) error

func (*Watcher) BeforeCommit

func (w *Watcher) BeforeCommit(tx bolted.WriteTx) error

func (*Watcher) Closed

func (w *Watcher) Closed() error

Closed TODO: add closing of the database semantics

func (*Watcher) CreateMap

func (w *Watcher) CreateMap(tx bolted.WriteTx, path string) error

func (*Watcher) Delete

func (w *Watcher) Delete(tx bolted.WriteTx, path string) error

func (*Watcher) Opened

func (w *Watcher) Opened(b *bolted.Bolted) error

func (*Watcher) Put

func (w *Watcher) Put(tx bolted.WriteTx, path string, newValue []byte) error

func (*Watcher) Start

func (w *Watcher) Start(c bolted.WriteTx) error

func (*Watcher) WatchForChanges

func (w *Watcher) WatchForChanges(ctx context.Context, path string, cb func(c bolted.ReadTx) error) error