- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 73 for Writer (0.17 sec)
-
istioctl/pkg/writer/compare/sds/writer.go
} // NewSDSWriter generates a new instance which conforms to SDSWriter interface func NewSDSWriter(w io.Writer, format Format) SDSWriter { return &sdsWriter{ w: w, output: format, } } // sdsWriter is provided concrete implementation of SDSWriter type sdsWriter struct { w io.Writer output Format }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 21 14:17:23 GMT 2023 - 4.1K bytes - Viewed (0) -
istioctl/pkg/writer/table/writer.go
"io" "strings" "unicode/utf8" "github.com/fatih/color" ) type ColoredTableWriter struct { writer io.Writer header Row rows []Row addRowFunc func(obj interface{}) Row } func NewStyleWriter(writer io.Writer) *ColoredTableWriter { return &ColoredTableWriter{ writer: writer, rows: make([]Row, 0), header: Row{}, } } type BuildRowFunc func(obj interface{}) Row
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Oct 08 04:41:42 GMT 2022 - 2.8K bytes - Viewed (0) -
istioctl/pkg/writer/table/writer_test.go
Xiaopeng Han <******@****.***> 1665204102 +0800
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Oct 08 04:41:42 GMT 2022 - 1.6K bytes - Viewed (0) -
istioctl/pkg/writer/compare/sds/writer_test.go
t.Helper() for _, expected := range expected { if !strings.Contains(output, expected) { t.Errorf("expected %s included in writer output, did not find", expected) } } for _, unexpected := range unexpected { if strings.Contains(output, unexpected) { t.Errorf("unexpected string %s included in writer output", unexpected) } }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri May 29 20:42:01 GMT 2020 - 4.9K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
if len(mappedResp) > 0 { mresp, err := json.MarshalIndent(mappedResp, "", " ") if err != nil { return nil, nil, err } _, _ = s.Writer.Write(mresp) _, _ = s.Writer.Write([]byte("\n")) } return w, fullStatus, nil } func xdsStatusPrintln(w io.Writer, status *xdsWriterStatus) error { _, err := fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\t%v\t%v\t%v\n", status.proxyID, status.clusterID,
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/util/common.go
Err error } func (c CommandParseError) Error() string { return c.Err.Error() } // Confirm waits for a user to confirm with the supplied message. func Confirm(msg string, writer io.Writer) bool { for { _, _ = fmt.Fprintf(writer, "%s ", msg) var response string _, err := fmt.Scanln(&response) if err != nil { return false } switch strings.ToUpper(response) { case "Y", "YES": return true
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.6K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
signal.Notify(signals, os.Interrupt) defer signal.Stop(signals) <-signals fw.Close() }() } func openBrowser(url string, writer io.Writer, browser bool) { var err error fmt.Fprintf(writer, "%s\n", url) if !browser { fmt.Fprint(writer, "skipping opening a browser") return } switch runtime.GOOS { case "linux": err = exec.Command("xdg-open", url).Start()
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/clusters.go
}, } opts.AttachControlPlaneFlags(cmd) return cmd } func writeMulticlusterStatus(out io.Writer, input map[string][]byte) error { statuses, err := parseClusterStatuses(input) if err != nil { return err } w := new(tabwriter.Writer).Init(out, 0, 8, 5, ' ', 0) _, _ = fmt.Fprintln(w, "NAME\tSECRET\tSTATUS\tISTIOD") for istiod, clusters := range statuses {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 2.3K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/policies.go
"cmp" "encoding/json" "fmt" "strings" "sigs.k8s.io/yaml" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/slices" ) // PolicyFilter is used to pass filter information into service based config writer print functions type PolicyFilter struct { Namespace string } // Verify returns true if the passed workload matches the filter fields func (wf *PolicyFilter) Verify(pol *ZtunnelPolicy) bool {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
return filtered[i].Name < filtered[j].Name }) return filtered, nil } func printNS(writer io.Writer, namespaces []corev1.Namespace, hooks []admitv1.MutatingWebhookConfiguration, allPods map[resource.Namespace][]corev1.Pod, ) error { outputCount := 0 w := new(tabwriter.Writer).Init(writer, 0, 8, 1, ' ', 0) for _, namespace := range namespaces { revision := getInjectedRevision(&namespace, hooks)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Jan 04 03:08:06 GMT 2024 - 10.4K bytes - Viewed (0)