Documentation
¶
Overview ¶
Package ipwatcher watches the IP and port changes of pods, services and endpointslices
Index ¶
- func Transform(obj interface{}) (interface{}, error)
- type IPPortCache
- func (c *IPPortCache) CleanupStaleEntries(svcLister corelisters.ServiceLister, ...) error
- func (c *IPPortCache) Delete(uid string)
- func (c *IPPortCache) Get(uid string) (ipPort, bool)
- func (c *IPPortCache) GetAllEntries() map[string]ipPort
- func (c *IPPortCache) SyncCache(ec map[string]varmortypes.EgressInfo, svcLister corelisters.ServiceLister, ...)
- func (c *IPPortCache) Update(uid string, i ipPort)
- type IPWatcher
- type SlimObject
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type IPPortCache ¶
type IPPortCache struct {
// contains filtered or unexported fields
}
func (*IPPortCache) CleanupStaleEntries ¶
func (c *IPPortCache) CleanupStaleEntries(svcLister corelisters.ServiceLister, epsLister discoverylisters.EndpointSliceLister) error
func (*IPPortCache) Delete ¶
func (c *IPPortCache) Delete(uid string)
func (*IPPortCache) Get ¶
func (c *IPPortCache) Get(uid string) (ipPort, bool)
func (*IPPortCache) GetAllEntries ¶
func (c *IPPortCache) GetAllEntries() map[string]ipPort
func (*IPPortCache) SyncCache ¶
func (c *IPPortCache) SyncCache(ec map[string]varmortypes.EgressInfo, svcLister corelisters.ServiceLister, epsLister discoverylisters.EndpointSliceLister)
func (*IPPortCache) Update ¶
func (c *IPPortCache) Update(uid string, i ipPort)
type IPWatcher ¶
type IPWatcher struct {
// contains filtered or unexported fields
}
func NewIPWatcher ¶
func NewIPWatcher( varmorInterface varmorinterface.CrdV1beta1Interface, podinformer coreinformers.PodInformer, serviceinformer coreinformers.ServiceInformer, epsinformer discoveryinformers.EndpointSliceInformer, egressCache map[string]varmortypes.EgressInfo, egressCacheMutex *sync.RWMutex, log logr.Logger, ) (*IPWatcher, error)
Source Files
Click to show internal directories.
Click to hide internal directories.