k8swatcher

Feb 9, 2024

Changes in this version

type IPPoolWatcher

+ func (c *IPPoolWatcher) SyncCache(stopCh <-chan struct{}) bool

type NodeWatcher

+ func (c *NodeWatcher) SyncCache(stopCh <-chan struct{}) error

Feb 9, 2024

Changes in this version

+ type IPPoolHandler interface

+ SyncIPPool func(poolKey string, poolLister crdlisters.IPPoolLister) error

+ type IPPoolWatcher struct

+ func NewIPPoolWatcher(poolInformer crdinformers.IPPoolInformer, resyncPeriod time.Duration) *IPPoolWatcher

+ func (c *IPPoolWatcher) RegisterEventHandler(handler IPPoolHandler)

+ func (c *IPPoolWatcher) Run(workers int, stopCh <-chan struct{})

+ type NodeHandler interface

+ SyncNode func(nodeKey string, nodeLister corelisters.NodeLister) error

+ type NodeWatcher struct

+ func NewNodeWatcher(nodeInformer coreinformers.NodeInformer, resyncPeriod time.Duration) *NodeWatcher

+ func (c *NodeWatcher) RegisterEventHandler(handler NodeHandler)

+ func (c *NodeWatcher) Run(workers int, stopCh <-chan struct{})