watchhook

Documentation

Index

• func AddHook(hook *WatchHook) error
• func DeleteHook(id string) error
• func Trigger(e watch.Event)
• type ChanReceiver
  • func NewChanReceiver(ch chan<- watch.Event) *ChanReceiver
  • func (hc *ChanReceiver) Receive(event watch.Event) error
• type Receiver
• type WatchHook
  • func NewWatchHook(key string, rev uint64, receiver Receiver) *WatchHook
  • func (h *WatchHook) Do(event watch.Event) error
  • func (h *WatchHook) GetGVR() schema.GroupVersionResource
  • func (h *WatchHook) GetName() string
  • func (h *WatchHook) GetNamespace() string
  • func (h *WatchHook) GetResourceVersion() uint64
  • func (h *WatchHook) Lock()
  • func (h *WatchHook) Stop()
  • func (h *WatchHook) UnLock()

Functions

func AddHook

func AddHook(hook *WatchHook) error

func DeleteHook

func DeleteHook(id string) error

func Trigger

func Trigger(e watch.Event)

Trigger trigger the corresponding hook to serve watch based on the event passed in

Types

type ChanReceiver

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

func NewChanReceiver

func NewChanReceiver(ch chan<- watch.Event) *ChanReceiver

func (*ChanReceiver) Receive

func (hc *ChanReceiver) Receive(event watch.Event) error

type Receiver

type Receiver interface {
	Receive(event watch.Event) error
}

type WatchHook

type WatchHook struct {
	GVR             schema.GroupVersionResource
	Namespace       string
	Name            string
	ResourceVersion uint64

	Receiver
	// contains filtered or unexported fields
}

func NewWatchHook

func NewWatchHook(key string, rev uint64, receiver Receiver) *WatchHook

func (*WatchHook) Do

func (h *WatchHook) Do(event watch.Event) error

func (*WatchHook) GetGVR

func (h *WatchHook) GetGVR() schema.GroupVersionResource

func (*WatchHook) GetName

func (h *WatchHook) GetName() string

func (*WatchHook) GetNamespace

func (h *WatchHook) GetNamespace() string

func (*WatchHook) GetResourceVersion

func (h *WatchHook) GetResourceVersion() uint64

func (*WatchHook) Lock

func (h *WatchHook) Lock()

func (*WatchHook) Stop

func (h *WatchHook) Stop()

func (*WatchHook) UnLock

func (h *WatchHook) UnLock()