- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 141 for fmt (0.17 sec)
-
istioctl/pkg/dashboard/dashboard.go
kubeClient, err := ctx.CLIClient() if err != nil { return fmt.Errorf("failed to create k8s client: %v", err) } if labelSelector == "" && len(args) < 1 { c.Println(c.UsageString()) return fmt.Errorf("specify a pod or --selector") } if labelSelector != "" && len(args) > 0 { c.Println(c.UsageString()) return fmt.Errorf("name cannot be provided when a selector is specified") }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version_test.go
}, { version: versionInvalid1, errMsg: fmt.Errorf("could not parse Malformed version: %v", versionInvalid1.GitVersion), isValid: false, }, { version: versionInvalid2, errMsg: fmt.Errorf("could not parse Malformed version: %v", versionInvalid2.GitVersion), isValid: false, }, } for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, c.version), func(t *testing.T) {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 19 02:46:48 GMT 2024 - 6.3K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener.go
if err != nil { return nil, fmt.Errorf("failed to listen on unix socket %q: %v", path, err) } // Update file permission so that cni plugin has permission to access it. if _, err := os.Stat(path); err != nil { return nil, fmt.Errorf("cni listener file %q doesn't exist", path) } if err := os.Chmod(path, 0o666); err != nil { return nil, fmt.Errorf("failed to update %q permission", path) }
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) -
operator/cmd/mesh/manifest-generate.go
b.WriteString("InFilenames: " + fmt.Sprint(a.InFilenames) + "\n") b.WriteString("OutFilename: " + a.OutFilename + "\n") b.WriteString("Set: " + fmt.Sprint(a.Set) + "\n") b.WriteString("Force: " + fmt.Sprint(a.Force) + "\n") b.WriteString("ManifestsPath: " + a.ManifestsPath + "\n") b.WriteString("Revision: " + a.Revision + "\n") b.WriteString("Components: " + fmt.Sprint(a.Components) + "\n") return b.String()
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/policies.go
slices.SortFunc(pols, func(a, b *ZtunnelPolicy) int { if r := cmp.Compare(a.Namespace, b.Namespace); r != 0 { return r } return cmp.Compare(a.Name, b.Name) }) fmt.Fprintln(w, "NAMESPACE\tPOLICY NAME\tACTION\tSCOPE") for _, pol := range pols { fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", pol.Namespace, pol.Name, pol.Action, pol.Scope) } return w.Flush() }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
} return "", fmt.Errorf("no valid networks found in %s", confDir) } // newCNIConfig = istio-cni config, that should be inserted into existingCNIConfig func insertCNIConfig(newCNIConfig, existingCNIConfig []byte) ([]byte, error) { var istioMap map[string]any err := json.Unmarshal(newCNIConfig, &istioMap) if err != nil { return nil, fmt.Errorf("error loading Istio CNI config (JSON error): %v", err)
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) -
cni/pkg/nodeagent/ztunnelserver.go
var _ ZtunnelServer = &ztunnelServer{} func newZtunnelServer(addr string, pods PodNetnsCache) (*ztunnelServer, error) { if addr == "" { return nil, fmt.Errorf("addr cannot be empty") } resolvedAddr, err := net.ResolveUnixAddr("unixpacket", addr) if err != nil { return nil, fmt.Errorf("failed to resolve unix addr: %w", err) } // remove potentially existing address
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/xds/client.go
InsecureSkipVerify: opts.InsecureSkipVerify, XDSSAN: opts.XDSSAN, GrpcOpts: grpcOpts, }, }, nil) if err != nil { return nil, fmt.Errorf("could not dial: %w", err) } err = adscConn.Run() if err != nil { return nil, fmt.Errorf("ADSC: failed running %v", err) } err = adscConn.Send(dr) if err != nil { return nil, err }
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) -
istioctl/pkg/writer/pilot/status.go
w := new(tabwriter.Writer).Init(s.Writer, 0, 8, 5, ' ', 0) _, _ = fmt.Fprintln(w, "NAME\tCLUSTER\tCDS\tLDS\tEDS\tRDS\tECDS\tISTIOD\tVERSION") for _, dr := range drs { for _, resource := range dr.Resources { clientConfig := xdsstatus.ClientConfig{} err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err) }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
func (cfg *IptablesConfigurator) appendInpodRules(hostProbeSNAT *netip.Addr) *builder.IptablesRuleBuilder { redirectDNS := cfg.cfg.RedirectDNS inpodMark := fmt.Sprintf("0x%x", InpodMark) + "/" + fmt.Sprintf("0x%x", InpodMask) inpodTproxyMark := fmt.Sprintf("0x%x", InpodTProxyMark) + "/" + fmt.Sprintf("0x%x", InpodTProxyMask) iptablesBuilder := builder.NewIptablesRuleBuilder(ipbuildConfig(cfg.cfg)) // Insert jumps to our custom chains
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)