watchers

Documentation

Index

• Variables
• func CiliumEndpointsInit(ciliumNPClient cilium_cli.CiliumV2Interface)
• func HasCE(ns, name string) (*cilium_api_v2.CiliumEndpoint, bool, error)
• func HasCEWithIdentity(identity string) bool
• func PodsInit(k8sClient kubernetes.Interface)
• func UnmanagedPodsInit(k8sClient kubernetes.Interface)

Variables

var (

	// CiliumEndpointStore contains all CiliumEndpoint present in k8s.
	// Warning: The CiliumEndpoints stored in the cache are not intended to be
	// used for Update operations in k8s as some of its fields were are not
	// populated.
	CiliumEndpointStore cache.Indexer

	// CiliumEndpointsSynced is closed once the CiliumEndpointStore is synced
	// with k8s.
	CiliumEndpointsSynced = make(chan struct{})
)

var (
	// PodStore has a minimal copy of all pods running in the cluster.
	// Warning: The pods stored in the cache are not intended to be used for Update
	// operations in k8s as some of its fields were are not populated.
	PodStore cache.Store

	// PodStoreSynced is closed once the PodStore is synced with k8s.
	PodStoreSynced = make(chan struct{})

	// UnmanagedPodStore has a minimal copy of the unmanaged kube-dns pods running
	// in the cluster.
	// Warning: The pods stored in the cache are not intended to be used for Update
	// operations in k8s as some of its fields were are not populated.
	UnmanagedPodStore cache.Store

	// UnmanagedPodStoreSynced is closed once the UnmanagedPodStore is synced
	// with k8s.
	UnmanagedPodStoreSynced = make(chan struct{})
)

Functions

func CiliumEndpointsInit

func CiliumEndpointsInit(ciliumNPClient cilium_cli.CiliumV2Interface)

CiliumEndpointsInit starts a CiliumEndpointWatcher

func HasCE

func HasCE(ns, name string) (*cilium_api_v2.CiliumEndpoint, bool, error)

HasCE returns true or false if the Cilium Endpoint store has the endpoint with the given name.

func HasCEWithIdentity

func HasCEWithIdentity(identity string) bool

HasCEWithIdentity returns true or false if the Cilium Endpoint store has the given identity.

func PodsInit

func PodsInit(k8sClient kubernetes.Interface)

func UnmanagedPodsInit

func UnmanagedPodsInit(k8sClient kubernetes.Interface)