- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for Gaebel (0.17 sec)
-
istioctl/pkg/multixds/gather.go
xdsstatus "github.com/envoyproxy/go-control-plane/envoy/service/status/v3" "google.golang.org/grpc" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "istio.io/api/label" "istio.io/istio/istioctl/pkg/clioptions" "istio.io/istio/istioctl/pkg/xds" pilotxds "istio.io/istio/pilot/pkg/xds" "istio.io/istio/pkg/kube" istioversion "istio.io/istio/pkg/version" ) const (
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
// wait for an update events // total 3 update at before unlabel point: 1. init ns reconcile 2. ns label reconcile 3. pod annotation update mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(4)) waitForMockCalls() assertPodNotAnnotated(t, client, pod) // patch a test label to emulate a POD update event _, err = client.Kube().CoreV1().Pods(pod.Namespace).Patch(ctx, pod.Name,
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) -
istioctl/pkg/dashboard/dashboard.go
envoy.PersistentFlags().StringVarP(&labelSelector, "selector", "l", "", "Label selector") envoy.PersistentFlags().IntVar(&proxyAdminPort, "ui-port", util.DefaultProxyAdminPort, "The component dashboard UI port.") dashboardCmd.AddCommand(envoy) proxy := proxyDashCmd(cliContext) proxy.PersistentFlags().StringVarP(&labelSelector, "selector", "l", "", "Label selector")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
"testing" "github.com/containernetworking/cni/pkg/skel" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "istio.io/api/annotation" "istio.io/api/label" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test/util/assert" ) const ( testPodName = "testPod" testNSName = "testNS"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
opts.Revision = "default" } if len(istiodLabelSelector) > 0 { istiodLabelSelector = fmt.Sprintf("%s,%s=%s", istiodLabelSelector, label.IoIstioRev.Name, opts.Revision) } else { istiodLabelSelector = fmt.Sprintf("%s=%s", label.IoIstioRev.Name, opts.Revision) } pl, err := client.PodsForSelector(context.TODO(), ctx.NamespaceOrDefault(ctx.IstioNamespace()), istiodLabelSelector)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
return r }() codecs = serializer.NewCodecFactory(runtimeScheme) deserializer = codecs.UniversalDeserializer() ) // GetFirstPod returns a pod matching the namespace and label selector // and the number of all pods that match the label selector. // This is forked from polymorphichelpers.GetFirstPod to not watch and instead return an error if no pods are found
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
`, Aliases: []string{"es"}, Args: func(cmd *cobra.Command, args []string) error { if len(args) != 1 && (labelSelector == "") { cmd.Println(cmd.UsageString()) return fmt.Errorf("stats requires pod name or label selector") } return nil }, RunE: func(c *cobra.Command, args []string) error { var stats string kubeClient, err := ctx.CLIClient() if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
// If they don't, the user will be warned and be presented with the command to label their namespace as ambient if they // choose to do so. // // NOTE: This is a warning and not an error because the user may not intend to label their namespace as ambient. // // e.g. Users are handling ambient redirection per workload rather than at the namespace level.
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) -
istioctl/pkg/tag/generate_test.go
"k8s.io/apimachinery/pkg/runtime/serializer" "istio.io/api/label" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test/env" "istio.io/istio/pkg/test/util/assert" ) var ( defaultRevisionCanonicalWebhook = admitv1.MutatingWebhookConfiguration{ ObjectMeta: metav1.ObjectMeta{ Name: "istio-sidecar-injector", Labels: map[string]string{label.IoIstioRev.Name: "default"}, }, Webhooks: []admitv1.MutatingWebhook{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 12.1K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
repairLog.Infof("Pod detected as broken, adding label: %s/%s", pod.Namespace, pod.Name) labels := pod.GetLabels() if _, ok := labels[c.cfg.LabelKey]; ok { m.With(resultLabel.Value(resultSkip)).Increment() repairLog.Infof("Pod %s/%s already has label with key %s, skipping", pod.Namespace, pod.Name, c.cfg.LabelKey) return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0)