- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 34 for newWriter (0.18 sec)
-
internal/logger/logrotate.go
if err != nil { return err } defer r.Close() gw, err := os.Create(oldLgFile + ".gz") if err != nil { return err } defer gw.Close() var wc io.WriteCloser wc = gzip.NewWriter(gw) if _, err = io.Copy(wc, r); err != nil { return err } if err = wc.Close(); err != nil { return err } // Persist to disk any caches. if err = gw.Sync(); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
} func printHeader(writer io.Writer) { w := tabwriter.NewWriter(writer, 13, 1, 2, ' ', tabwriter.AlignRight) _, _ = fmt.Fprintf(w, "%40s\tTOTAL RPS\tERROR RPS\tP50 LATENCY\tP90 LATENCY\tP99 LATENCY\t\n", "WORKLOAD") _ = w.Flush() } func printMetrics(writer io.Writer, wm workloadMetrics) { w := tabwriter.NewWriter(writer, 13, 1, 2, ' ', tabwriter.AlignRight) _, _ = fmt.Fprintf(w, "%40s\t", wm.workload)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 8.4K bytes - Viewed (0) -
src/archive/tar/tar_test.go
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24K bytes - Viewed (0) -
cmd/callhome.go
return err } func createHealthJSONGzip(ctx context.Context, healthInfo madmin.HealthInfo) []byte { var b bytes.Buffer gzWriter := gzip.NewWriter(&b) header := struct { Version string `json:"version"` }{Version: healthInfo.Version} enc := json.NewEncoder(gzWriter) if e := enc.Encode(header); e != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
istioctl/pkg/writer/envoy/configdump/configdump.go
if err != nil { return err } var ( istioVersion, istioProxySha = c.getIstioVersionInfo(bootstrapDump) envoyVersion = c.getUserAgentVersionInfo(bootstrapDump) tw = tabwriter.NewWriter(c.Stdout, 0, 8, 1, ' ', 0) ) if len(istioVersion) > 0 { fmt.Fprintf(tw, "Istio Version:\t%s\n", istioVersion) } if len(istioProxySha) > 0 { fmt.Fprintf(tw, "Istio Proxy Version:\t%s\n", istioProxySha)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 29 20:46:41 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
func (gcs *warmBackendGCS) Put(ctx context.Context, key string, data io.Reader, length int64) (remoteVersionID, error) { object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)) // TODO: set storage class w := object.NewWriter(ctx) if gcs.StorageClass != "" { w.ObjectAttrs.StorageClass = gcs.StorageClass } if _, err := xioutil.Copy(w, data); err != nil { return "", gcsToObjectError(err, gcs.Bucket, key) } return "", w.Close()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.9K bytes - Viewed (0) -
cmd/post-policy_test.go
"policy": encodedPolicy, "signature": signature, "X-Amz-Ignore-AWSAccessKeyId": "", } // Create the multipart form. var buf bytes.Buffer w := multipart.NewWriter(&buf) // Set the normal formData for k, v := range formData { w.WriteField(k, v) } // Set the File formData writer, err := w.CreateFormFile("file", "upload.txt") if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
cmd/data-usage-cache.go
_, err := dst.Write([]byte{dataUsageCacheVerCurrent}) if err != nil { return err } enc, err := zstd.NewWriter(dst, zstd.WithEncoderLevel(zstd.SpeedFastest), zstd.WithWindowSize(1<<20), zstd.WithEncoderConcurrency(2)) if err != nil { return err } mEnc := msgp.NewWriter(enc) err = d.EncodeMsg(mEnc) if err != nil { return err } err = mEnc.Flush() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
src/archive/zip/reader_test.go
// if err := os.WriteFile("/tmp/biggest.zip", biggestZip, 0666); err != nil { // log.Fatal(err) // } // } // // func makeZip(name string, r io.Reader) []byte { // var buf bytes.Buffer // w := zip.NewWriter(&buf) // wf, err := w.Create(name) // if err != nil { // log.Fatal(err) // } // if _, err = io.Copy(wf, r); err != nil { // log.Fatal(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 - 55.3K bytes - Viewed (0) -
cmd/update.go
b := bytebufferpool.Get() bc := bytebufferpool.Get() defer func() { b.Reset() bc.Reset() bytebufferpool.Put(b) bytebufferpool.Put(bc) }() w, err := zstd.NewWriter(bc) if err != nil { return nil, nil, err } if _, err = io.Copy(w, io.TeeReader(reader, b)); err != nil { return nil, nil, err } w.Close() return bc.Bytes(), b.Bytes(), nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0)