- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 42 for fmt (0.4 sec)
-
istioctl/pkg/waypoint/waypoint.go
break } if time.Since(startTime) > waitTimeout { errorMsg := fmt.Sprintf("timed out while waiting for waypoint %v/%v", gw.Namespace, gw.Name) if err != nil { errorMsg += fmt.Sprintf(": %s", err) } return fmt.Errorf(errorMsg) } } } fmt.Fprintf(cmd.OutOrStdout(), "waypoint %v/%v applied\n", gw.Namespace, gw.Name)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
if len(args) == 0 { return fmt.Errorf("must provide a tag for modification") } if len(args) > 1 { return fmt.Errorf("must provide a single tag for creation") } return nil }, RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClient() if err != nil { return fmt.Errorf("failed to create Kubernetes client: %v", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
}) for _, match := range matches { if includeConfigType { name := fmt.Sprintf("listener/%s", l.Name) fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\n", name, strings.Join(addresses, ","), port, match.match, match.destination) } else { fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", strings.Join(addresses, ","), port, match.match, match.destination) } } } else {
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/plugin/sidecar_redirect.go
case redirectModeREDIRECT: case redirectModeTPROXY: default: return fmt.Errorf("interceptionMode invalid: %v", mode) } return nil } func validateCIDRList(cidrs string) error { if len(cidrs) > 0 { for _, cidr := range strings.Split(cidrs, ",") { if _, err := netip.ParsePrefix(cidr); err != nil { return fmt.Errorf("failed parsing cidr '%s': %v", cidr, err) } } } return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.6K bytes - Viewed (0) -
istioctl/pkg/tag/generate_test.go
}, Webhooks: []admitv1.MutatingWebhook{ { Name: fmt.Sprintf("namespace.%s", istioInjectionWebhookSuffix), ClientConfig: admitv1.WebhookClientConfig{ Service: &admitv1.ServiceReference{ Namespace: "default", Name: "istiod", }, CABundle: []byte("ca"), }, }, { Name: fmt.Sprintf("object.%s", istioInjectionWebhookSuffix),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 12.1K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
if protocol.Parse(ap.(string)).IsUnsupported() { errs = multierror.Append(errs, fmt.Errorf("service %q doesn't follow Istio protocol selection. "+ "This is not recommended, See "+url.ProtocolSelection, fmt.Sprintf("%s/%s/:", un.GetName(), un.GetNamespace()))) } } else { if p["name"] == nil { errs = multierror.Append(errs, fmt.Errorf("service %q has an unnamed port. This is not recommended,"+
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
// If there is a specific pod name in ResourceName, use the agent in the pod. if len(dr.ResourceNames) != 1 { return nil, fmt.Errorf("`ResourceNames` must have one element when `all` flag is turned on") } slice := strings.SplitN(dr.ResourceNames[0], ".", 2) if len(slice) != 2 { return nil, fmt.Errorf("invalid resource name format: %v", slice) } podName := slice[0] ns := slice[1]
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/admin/istiodconfig.go
}, ) } switch ga.outputFormat { case "short": w := new(tabwriter.Writer).Init(out, 0, 8, 3, ' ', 0) _, _ = fmt.Fprintln(w, "ACTIVE SCOPE\tDESCRIPTION\tLOG LEVEL") for _, sll := range resultScopeLogLevel { _, _ = fmt.Fprintf(w, "%s\t%s\t%s\n", sll.ScopeName, sll.Description, sll.LogLevel) } return w.Flush() case "json", "yaml":
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
if err != nil { return nil, err } namespace, selector, err := polymorphichelpers.SelectorsForObject(svc) if err != nil { if e.injectorAddress == "" { return nil, fmt.Errorf("cannot attach to %T: %v", svc, err) } address = fmt.Sprintf("https://%s:%d%s", e.injectorAddress, *cc.Service.Port, *cc.Service.Path) } else { pod, err := GetFirstPod(e.client.Kube().CoreV1(), namespace, selector.String()) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
operator/cmd/mesh/install.go
b.WriteString("InFilenames: " + fmt.Sprint(a.InFilenames) + "\n") b.WriteString("ReadinessTimeout: " + fmt.Sprint(a.ReadinessTimeout) + "\n") b.WriteString("SkipConfirmation: " + fmt.Sprint(a.SkipConfirmation) + "\n") b.WriteString("Force: " + fmt.Sprint(a.Force) + "\n") b.WriteString("Verify: " + fmt.Sprint(a.Verify) + "\n") b.WriteString("Set: " + fmt.Sprint(a.Set) + "\n")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1)