watcher

package

v1.1.16-alpha Latest Latest Go to latest Published: Feb 19, 2024 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Event struct {
	Event *clientv3.Event
	Data  interface{}
}

Event watcher event

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

General a base watcher this will be use for most watchers

func New(opts ...Option) (w *General, err error)

New returns a new General watcher with handler

func (w *General) Close() error

func (w *General) GetKey() string

GetKey returns General key

func (w *General) WatchEtcd(ctx context.Context, opts ...clientv3.OpOption) (ch chan *Event, err error)

WatchEtcd start watch etcd changes

func (w *General) WatchEtcdList(ctx context.Context) (ch chan *Event, err error)

WatchEtcdList start watch etcd changes for list

type Handler func(*clientv3.Event) (*Event, error)

Handler function of handle event

func WrapInstance(prefix string, pipeName string) Handler

func WrapNode(prefix string, nodeName string) Handler

func WrapNodeStatus(prefix string, name string) Handler

func WrapPipeline(prefix string, pipeName string) Handler

func WrapSchedulerBinding() Handler

func WrapStrHandler() Handler

type Option func(*Options)

func WithHandler(h Handler) Option

func WithKey(k string) Option

type Options struct {
	Key     string
	Handler Handler
}

func NewOptions(opt ...Option) *Options

type Watcher interface {
	Watch() chan model.Model
}

Watcher a wrapper for etcd watcher