watcher

Documentation

Index

• Variables
• type PlanHandlerFunc
• type UnwatchKeyFunc
• type WatchKeyFunc
• type WatchKeys
• type WatchPrefixKey
• type WatchPrefixKeyFunc
• type Watcher
  • func NewWatcher(cli *api.Client, logger *zap.Logger) *Watcher
  • func (w *Watcher) Start(_ context.Context) error
  • func (w *Watcher) Stop(_ context.Context) error
  • func (w *Watcher) WatchKeys(keys WatchKeys) error
  • func (w *Watcher) WatchPrefixKeys(keys WatchPrefixKey) error

Variables

var (
	ErrWatchFuncNotExists     = errors.New("watchKeyFunc not exists")
	ErrWatchFuncAlreadyExists = errors.New("watchKeyFunc already exists")
)

Types

type PlanHandlerFunc

type PlanHandlerFunc func(typeWatch, key string) func(idx uint64, raw any)

type UnwatchKeyFunc

type UnwatchKeyFunc func() error

type WatchKeyFunc

type WatchKeyFunc func(key, sessionID string, value []byte)

type WatchKeys

type WatchKeys map[string]WatchKeyFunc

type WatchPrefixKey

type WatchPrefixKey map[string]WatchPrefixKeyFunc

type WatchPrefixKeyFunc

type WatchPrefixKeyFunc func(params map[string][]byte)

type Watcher

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

func NewWatcher

func NewWatcher(cli *api.Client, logger *zap.Logger) *Watcher

func (*Watcher) Start

func (w *Watcher) Start(_ context.Context) error

func (*Watcher) Stop

func (w *Watcher) Stop(_ context.Context) error

func (*Watcher) WatchKeys

func (w *Watcher) WatchKeys(keys WatchKeys) error

func (*Watcher) WatchPrefixKeys

func (w *Watcher) WatchPrefixKeys(keys WatchPrefixKey) error