- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for ns (0.16 sec)
-
istioctl/pkg/waypoint/waypoint.go
if err != nil { return fmt.Errorf("failed to create Kubernetes client: %v", err) } var ns string if allNamespaces { ns = "" } else { ns = ctx.NamespaceOrDefault(ctx.Namespace()) } gws, err := kubeClient.GatewayAPI().GatewayV1().Gateways(ns). List(context.Background(), metav1.ListOptions{}) if err != nil { return err } if len(gws.Items) == 0 {
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/plugin_test.go
excludedNS := "testExcludeNS" pod, ns := buildFakePodAndNSForClient() app := corev1.Container{Name: "app"} ns.ObjectMeta.Name = excludedNS ns.ObjectMeta.Labels = map[string]string{constants.DataplaneMode: constants.AmbientRedirectionEnabled} pod.ObjectMeta.Namespace = excludedNS pod.Spec.Containers = []corev1.Container{app} testDoAddRun(t, cniConf, excludedNS, pod, ns) wasCalled := serverClose()
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
constants.DataplaneMode)) _, err = client.Kube().CoreV1().Namespaces().Patch(ctx, ns.Name, types.MergePatchType, labelsPatch, metav1.PatchOptions{}) assert.NoError(t, err) // wait for another two update events // total 3 update at before unlabel point: 1. init ns reconcile 2. ns label reconcile 3. pod annotation update
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
})) return s } func (s *InformerHandlers) GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error) { ns := s.namespaces.Get(podNamespace, "") if ns == nil { return nil, fmt.Errorf("failed to find namespace %v", ns) } pod := s.pods.Get(podName, podNamespace) if util.PodRedirectionEnabled(ns, pod) { return pod, nil } return nil, nil } func (s *InformerHandlers) Start() {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 9.9K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
// only use the first pod in the list podName = pl.Items[0].Name ns = pl.Items[0].Namespace } else { podName, ns, err = ctx.InferPodInfoFromTypedResource(args[0], ctx.IstioNamespace()) if err != nil { return err } } port := inferMonitoringPort(client, podName, ns) return portForward(podName, ns, fmt.Sprintf("Istio debug %s", podName),
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
# Apply the tag to cluster kubectl apply -f tag.yaml # Point namespace "test-ns" at the revision pointed to by the "prod" revision tag kubectl label ns test-ns istio.io/rev=prod # Rollout namespace "test-ns" to update workloads to the "1-8-0" revision kubectl rollout restart deployments -n test-ns `, Args: func(cmd *cobra.Command, args []string) error { if len(args) == 0 {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
client.initWebSocket(random, pingIntervalMillis = 500) taskFaker.advanceUntil(ns(500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. taskFaker.advanceUntil(ns(1000L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. taskFaker.advanceUntil(ns(1500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject_test.go
func Test_analyzeRunningWebhooks(t *testing.T) { cases := []struct { name string pod *corev1.Pod ns *corev1.Namespace expectedMessages []webhookAnalysis }{ { name: "no inj because of no match labels", pod: podTestObject("test1", "test1", "", ""), ns: nsTestObject("test1", "", ""), expectedMessages: []webhookAnalysis{ { Name: "istio-sidecar-injector",
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 10.6K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
ns string, serviceAccount string, kubeClient kube.CLIClient, options Options, ) (map[string]*discovery.DiscoveryResponse, error) { // If Central Istiod case, just call it if ns == "" { ns = istioNamespace } if ns == istioNamespace { serviceAccount = tokenServiceAccount } if centralOpts.Xds != "" {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
operator/cmd/mesh/install.go
} profile, ns, enabledComponents, err := getProfileNSAndEnabledComponents(iop) if err != nil { return fmt.Errorf("failed to get profile, namespace or enabled components: %v", err) } // 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)
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 15.2K bytes - Viewed (0)