- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 60 for geturl (0.45 sec)
-
cni/pkg/nodeagent/fakes_test.go
// the fake inode is the fd! magic. return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: uint64(fd)} } func newFakeNsInode(fd uintptr, inode uint64) *fakeNs { return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: inode} } // Fd returns the file descriptor func (f *fakeNs) Fd() uintptr { return f.fd } func (f *fakeNs) Inode() uint64 { return f.inode }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
if err != nil { return nil, nil } uid, _, err := GetPodUIDAndContainerID(cgroupData) if err != nil { return nil, err } if filter != nil && !filter.Contains(uid) { return nil, nil } netns, err := proc.Open(netnsName) if err != nil { return nil, err } fd, err := GetFd(netns) if err != nil { netns.Close() return nil, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
istioctl/pkg/cli/context.go
return i.clients[rev], nil } func (i *instance) CLIClient() (kube.CLIClient, error) { return i.CLIClientWithRevision("") } func (i *instance) InferPodInfoFromTypedResource(name, namespace string) (pod string, ns string, err error) { client, err := i.CLIClient() if err != nil { return "", "", err } return handlers.InferPodInfoFromTypedResource(name, i.NamespaceOrDefault(namespace), MakeKubeFactory(client)) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 6.4K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
return err } if err := createClusterEnv(wg, proxyConfig, istioNamespace, revision, internalIP, externalIP, outputDir); err != nil { return err } if err := createCertsTokens(kubeClient, wg, outputDir, out); err != nil { return err } if err := createHosts(kubeClient, istioNamespace, ingressIP, outputDir, revision); err != nil { return err } return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
istioctl/pkg/version/version.go
} return remInfo, err } } func getProxyInfoWrapper(ctx cli.Context, opts *clioptions.ControlPlaneOptions) func() (*[]istioVersion.ProxyInfo, error) { return func() (*[]istioVersion.ProxyInfo, error) { client, err := ctx.CLIClientWithRevision(opts.Revision) if err != nil { return nil, err } return proxy.GetProxyInfo(client, ctx.IstioNamespace()) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.3K bytes - Viewed (0) -
istioctl/pkg/cli/mock_client.go
"istio.io/istio/pkg/kube" ) type MockPortForwarder struct{} func (m MockPortForwarder) Start() error { return nil } func (m MockPortForwarder) Address() string { return "localhost:3456" } func (m MockPortForwarder) Close() { } func (m MockPortForwarder) ErrChan() <-chan error { return make(chan error) } func (m MockPortForwarder) WaitForStop() { }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 2.1K bytes - Viewed (0) -
istioctl/pkg/writer/compare/route.go
if err != nil { return err } envoyBytes.WriteString(envoy) } istiodRouteDump, err := c.istiod.GetDynamicRouteDump(true) if err != nil { istiodBytes.WriteString(err.Error()) } else { istiod, err := protomarshal.ToJSONWithAnyResolver(istiodRouteDump, " ", &envoyResolver) if err != nil { return err } istiodBytes.WriteString(istiod) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Mar 12 10:02:09 GMT 2024 - 2.3K bytes - Viewed (0) -
cni/pkg/nodeagent/healthServer.go
router.HandleFunc(constants.ReadinessEndpoint, readyz(installReady, watchReady)) return } func healthz(w http.ResponseWriter, _ *http.Request) { w.WriteHeader(http.StatusOK) } func readyz(installReady, watchReady *atomic.Value) http.HandlerFunc { return func(w http.ResponseWriter, _ *http.Request) { if !installReady.Load().(bool) || !watchReady.Load().(bool) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 1.8K bytes - Viewed (0) -
istioctl/cmd/root.go
err := viper.ReadInConfig() // Ignore errors reading the configuration unless the file is explicitly customized if root.IstioConfig != defaultIstioctlConfig { return err } return nil } func init() { viper.SetDefault("istioNamespace", constants.IstioSystemNamespace) viper.SetDefault("xds-port", 15012) } // GetRootCmd returns the root of the cobra command-tree.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 11 20:51:30 GMT 2024 - 10K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
if err := os.MkdirAll(dir, 0o755); err != nil { return err } } outFile, err := os.Create(dest) if err != nil { return fmt.Errorf("create: %v", err) } if _, err := io.Copy(outFile, tarReader); err != nil { return fmt.Errorf("copy: %v", err) } outFile.Close() default: return fmt.Errorf("unknown type: %v in %v", header.Typeflag, header.Name) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0)