- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 101 for Writer (0.15 sec)
-
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 May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 04 03:08:06 GMT 2024 - 10.4K bytes - Viewed (0) -
src/archive/zip/zip_test.go
} for i := 0; i < chunks; i++ { _, err := f.Write(chunk) if err != nil { t.Fatal("write chunk:", err) } } if frag := int(size % chunkSize); frag > 0 { _, err := f.Write(chunk[:frag]) if err != nil { t.Fatal("write chunk:", err) } } end := []byte("END\n") _, err = f.Write(end) if err != nil { t.Fatal("write end:", err) } if err := w.Close(); err != nil {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Mar 27 18:23:49 GMT 2024 - 19.5K bytes - Viewed (0) -
internal/s3select/select.go
} func (s3Select *S3Select) marshal(buf *bytes.Buffer, record sql.Record) error { switch s3Select.Output.format { case csvFormat: // Use bufio Writer to prevent csv.Writer from allocating a new buffer. bufioWriter := bufioWriterPool.Get().(*bufio.Writer) defer func() { bufioWriter.Reset(xioutil.Discard) bufioWriterPool.Put(bufioWriter) }() bufioWriter.Reset(buf) opts := sql.WriteCSVOpts{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
} } fmt.Fprintln(c.Stdout, string(out)) return nil } func (c *ConfigWriter) setupListenerConfigWriter() (*tabwriter.Writer, []*listener.Listener, error) { listeners, err := c.retrieveSortedListenerSlice() if err != nil { return nil, nil, err } w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 1, ' ', 0) return w, listeners, nil }
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) -
internal/grid/msg_gen.go
} // EncodeMsg implements msgp.Encodable func (z *connectReq) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "ID" err = en.Append(0x82, 0xa2, 0x49, 0x44) if err != nil { return } err = en.WriteBytes((z.ID)[:]) if err != nil { err = msgp.WrapError(err, "ID") return } // write "Host" err = en.Append(0xa4, 0x48, 0x6f, 0x73, 0x74) if err != nil { return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 18.8K bytes - Viewed (0) -
cmd/object-api-datatypes.go
// User-Defined object tags UserTags string // List of individual parts, maximum size of upto 10,000 Parts []ObjectPartInfo `json:"-"` // Implements writer and reader used by CopyObject API Writer io.WriteCloser `json:"-" msg:"-"` Reader *hash.Reader `json:"-" msg:"-"` PutObjReader *PutObjReader `json:"-" msg:"-"` metadataOnly bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
cmd/metacache_gen.go
} // EncodeMsg implements msgp.Encodable func (z *metacache) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 13 // write "end" err = en.Append(0x8d, 0xa3, 0x65, 0x6e, 0x64) if err != nil { return } err = en.WriteTime(z.ended) if err != nil { err = msgp.WrapError(err, "ended") return } // write "st" err = en.Append(0xa2, 0x73, 0x74) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 08 18:26:08 GMT 2021 - 10K bytes - Viewed (0) -
cmd/batch-job-common-types_gen.go
return } // EncodeMsg implements msgp.Encodable func (z BatchJobKV) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "Key" err = en.Append(0x82, 0xa3, 0x4b, 0x65, 0x79) if err != nil { return } err = en.WriteString(z.Key) if err != nil { err = msgp.WrapError(err, "Key") return } // write "Value" err = en.Append(0xa5, 0x56, 0x61, 0x6c, 0x75, 0x65) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 21.9K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
return fmt.Sprintf("no running Istio pods in %q", c.Namespace) } var _ error = ControlPlaneNotFoundError{} type Options struct { // MessageWriter is a writer for displaying messages to users. MessageWriter io.Writer // XdsViaAgents accesses Istiod via the tap service of each agent. // This is only used in `proxy-status` command. XdsViaAgents bool
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/ztunnelconfig/ztunnelconfig.go
return debug, err } func setupConfigdumpZtunnelConfigWriter(debug []byte, out io.Writer) (*ztunnelDump.ConfigWriter, error) { cw := &ztunnelDump.ConfigWriter{Stdout: out, FullDump: debug} err := cw.Prime(debug) if err != nil { return nil, err } return cw, nil } func setupFileZtunnelConfigdumpWriter(filename string, out io.Writer) (*ztunnelDump.ConfigWriter, error) { data, err := readFile(filename) if err != 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)