- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for Background (0.25 sec)
-
istioctl/pkg/waypoint/waypoint.go
if _, err := kubeClient.Kube().CoreV1().Namespaces().Update(context.Background(), nsObj, metav1.UpdateOptions{}); err != nil { return fmt.Errorf("failed to update namespace %s: %v", ns, err) } return nil } func namespaceIsLabeledAmbient(kubeClient kube.CLIClient, ns string) (bool, error) { nsObj, err := kubeClient.Kube().CoreV1().Namespaces().Get(context.Background(), ns, metav1.GetOptions{}) if errors.IsNotFound(err) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
"istio.io/istio/pkg/test/util/assert" ) func TestExistingPodAddedWhenNsLabeled(t *testing.T) { setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{ NodeName: NodeName, },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
UID: "123", }, Spec: corev1.PodSpec{ Containers: containers, }, Status: podStatus, } } func TestServerAddPod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging() fixture := getTestFixure(ctx) netServer := fixture.netServer ztunnelServer := fixture.ztunnelServer podMeta := metav1.ObjectMeta{ Name: "foo",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
operator/cmd/mesh/install.go
// Ignore the err because we don't want to show // "no running Istio pods in istio-system" for the first time _ = detectIstioVersionDiff(p, tag, ns, kubeClient, iop) exists := revtag.PreviousInstallExists(context.Background(), kubeClient.Kube()) err = detectDefaultWebhookChange(p, kubeClient, iop, exists) if err != nil { return fmt.Errorf("failed to detect the default webhook change: %v", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
istioctl/pkg/util/ambient/util.go
isZtunnel := strings.HasPrefix(podName, "ztunnel") if client == nil { return isZtunnel } pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{}) if err != nil { return isZtunnel } if v, ok := pod.Labels["app"]; ok { return v == "ztunnel" } 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
} func AnnotateEnrolledPod(client kubernetes.Interface, pod *metav1.ObjectMeta) error { _, err := client.CoreV1(). Pods(pod.Namespace). Patch( context.Background(), pod.Name, types.MergePatchType, annotationPatch, metav1.PatchOptions{}, // Both "pods" and "pods/status" can mutate the metadata. However, pods/status is lower privilege, so we use that instead.
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) -
architecture/ambient/ztunnel.md
# Ztunnel This document provides an overview of the architecture and design decisions around Ztunnel, the node-proxy component in ambient mode. ## Background and motivation Motivations to implement ztunnel generally came from two areas. First, and most importantly, it serves as a means to implement the real goal: waypoints.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 22:35:16 GMT 2024 - 16.6K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
func isAmbientPod(client kubernetes.Interface, podName, podNamespace string) (bool, error) { pod, err := client.CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{}) if err != nil { return false, err } ns, err := client.CoreV1().Namespaces().Get(context.Background(), podNamespace, metav1.GetOptions{}) if err != nil { return false, err } return util.PodRedirectionEnabled(ns, pod), nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
PodName: "pod-bingo", PodNamespace: "funkyns", IPs: []IPConfig{{ Address: *addr, }}, } setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod-bingo", Namespace: "funkyns", }, Spec: corev1.PodSpec{ NodeName: NodeName, },
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) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
return f(configWriter) } } func PodOnNodeFromDaemonset(node string, name, namespace string, client kube.Client) (types.NamespacedName, error) { ds, err := client.Kube().AppsV1().DaemonSets(namespace).Get(context.Background(), name, metav1.GetOptions{}) if err != nil { return types.NamespacedName{}, err } selector := ds.Spec.Selector if selector == nil { return types.NamespacedName{}, fmt.Errorf("selector is required")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0)