- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for ns (0.17 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) -
istioctl/pkg/writer/ztunnel/configdump/testdata/secretsummary.txt
spiffe://cluster.local/ns/istio-system/sa/istiod Leaf Available true e5dfb59150b2ba7f108d93dcec5aa613 2033-03-22T13:04:57Z 2023-03-21T13:02:57Z spiffe://cluster.local/ns/istio-system/sa/istiod Root Available false 8a516645c40ce76c2c0d27ab4e2461c1 2022-03-18T13:04:49Z 2022-03-21T13:04:49Z
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 1022 bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 1) // make sure the uid was taken from cache and netns closed netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns: //revive:disable-next-line:call-to-gc Just a test that we are cleaning up the netns runtime.GC() assertNSClosed(t, closed) } func TestServerDeletePod(t *testing.T) {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cmd/metrics-v2.go
} } func getClusterReplProxiedGetOperationsMD(ns MetricNamespace) MetricDescription { return MetricDescription{ Namespace: ns, Subsystem: replicationSubsystem, Name: proxiedGetRequestsTotal, Help: "Number of GET requests proxied to replication target", Type: counterMetric, } } func getClusterReplProxiedHeadOperationsMD(ns MetricNamespace) MetricDescription {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
// don't return error here, as this is purely informational. } return retErr } func (s *meshDataplane) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) err := s.netServer.RemovePodFromMesh(ctx, pod) if err != nil { log.Errorf("failed to remove pod from mesh: %v", err) return err } log.Debug("removing annotation from pod")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
if len(args) == 1 { podName, ns, err := getComponentPodName(ctx, args[0]) if err != nil { return err } ztunnelPod := ambientutil.IsZtunnelPod(kubeClient, podName, ns) if !ztunnelPod { return fmt.Errorf("workloads command is only supported by Ztunnel proxies: %v", podName) } podNames = []string{podName} podNamespace = ns } else { var err error
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
} } // Remove pod from mesh: pod is not deleted, we just want to remove it from the mesh. func (s *NetServer) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) log.Debugf("Pod is now opt out... cleaning up.") openNetns := s.currentPodSnapshot.Take(string(pod.UID)) if openNetns == nil { log.Warn("failed to find pod netns")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
architecture/ambient/ztunnel.md
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Apr 25 22:35:16 GMT 2024 - 16.6K bytes - Viewed (0) -
cmd/erasure-server-pool.go
if z.SinglePool() { return z.serverPools[0].PutObject(ctx, bucket, object, data, opts) } if !opts.NoLock { ns := z.NewNSLock(bucket, object) lkctx, err := ns.GetLock(ctx, globalOperationTimeout) if err != nil { return ObjectInfo{}, err } ctx = lkctx.Context() defer ns.Unlock(lkctx) opts.NoLock = true } idx, err := z.getPoolIdxNoLock(ctx, bucket, object, data.Size())
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 80.1K bytes - Viewed (0) -
cmd/erasure-object.go
} data := r.Reader if opts.CheckPrecondFn != nil { if !opts.NoLock { ns := er.NewNSLock(bucket, object) lkctx, err := ns.GetLock(ctx, globalOperationTimeout) if err != nil { return ObjectInfo{}, err } ctx = lkctx.Context() defer ns.Unlock(lkctx) opts.NoLock = true } obj, err := er.getObjectInfo(ctx, bucket, object, opts)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 76.9K bytes - Viewed (2)