- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for it (0.16 sec)
-
cni/pkg/nodeagent/net.go
openNetns := s.currentPodSnapshot.Get(string(pod.UID)) if openNetns != nil { return openNetns, nil } log.Debug("pod netns was not found, trying to find it using procfs") // this can happen if the pod was dynamically added to the mesh after it was created. // in that case, try finding the netns using procfs. if err := s.rescanPod(pod); err != nil { log.Errorf("error scanning proc: error was %s", err)
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) -
operator/cmd/mesh/manifest_shared_test.go
const ( goldenFileSuffixHideChangesInReview = ".golden.yaml" goldenFileSuffixShowChangesInReview = ".golden-show-in-gh-pull-request.yaml" ) var ( // By default, tests only run with manifest generate, since it doesn't require any external fake test environment. testedManifestCmds = []cmdType{cmdGenerate} // Only used if kubebuilder is installed. testenv *envtest.Environment testClient client.Client
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
istioctl/pkg/multixds/gather.go
break GetProxyLoop } namespacedName := pod.Name + "." + pod.Namespace if visited[namespacedName] { // If we already have information about the pod, skip it. continue } resp, err := queryToOnePod(&pod) if err != nil { fmt.Fprintf(os.Stderr, "Skip the agent in Pod %s due to the error: %s\n", namespacedName, err.Error()) continue }
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) -
istioctl/pkg/writer/envoy/configdump/listener.go
switch v := match.GetOnNoMatch().GetOnMatch().(type) { case *matcher.Matcher_OnMatch_Action: if v.Action.GetName() == name { // TODO this only makes sense in context of a chain... do we need a way to give it context return []string{"ANY"}, true } case *matcher.Matcher_OnMatch_Matcher: ms, f := recurse(name, v.Matcher) if !f { return []string{"NONE"}, true } return ms, true }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
return cniConfigFilepath, err } if cfg.chainedCNIPlugin && strings.HasSuffix(cniConfigFilepath, ".conf") { // If the old CNI config filename ends with .conf, rename it to .conflist, because it has to be changed to a list installLog.Infof("Renaming %s extension to .conflist", cniConfigFilepath) err = os.Rename(cniConfigFilepath, cniConfigFilepath+"list") if err != nil {
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) -
cni/pkg/iptables/iptables.go
// a local node socket". If the latter, outside the pod in the host netns, redirect that traffic to a hardcoded/custom proxy // healthcheck port, just like we used to. Otherwise, we can't assume it's local-node privileged traffic, and will capture and process it normally. // // All this is necessary because quite often apps use the same port for healthchecks as they do for reg. traffic, and // we cannot make assumptions there.
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/ztunnelserver.go
or when the ztunnel pod is restarted in the same pod (remove old entries when the same uid connects again, but with different boot id?) save a queue of what needs to be sent to the ztunnel pod and send it one by one when it connects. when a new ztunnel connects with different uid, only propagate deletes to older ztunnels. */ type connMgr struct { connectionSet map[*ZtunnelConnection]struct{} latestConn *ZtunnelConnection
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/test/install_cni.go
cp(wd+k8sSvcAcctSubDir+f, tempK8sSvcAcctDir+"/"+f, t) } t.Logf("Finished pre-populating working dirs") } // create an install server instance and run it, blocking until it gets terminated // via context cancellation func startInstallServer(ctx context.Context, serverConfig *config.Config, t *testing.T) { readyFlag := &atomic.Value{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
assert.NoError(t, err) fakeIPSetDeps.AssertExpectations(t) } // for tests that call `runtime.GC()` - we have no control over when the GC is actually scheduled, // and it is flake-prone to check for closure after calling it, this retries for a bit to make // sure the netns is closed eventually. func assertNSClosed(t *testing.T, closed *atomic.Bool) { for i := 0; i < 5; i++ { if closed.Load() { return }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
testDoAddRun(t, cniConf, excludedNS, pod, ns) wasCalled := serverClose() // If the pod is being added to a namespace that is explicitly excluded by plugin config denylist // it should never be added, even if the namespace has the annotation assert.Equal(t, wasCalled, false) } func TestCmdAdd(t *testing.T) { pod, ns := buildFakePodAndNSForClient()
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)