- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for stringa (0.21 sec)
-
cni/pkg/util/podutil_test.go
} func TestPodRedirectionEnabled(t *testing.T) { var ( ambientEnabledLabel = map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeAmbient} ambientDisabledLabel = map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeNone} sidecarStatusAnnotation = map[string]string{annotation.SidecarStatus.Name: "test"} namespaceWithAmbientEnabledLabel = &corev1.Namespace{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 4.9K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
} } return nil } func getModeLabel(m map[string]string) string { if m == nil { return "" } return m[constants.DataplaneModeLabel] } func (s *InformerHandlers) reconcilePod(input any) error { event := input.(controllers.Event) pod := event.Latest().(*corev1.Pod) defer EventTotals.With(eventTypeTag.Value(event.Event.String())).Increment() switch event.Event {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
istioctl/pkg/util/ambient/util.go
package ambient import ( "context" "strings" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "istio.io/api/label" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" ) func IsZtunnelPod(client kube.CLIClient, podName, podNamespace string) bool { isZtunnel := strings.HasPrefix(podName, "ztunnel") if client == nil { return isZtunnel }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 1.7K bytes - Viewed (0) -
cni/pkg/util/podutil.go
} return true } func podHasSidecar(pod *corev1.Pod) bool { if _, f := pod.GetAnnotations()[annotation.SidecarStatus.Name]; f { return true } return false } func IsZtunnelPod(systemNs string, pod *corev1.Pod) bool { return pod.Namespace == systemNs && pod.GetLabels()["app"] == "ztunnel" } func AnnotateEnrolledPod(client kubernetes.Interface, pod *metav1.ObjectMeta) error { _, err := client.CoreV1().
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 3.9K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list_test.go
cases := []struct { name string pod *corev1.Pod expectedRevision string }{ { name: "no rev", pod: &corev1.Pod{}, expectedRevision: "", }, { name: "has rev annotation", pod: &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Annotations: map[string]string{ annotation.SidecarStatus.Name: `{"revision": "test-anno"}`,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 2.9K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
valid := CNIPluginAddEvent{ Netns: "/var/netns/foo", PodName: "pod-bingo", PodNamespace: "funkyns", } payload, _ := json.Marshal(valid) invalid := string(payload) + "funkyjunk" _, err := processAddEvent([]byte(invalid)) assert.Error(t, err) } func TestCNIPluginServer(t *testing.T) { fakePodIP := "11.1.1.12" _, addr, _ := net.ParseCIDR(fakePodIP + "/32")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0)