watcher

Documentation

Index

• type Event
• type General
  • func New(opts ...Option) (w *General, err error)
  • func (w *General) Close() error
  • func (w *General) GetKey() string
  • func (w *General) WatchEtcd(ctx context.Context, opts ...clientv3.OpOption) (ch chan *Event, err error)
  • func (w *General) WatchEtcdList(ctx context.Context) (ch chan *Event, err error)
• type Handler
  • 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 WithHandler(h Handler) Option
  • func WithKey(k string) Option
• type Options
  • func NewOptions(opt ...Option) *Options
• type Watcher

Types

type Event

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

Event watcher event

type General

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

General a base watcher this will be use for most watchers

func New

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

New returns a new General watcher with handler

func (*General) Close

func (w *General) Close() error

func (*General) GetKey

func (w *General) GetKey() string

GetKey returns General key

func (*General) WatchEtcd

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

WatchEtcd start watch etcd changes

func (*General) WatchEtcdList

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

WatchEtcdList start watch etcd changes for list

type Handler

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

Handler function of handle event

func WrapInstance

func WrapInstance(prefix string, pipeName string) Handler

func WrapNode

func WrapNode(prefix string, nodeName string) Handler

func WrapNodeStatus

func WrapNodeStatus(prefix string, name string) Handler

func WrapPipeline

func WrapPipeline(prefix string, pipeName string) Handler

func WrapSchedulerBinding

func WrapSchedulerBinding() Handler

func WrapStrHandler

func WrapStrHandler() Handler

type Option

type Option func(*Options)

func WithHandler

func WithHandler(h Handler) Option

func WithKey

func WithKey(k string) Option

type Options

type Options struct {
	Key     string
	Handler Handler
}

func NewOptions

func NewOptions(opt ...Option) *Options

type Watcher

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

Watcher a wrapper for etcd watcher