- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for setOptions (0.22 sec)
-
istioctl/pkg/kubeinject/kubeinject.go
Transport: &http.Transport{ TLSClientConfig: tlsClientConfig, }, } if cc.Service != nil { svc, err := e.client.Kube().CoreV1().Services(cc.Service.Namespace).Get(context.Background(), cc.Service.Name, metav1.GetOptions{}) if err != nil { return nil, err } namespace, selector, err := polymorphichelpers.SelectorsForObject(svc) if err != nil { if e.injectorAddress == "" {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
} else if outputFormat == prometheusOutput { path += "/prometheus" } else if outputFormat == prometheusMergedOutput { pod, err := kubeClient.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{}) if err != nil { return "", fmt.Errorf("failed to retrieve Pod %s/%s: %v", podNamespace, podName, err) } promPath, promPort, err := util.PrometheusPathAndPort(pod) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
client, err := ctx.CLIClient() if err != nil { return err } pod, err := client.Kube().CoreV1().Pods(ns).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return err } writer := cmd.OutOrStdout() podLabels := klabels.Set(pod.ObjectMeta.Labels) annotations := klabels.Set(pod.ObjectMeta.Annotations)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
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 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
defer ticker.Stop() for range ticker.C { programmed := false gwc, err := kubeClient.GatewayAPI().GatewayV1().Gateways(ctx.NamespaceOrDefault(ctx.Namespace())).Get(context.TODO(), gw.Name, metav1.GetOptions{}) if err == nil { // Check if gateway has Programmed condition set to true for _, cond := range gwc.Status.Conditions {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 01 16:16:40 GMT 2024 - 15.2K bytes - Viewed (0) -
cni/pkg/plugin/kubernetes.go
// getK8sPodInfo returns information of a POD func getK8sPodInfo(client kubernetes.Interface, podName, podNamespace string) (*PodInfo, error) { pod, err := client.CoreV1().Pods(podNamespace).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return nil, err } pi := ExtractPodInfo(pod) log.Debugf("Pod %v/%v info: \n%+v", podNamespace, podName, pi) return pi, nil } func ExtractPodInfo(pod *v1.Pod) *PodInfo {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 3.6K bytes - Viewed (0) -
istioctl/pkg/xds/google.go
client := exClient.Dynamic() gvr := schema.GroupVersionResource{ Group: "hub.gke.io", Version: "v1", Resource: "memberships", } u, err := client.Resource(gvr).Get(ctx, "membership", metav1.GetOptions{}) if err != nil { return nil, err } spec, ok := u.Object["spec"].(map[string]any) if !ok { return nil, errors.New(`field "spec" is not a map`) } var mem hubMembership
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Nov 14 20:23:34 GMT 2022 - 3.4K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
if selectedNamespace != "" { client, err := ctx.CLIClient() if err != nil { return err } _, err = client.Kube().CoreV1().Namespaces().Get(context.TODO(), selectedNamespace, metav1.GetOptions{}) if errors.IsNotFound(err) { fmt.Fprintf(cmd.ErrOrStderr(), "namespace %q not found\n", ctx.Namespace()) return nil } else if err != nil { return err } } }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
istioctl/pkg/tag/generate_test.go
assert.NoError(t, err) wh, err := fakeClient.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations(). Get(context.Background(), "istio-sidecar-injector", metav1.GetOptions{}) assert.NoError(t, err) assertFunc(t, wh.Webhooks, defaultWh.Webhooks) } func TestGenerateOptions(t *testing.T) { // Test generate option 'true', should not modify webhooks
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 12.1K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
kubeClient: fakeClientSet, netServer: server, } err := m.AddPodToMesh(fakeCtx, pod, podIPs, "") assert.NoError(t, err) pod, err = fakeClientSet.CoreV1().Pods("test").Get(fakeCtx, "test", metav1.GetOptions{}) assert.NoError(t, err) assert.Equal(t, len(pod.Annotations), 1) assert.Equal(t, pod.Annotations[constants.AmbientRedirection], constants.AmbientRedirectionEnabled) }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0)