Documentation
¶
Index ¶
- func ExtractNamespace(np NamespaceNameGetter) string
- func ExtractNamespaceOrDefault(np NamespaceNameGetter) string
- func GetClusterIPByFamily(ipFamily slim_corev1.IPFamily, service *slim_corev1.Service) string
- func GetLatestPodReadiness(podStatus slim_corev1.PodStatus) slim_corev1.ConditionStatus
- func GetObjNamespaceName(obj NamespaceNameGetter) string
- func GetServiceListOptionsModifier(cfg ServiceConfiguration) (func(options *v1meta.ListOptions), error)
- func GetWorkloadMetaFromPod(pod *slim_corev1.Pod) (slim_metav1.ObjectMeta, slim_metav1.TypeMeta, bool)
- func IsPodRunning(status slim_corev1.PodStatus) bool
- func ListerWatcherFromTyped[T k8sRuntime.Object](lw typedListWatcher[T]) cache.ListerWatcher
- func ListerWatcherWithFields(lw cache.ListerWatcher, fieldSelector fields.Selector) cache.ListerWatcher
- func ListerWatcherWithModifier(lw cache.ListerWatcher, optsModifier func(*metav1.ListOptions)) cache.ListerWatcher
- func SanitizePodLabels(labels map[string]string, namespace *slim_corev1.Namespace, ...) map[string]string
- func StripPodSpecialLabels(labels map[string]string) map[string]string
- func ValidIPs(podStatus slim_corev1.PodStatus) []string
- type GatewayAPIConfiguration
- type IngressConfiguration
- type NamespaceNameGetter
- type ServiceConfiguration
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExtractNamespace ¶
func ExtractNamespace(np NamespaceNameGetter) string
ExtractNamespace extracts the namespace of ObjectMeta. For cluster scoped objects the Namespace field is empty and this function assumes that the object is returned from kubernetes itself implying that the namespace is empty only and only when the Object is cluster scoped and thus returns empty namespace for such objects.
func ExtractNamespaceOrDefault ¶
func ExtractNamespaceOrDefault(np NamespaceNameGetter) string
ExtractNamespaceOrDefault extracts the namespace of ObjectMeta, it returns default namespace if the namespace field in the ObjectMeta is empty.
func GetClusterIPByFamily ¶
func GetClusterIPByFamily(ipFamily slim_corev1.IPFamily, service *slim_corev1.Service) string
GetClusterIPByFamily returns a service clusterip by family. From - https://github.com/kubernetes/kubernetes/blob/release-1.20/pkg/proxy/util/utils.go#L386-L411
func GetLatestPodReadiness ¶
func GetLatestPodReadiness(podStatus slim_corev1.PodStatus) slim_corev1.ConditionStatus
GetLatestPodReadiness returns the lastest podReady condition on a given pod.
func GetObjNamespaceName ¶
func GetObjNamespaceName(obj NamespaceNameGetter) string
GetObjNamespaceName returns the object's namespace and name. If the object is cluster scoped then the function returns only the object name without any namespace prefix.
func GetServiceListOptionsModifier ¶ added in v1.8.4
func GetServiceListOptionsModifier(cfg ServiceConfiguration) (func(options *v1meta.ListOptions), error)
GetServiceListOptionsModifier returns the options modifier for service object list. This methods returns a ListOptions modifier which adds a label selector to only select services that are in context of Cilium. Like kube-proxy Cilium does not select services containing k8s headless service label. We honor service.kubernetes.io/service-proxy-name label in the service object and only handle services that match our service proxy name. If the service proxy name for Cilium is an empty string, we assume that Cilium is the default service handler in which case we select all services that don't have the above mentioned label.
func GetWorkloadMetaFromPod ¶
func GetWorkloadMetaFromPod(pod *slim_corev1.Pod) (slim_metav1.ObjectMeta, slim_metav1.TypeMeta, bool)
GetWorkloadMetaFromPod heuristically derives workload metadata from the pod spec.
func IsPodRunning ¶
func IsPodRunning(status slim_corev1.PodStatus) bool
IsPodRunning returns true if the pod is considered to be in running state. We consider a Running pod a pod that does not report a Failed nor a Succeeded pod Phase.
func ListerWatcherFromTyped ¶
func ListerWatcherFromTyped[T k8sRuntime.Object](lw typedListWatcher[T]) cache.ListerWatcher
ListerWatcherFromTyped adapts a typed k8s client to cache.ListerWatcher so it can be used with an informer. With this construction we can use fake clients for testing, which would not be possible if we used NewListWatchFromClient and RESTClient().
func ListerWatcherWithFields ¶
func ListerWatcherWithFields(lw cache.ListerWatcher, fieldSelector fields.Selector) cache.ListerWatcher
func ListerWatcherWithModifier ¶
func ListerWatcherWithModifier(lw cache.ListerWatcher, optsModifier func(*metav1.ListOptions)) cache.ListerWatcher
func SanitizePodLabels ¶ added in v1.12.14
func SanitizePodLabels(labels map[string]string, namespace *slim_corev1.Namespace, serviceAccount, clusterName string) map[string]string
SanitizePodLabels makes sure that no important pod labels were overridden manually
func StripPodSpecialLabels ¶ added in v1.12.14
StripPodSpecialLabels strips labels that are not supposed to be coming from a k8s pod object
func ValidIPs ¶
func ValidIPs(podStatus slim_corev1.PodStatus) []string
ValidIPs return a sorted slice of unique IP addresses retrieved from the given PodStatus. Returns an error when no IPs are found.
Types ¶
type GatewayAPIConfiguration ¶
type GatewayAPIConfiguration interface { // K8sGatewayAPIEnabled returns true if gateway API is enabled in Cilium K8sGatewayAPIEnabled() bool }
GatewayAPIConfiguration is the required configuration for GetServiceListOptionsModifier
type IngressConfiguration ¶
type IngressConfiguration interface { // K8sIngressControllerEnabled returns true if ingress controller feature is enabled in Cilium K8sIngressControllerEnabled() bool }
IngressConfiguration is the required configuration for GetServiceListOptionsModifier
type NamespaceNameGetter ¶
type ServiceConfiguration ¶
type ServiceConfiguration interface { // K8sServiceProxyNameValue must return the value of the proxy name // annotation. If set, only services with this label will be handled. K8sServiceProxyNameValue() string }
ServiceConfiguration is the required configuration for GetServiceListOptionsModifier