- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for good (0.36 sec)
-
istioctl/pkg/util/handlers/handlers.go
if err != nil { return "", "", err } if podName != "" { return podName, namespace, nil } // We need to pass in a sorter, and the one used by `kubectl logs` is good enough. sortBy := func(pods []*corev1.Pod) sort.Interface { return podutils.ByLogging(pods) } timeout := 2 * time.Second if getFirstPodFunc == nil { getFirstPodFunc = polymorphichelpers.GetFirstPod }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 06 15:01:41 GMT 2024 - 6.2K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
// something first, we expect to get an os.ErrDeadlineExceeded error // here if the connection is still alive. // note that unlike tcp connections, reading is a good enough test here. _, err := conn.readMessage(time.Second / 100) switch { case !errors.Is(err, os.ErrDeadlineExceeded): log.Debugf("ztunnel keepalive failed: %v", err) if errors.Is(err, io.EOF) {
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) -
istioctl/pkg/kubeinject/google.go
package kubeinject import ( "context" "fmt" "net/http" "strings" "golang.org/x/oauth2" "golang.org/x/oauth2/google" ) func isMCPAddr(addr string) bool { // A bit inexact but should be good enough. return strings.Contains(addr, ".googleapis.com/") || strings.Contains(addr, ".googleapis.com:443/") } func mcpTransport(ctx context.Context, tr http.RoundTripper) (http.RoundTripper, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// pod was added to our cache // we get here in 2 cases: // 1. new pod was created on our node // 2. we were restarted and current existing pods are added to our cache // We have no good way to distinguish between these two cases from here. But we don't need to! // Existing pods will be handled by the dataplane using `GetAmbientPods`, // and the initial enqueueNamespace, and new pods will be handled by the CNI.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
return } switch runtime.GOOS { case "linux": err = exec.Command("xdg-open", url).Start() case "windows": err = exec.Command("rundll32", "url.dll,FileProtocolHandler", url).Start() case "darwin": err = exec.Command("open", url).Start() default: fmt.Fprintf(writer, "Unsupported platform %q; open %s in your browser.\n", runtime.GOOS, url) } if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cni/pkg/install/install.go
select { case <-watcher.Events: // Something changed, and we must yield return nil case err := <-watcher.Errors: // We had a watch error - that's no good return err case <-ctx.Done(): return ctx.Err() default: // Valid configuration; set isReady to true and wait for modifications before checking again setReady(in.isReady)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
}) if err != nil { return types.NamespacedName{}, err } pods := slices.Reference(podsr.Items) if len(pods) > 0 { // We need to pass in a sorter, and the one used by `kubectl logs` is good enough. sortBy := func(pods []*corev1.Pod) sort.Interface { return podutils.ByLogging(pods) } sort.Sort(sortBy(pods)) return config.NamespacedName(pods[0]), nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
istioctl/pkg/xds/google.go
gcpCreds credentials.PerRPCCredentials project string } func (c *meshAuthCredentials) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error) { ret := map[string]string{ "x-goog-user-project": c.project, } if err := updateAuthHdrs(ctx, uri, "k8s", c.k8sCreds, ret, "x-mesh-authorization"); err != nil { return nil, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Nov 14 20:23:34 GMT 2022 - 3.4K bytes - Viewed (0)