observer

Documentation

Index

• type EtcdEvent
• type EtcdFilter
  • func NewEtcdFilter(observer *EtcdObserver, handler EtcdObserveHandler) (*EtcdFilter, error)
  • func (f *EtcdFilter) Start() *EtcdFilter
  • func (f *EtcdFilter) Stop()
• type EtcdObserveHandler
• type EtcdObserveKey
• type EtcdObserver
  • func NewEtcdObserver(cfg *config.Config) (*EtcdObserver, error)
  • func (bs *EtcdObserver) Observe(ctx context.Context, path string) error
  • func (bs *EtcdObserver) RegisterHandler(handler EtcdObserveHandler) EtcdObserveKey
  • func (bs *EtcdObserver) RunEtcdObserver(path string)
  • func (bs *EtcdObserver) UnregisterHandler(id EtcdObserveKey)

Types

type EtcdEvent

type EtcdEvent struct {
	*v3.Event
}

type EtcdFilter

type EtcdFilter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewEtcdFilter

func NewEtcdFilter(observer *EtcdObserver, handler EtcdObserveHandler) (*EtcdFilter, error)

func (*EtcdFilter) Start

func (f *EtcdFilter) Start() *EtcdFilter

func (*EtcdFilter) Stop

func (f *EtcdFilter) Stop()

type EtcdObserveHandler

type EtcdObserveHandler func(ev *EtcdEvent)

type EtcdObserveKey

type EtcdObserveKey string

type EtcdObserver

type EtcdObserver struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewEtcdObserver

func NewEtcdObserver(cfg *config.Config) (*EtcdObserver, error)

func (*EtcdObserver) Observe

func (bs *EtcdObserver) Observe(ctx context.Context, path string) error

func (*EtcdObserver) RegisterHandler

func (bs *EtcdObserver) RegisterHandler(handler EtcdObserveHandler) EtcdObserveKey

func (*EtcdObserver) RunEtcdObserver

func (bs *EtcdObserver) RunEtcdObserver(path string)

func (*EtcdObserver) UnregisterHandler

func (bs *EtcdObserver) UnregisterHandler(id EtcdObserveKey)