- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 112 for Writer (0.16 sec)
-
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 May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.6K bytes - Viewed (0) -
internal/s3select/sql/record.go
type Record interface { Get(name string) (*Value, error) // Set a value. // Can return a different record type. Set(name string, value *Value) (Record, error) WriteCSV(writer io.Writer, opts WriteCSVOpts) error WriteJSON(writer io.Writer) error // Clone the record and if possible use the destination provided. Clone(dst Record) Record Reset() // Returns underlying representation
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 3.4K bytes - Viewed (0) -
internal/config/subnet/subnet.go
} var body bytes.Buffer writer := multipart.NewWriter(&body) part, e := writer.CreateFormFile("file", filename) if e != nil { return "", e } if _, e = part.Write(payload); e != nil { return "", e } writer.Close() r, e := http.NewRequest(http.MethodPost, reqURL, &body) if e != nil { return "", e } r.Header.Add("Content-Type", writer.FormDataContentType()) return c.submitPost(r)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 27 16:35:36 GMT 2023 - 2.9K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
) // Comparator diffs between a config dump from Istiod and one from Envoy type Comparator struct { envoy, istiod *configdump.Wrapper w io.Writer context int location string } // NewComparator is a comparator constructor func NewComparator(w io.Writer, istiodResponses map[string][]byte, envoyResponse []byte) (*Comparator, error) { c := &Comparator{} for _, resp := range istiodResponses {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 3.7K bytes - Viewed (1) -
istioctl/pkg/checkinject/checkinject.go
return cmd } func printCheckInjectorResults(writer io.Writer, was []webhookAnalysis) error { if len(was) == 0 { fmt.Fprintf(writer, "ERROR: no Istio injection hooks present.\n") return nil } w := table.NewStyleWriter(writer) w.SetAddRowFunc(func(obj interface{}) table.Row { wa := obj.(webhookAnalysis) row := table.Row{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
istioctl/pkg/util/formatting/formatter.go
} func colorSuffix(colorize bool) string { if !colorize { return "" } return "\033[0m" } func IstioctlColorDefault(writer io.Writer) bool { if strings.EqualFold(termEnvVar.Get(), "dumb") { return false } file, ok := writer.(*os.File) if ok { if !isatty.IsTerminal(file.Fd()) { return false } } return true
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 11 02:41:45 GMT 2023 - 3.1K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig_test.go
} }) } } func resourceHandler(writer http.ResponseWriter, request *http.Request) { const getResponse = `{"name":"resource","description":"Core resource model scope","output_level":"info","stack_trace_level":"none","log_callers":false}` switch request.Method { case http.MethodGet: _, _ = writer.Write([]byte(getResponse)) } } func adsHandler(writer http.ResponseWriter, request *http.Request) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 6.2K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/certificates.go
func (c *ConfigWriter) PrintSecretSummary() error { if c.ztunnelDump == nil { return fmt.Errorf("config writer has not been primed") } secretDump := c.ztunnelDump.Certificates w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 5, ' ', 0) fmt.Fprintln(w, "CERTIFICATE NAME\tTYPE\tSTATUS\tVALID CERT\tSERIAL NUMBER\tNOT AFTER\tNOT BEFORE") for _, secret := range secretDump {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 3.2K bytes - Viewed (0) -
internal/ioutil/discard.go
// implementation which is buggy on NUMA systems, we have to use a simpler // io.Writer implementation alone avoids also unnecessary buffer copies, // and as such incurred latencies. var Discard io.Writer = discard{} // discard is /dev/null for Golang. type discard struct{} func (discard) Write(p []byte) (int, error) { return len(p), nil } // DiscardReader discarded reader
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 1.3K bytes - Viewed (0) -
internal/crypto/sse.go
partKey := key.DerivePartKey(uint32(partID)) return EncryptSinglePart(r, ObjectKey(partKey)) } // DecryptSinglePart decrypts an io.Writer which must an object // uploaded with the single-part PUT API. The offset and length // specify the requested range. func DecryptSinglePart(w io.Writer, offset, length int64, key ObjectKey) io.WriteCloser { const PayloadSize = 1 << 16 // DARE 2.0 w = ioutil.LimitedWriter(w, offset%PayloadSize, length)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 4.4K bytes - Viewed (0)