- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for Dost (0.12 sec)
-
cni/pkg/nodeagent/net.go
go s.ztunnelServer.Run(ctx) } func (s *NetServer) Stop() { log.Debug("removing host iptables rules") s.iptablesConfigurator.DeleteHostRules() log.Debug("destroying host ipset") s.hostsideProbeIPSet.Flush() if err := s.hostsideProbeIPSet.DestroySet(); err != nil { log.Warnf("could not destroy host ipset on shutdown") } log.Debug("stopping ztunnel server") s.ztunnelServer.Close() }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/repair/netns.go
"istio.io/istio/pkg/log" ) func getPidNamespace(pid int) string { return "/host/proc/" + strconv.Itoa(pid) + "/ns/net" } func runInHost[T any](f func() (T, error)) (T, error) { var res T ns, err := netns.GetNS(getPidNamespace(1)) if err != nil { return res, fmt.Errorf("failed to get host network: %v", err) } err = ns.Do(func(ns netns.NetNS) error { var err error res, err = f()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers_test.go
}, { proxyName: "istio-security-post-install-1.2.2-bm9w2.istio-system", namespace: "istio-system", wantPodName: "istio-security-post-install-1.2.2-bm9w2", wantNamespace: "istio-system", }, { proxyName: "istio-security-post-install-1.2.2-bm9w2.istio-system", namespace: "", wantPodName: "istio-security-post-install-1.2.2-bm9w2", wantNamespace: "istio-system", }, {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 6.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
} // Create hostprobe rules now, in the host netns // Later we will reuse this same configurator inside the pod netns for adding other rules iptablesConfigurator.DeleteHostRules() if err := iptablesConfigurator.CreateHostRulesForHealthChecks(&HostProbeSNATIP, &HostProbeSNATIPV6); err != nil { return nil, fmt.Errorf("error initializing the host rules for health checks: %w", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
) (map[string]*discovery.DiscoveryResponse, error) { return MultiRequestAndProcessXds(false, dr, centralOpts, istioNamespace, ns, serviceAccount, kubeClient, options) } type xdsAddr struct { gcpProject, host, istiod string } func getXdsAddressFromWebhooks(client kube.CLIClient) (*xdsAddr, error) {
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/pod_cache.go
nspathInContainer := filepath.Join(hostMountsPath, nspath) ns, err := OpenNetns(nspathInContainer) if err != nil { err = fmt.Errorf("failed to open netns: %w. Make sure that the netns host path %s is mounted in under %s in the container", err, nspath, hostMountsPath) log.Error(err.Error()) } return ns, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// within all pods as we do on the host. // // This should be fine, as the host binaries are all we have to work with here anyway, // as we are running within a privileged container - and we don't want to take the time to // redetect for each pod anyway. // // Extreme corner case: // If for some reason your host had both binaries, and you were injecting out-of-band
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
}, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}} client := kube.NewFakeClient(ns, pod) // We are expecting at most 1 calls to the mock, wait for them wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), "", ).Return(nil)
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) -
cni/pkg/install/kubeconfig_test.go
expectedFailure bool k8sServiceProtocol string k8sServiceHost string k8sServicePort string kubeCAFilepath string skipTLSVerify bool }{ { name: "k8s service host not set", expectedFailure: true, }, { name: "k8s service port not set", expectedFailure: true, k8sServiceHost: k8sServiceHost, }, { name: "skip TLS verify",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 03:52:24 GMT 2024 - 5.1K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBECONFIG_FILEPATH__", filepath.Join(vars.cniNetDir, vars.kubeconfigFilename)) cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBERNETES_SERVICE_HOST__", vars.k8sServiceHost) cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBERNETES_SERVICE_PORT__", vars.k8sServicePort) cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBERNETES_NODE_NAME__", vars.k8sNodeName)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0)