ipwatcher

package

v0.8.0-alpha2 Latest Latest Go to latest Published: Jun 6, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bytedance/vArmor

Links

Open Source Insights

Documentation ¶

Index ¶

func Transform(obj interface{}) (interface{}, error)
func TransformEndpointSliceFunc(obj interface{}) (interface{}, error)
func TransformPodFunc(obj interface{}) (interface{}, error)
func TransformServiceFunc(obj interface{}) (interface{}, error)
type IPCache
type IPWatcher
- func NewIPWatcher(varmorInterface varmorinterface.CrdV1beta1Interface, ...) (*IPWatcher, error)
- func (i *IPWatcher) Run(workers int, stopCh <-chan struct{})
type SlimObject

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Transform ¶

func Transform(obj interface{}) (interface{}, error)

func TransformEndpointSliceFunc ¶

func TransformEndpointSliceFunc(obj interface{}) (interface{}, error)

func TransformPodFunc ¶

func TransformPodFunc(obj interface{}) (interface{}, error)

func TransformServiceFunc ¶

func TransformServiceFunc(obj interface{}) (interface{}, error)

Types ¶

type IPCache ¶

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

func (*IPCache) CleanupStaleEntries ¶

func (c *IPCache) CleanupStaleEntries(svcLister corelisters.ServiceLister, epsLister discoverylisters.EndpointSliceLister) error

func (*IPCache) Delete ¶

func (c *IPCache) Delete(uid string)

func (*IPCache) Get ¶

func (c *IPCache) Get(uid string) ([]string, bool)

func (*IPCache) GetAllEntries ¶

func (c *IPCache) GetAllEntries() map[string][]string

func (*IPCache) SyncCache ¶

func (c *IPCache) SyncCache(ec map[string]varmortypes.EgressInfo, svcLister corelisters.ServiceLister, epsLister discoverylisters.EndpointSliceLister)

func (*IPCache) Update ¶

func (c *IPCache) Update(uid string, ips []string)

type IPWatcher ¶

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

func NewIPWatcher ¶

func NewIPWatcher(
	varmorInterface varmorinterface.CrdV1beta1Interface,
	podInterface typedcore.PodInterface,
	serviceInterface typedcore.ServiceInterface,
	podinformer coreinformers.PodInformer,
	serviceinformer coreinformers.ServiceInformer,
	nsinformer coreinformers.NamespaceInformer,
	epsinformer discoveryinformers.EndpointSliceInformer,
	statusManager *statusmanager.StatusManager,
	egressCache map[string]varmortypes.EgressInfo,
	egressCacheMutex *sync.RWMutex,
	log logr.Logger,
) (*IPWatcher, error)

func (*IPWatcher) Run ¶

func (i *IPWatcher) Run(workers int, stopCh <-chan struct{})

type SlimObject ¶

type SlimObject struct {
	metav1.TypeMeta
	metav1.ObjectMeta
	IPs        []string
	AddedIPs   []string
	DeletedIPs []string
	EventType  string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL