- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Setns (0.06 sec)
-
cni/pkg/nodeagent/net.go
// in that case, try finding the netns using procfs. filter := map[types.UID]*corev1.Pod{ pod.UID: pod, } return s.scanProcForPodsAndCache(filter) } func (s *NetServer) getOrOpenNetns(pod *corev1.Pod, netNs string) (Netns, error) { if netNs == "" { return s.getNetns(pod) } return s.openNetns(pod, netNs) } func (s *NetServer) openNetns(pod *corev1.Pod, netNs string) (Netns, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K 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) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
"number of connections to ztunnel") type ZtunnelServer interface { Run(ctx context.Context) PodDeleted(ctx context.Context, uid string) error PodAdded(ctx context.Context, pod *v1.Pod, netns Netns) error Close() error } /* To clean up stale ztunnels we may need to ztunnel to send its (uid, bootid / boot time) to us so that we can remove stale entries when the ztunnel pod is deleted
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 12.3K bytes - Viewed (0) -
cni/README.md
- on pod add, determines whether pod should have netns setup to redirect to Istio proxy. See [cmdAdd](#cmdadd-workflow) for detailed logic. - it connects to K8S using the kubeconfig and JWT token copied from install-cni to get Pod and Namespace. Since this is a short-running command, each invocation creates a new connection. - If so, calls `istio-iptables` with params to setup pod netns - If ambient, sets up the ambient logic.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 03 19:29:42 UTC 2024 - 12.3K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
log.Infof("pod %s update event skipped, reason: added/labeled by CNI plugin", pod.Name) return nil } log.Debugf("pod %s now matches, adding to mesh", newPod.Name) // netns == ""; at this point netns should have been added via the initial snapshot, // or via the cni plugin. If it happens to get here before the cni plugin somehow,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
Name: testNSName, Namespace: "", Labels: map[string]string{}, }, } return fakePod, fakeNS } func (mrdir *mockInterceptRuleMgr) Program(podName, netns string, redirect *Redirect) error { mrdir.lastRedirect = append(mrdir.lastRedirect, redirect) return nil } // returns the test server URL and a dispose func for the test server
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
"--mark", inpodMark, "-j", "CONNMARK", "--set-xmark", inpodTproxyMark) // Handle healthcheck probes from the host node. In the host netns, before the packet enters the pod, we SNAT // the healthcheck packet to a fixed IP if the packet is coming from a node-local process with a socket. //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 19.9K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
log.Debugf("Setting up redirect") redirect, err := NewRedirect(pi) if err != nil { log.Errorf("redirect failed due to bad params: %v", err) return err } if err := rulesMgr.Program(podName, args.Netns, redirect); err != nil { return err } return nil } func setupLogging(conf *Config) { if conf.LogUDSAddress != "" { // reconfigure log output with tee to UDS if UDS log is enabled.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 10.7K bytes - Viewed (0) -
go.mod
github.com/spf13/viper v1.19.0 github.com/stoewer/go-strcase v1.3.0 github.com/stretchr/testify v1.9.0 github.com/vishvananda/netlink v1.2.1-beta.2.0.20240411215012-578e95cc3190 github.com/vishvananda/netns v0.0.4 github.com/yl2chen/cidranger v1.0.2 go.opentelemetry.io/otel v1.27.0 go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.27.0 go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.27.0
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 15:32:28 UTC 2024 - 10.6K bytes - Viewed (0) -
go.mod
github.com/robfig/cron/v3 v3.0.1 github.com/spf13/cobra v1.8.0 github.com/spf13/pflag v1.0.5 github.com/stretchr/testify v1.8.4 github.com/vishvananda/netlink v1.1.0 github.com/vishvananda/netns v0.0.4 go.etcd.io/etcd/api/v3 v3.5.13 go.etcd.io/etcd/client/pkg/v3 v3.5.13 go.etcd.io/etcd/client/v3 v3.5.13 go.opentelemetry.io/contrib/instrumentation/github.com/emicklei/go-restful/otelrestful v0.42.0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:11 UTC 2024 - 11.8K bytes - Viewed (0)