- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 79 for it (0.2 sec)
-
cni/pkg/pluginlistener/listener.go
// Anything other than "file not found" is an error. return nil, fmt.Errorf("failed to remove unix://%s: %v", path, err) } // Attempt to create the folder in case it doesn't exist if err := os.MkdirAll(filepath.Dir(path), 0o750); err != nil { // If we cannot create it, just warn here - we will fail later if there is a real error log.Warnf("Failed to create directory for %v: %v", path, err) } var err error
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.7K 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 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
installerScope.Debugf("Using the following manifest to install operator:\n%s\n", mstr) opts := &applyOptions{ DryRun: args.DryRun, } // If CR was passed, we must create a namespace for it and install CR into it. customResource, istioNamespace, err := getCRAndNamespaceFromFile(oiArgs.inFilename, l) if err != nil { l.LogAndFatal(err) } var iop *iopv1alpha1.IstioOperator if oiArgs.common.revision != "" {
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/util/configdump/route.go
} if lastUpdated.After(time.Unix(0, 0)) { // if a timestamp was obtained from a drc return &lastUpdated, nil } return nil, nil } // GetDynamicRouteDump retrieves a route dump with just dynamic active routes in it func (w *Wrapper) GetDynamicRouteDump(stripVersions bool) (*admin.RoutesConfigDump, error) { routeDump, err := w.GetRouteConfigDump() if err != nil { return nil, err } drc := routeDump.GetDynamicRouteConfigs()
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 3.2K 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 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 19.6K 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 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
istioctl/pkg/util/configdump/cluster.go
cluster "github.com/envoyproxy/go-control-plane/envoy/config/cluster/v3" v3 "istio.io/istio/pilot/pkg/xds/v3" ) // GetDynamicClusterDump retrieves a cluster dump with just dynamic active clusters in it func (w *Wrapper) GetDynamicClusterDump(stripVersions bool) (*admin.ClustersConfigDump, error) { clusterDump, err := w.GetClusterConfigDump() if err != nil { return nil, err }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 2.1K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
// Only runs over istioctl experimental // TODO: https://github.com/istio/istio/issues/41937 grpc.WithTransportCredentials(credentials.NewTLS( &tls.Config{ // Always skip verifying, because without it we always get "certificate signed by unknown authority". // We don't set the XDSSAN for the same reason. InsecureSkipVerify: true, })), grpc.WithPerRPCCredentials(k8sCreds), }, nil
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K 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 01 22:53:12 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 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0)