Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 91 for newWriter (0.1 sec)

  1. cmd/mrf.go

    		go func() {
    			// Initialize MRF meta header.
    			var data [4]byte
    			binary.LittleEndian.PutUint16(data[0:2], healMRFMetaFormat)
    			binary.LittleEndian.PutUint16(data[2:4], healMRFMetaVersionV1)
    			mw := msgp.NewWriter(w)
    			n, err := mw.Write(data[:])
    			if err != nil {
    				w.CloseWithError(err)
    				return
    			}
    			if n != len(data) {
    				w.CloseWithError(io.ErrShortWrite)
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. cmd/warm-backend-gcs.go

    func (gcs *warmBackendGCS) PutWithMeta(ctx context.Context, key string, data io.Reader, length int64, meta map[string]string) (remoteVersionID, error) {
    	object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key))
    	w := object.NewWriter(ctx)
    	if gcs.StorageClass != "" {
    		w.ObjectAttrs.StorageClass = gcs.StorageClass
    	}
    	w.ObjectAttrs.Metadata = meta
    	if _, err := xioutil.Copy(w, data); err != nil {
    		return "", gcsToObjectError(err, gcs.Bucket, key)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. 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)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Feb 29 20:46:41 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  4. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/io/CharSourceTest.java

          assertThrows(IOException.class, () -> okSource.copyTo(new TestCharSink(option)));
          // ensure reader was closed IF it was opened (depends on implementation whether or not it's
          // opened at all if sink.newWriter() throws).
          assertTrue(
              "stream not closed when copying to sink with option: " + option,
              !okSource.wasStreamOpened() || okSource.wasStreamClosed());
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 07 15:26:58 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/CharSourceTest.java

          assertThrows(IOException.class, () -> okSource.copyTo(new TestCharSink(option)));
          // ensure reader was closed IF it was opened (depends on implementation whether or not it's
          // opened at all if sink.newWriter() throws).
          assertTrue(
              "stream not closed when copying to sink with option: " + option,
              !okSource.wasStreamOpened() || okSource.wasStreamClosed());
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  7. src/archive/tar/writer.go

    	// err is a persistent error.
    	// It is only the responsibility of every exported method of Writer to
    	// ensure that this error is sticky.
    	err error
    }
    
    // NewWriter creates a new Writer writing to w.
    func NewWriter(w io.Writer) *Writer {
    	return &Writer{w: w, curr: &regFileWriter{w, 0}}
    }
    
    type fileWriter interface {
    	io.Writer
    	fileState
    
    	ReadFrom(io.Reader) (int64, error)
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  8. cmd/post-policy_test.go

    		"signature": signature,
    	}
    
    	for key, value := range formInputData {
    		formData[key] = value
    	}
    
    	// 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. 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 {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 55.6K bytes
    - Viewed (0)
  10. cmd/admin-handlers.go

    	// Write a version for making *incompatible* changes.
    	// The AdminClient will reject any version it does not know.
    	var inspectZipW *zip.Writer
    	if publicKey != nil {
    		w.WriteHeader(200)
    		stream := estream.NewWriter(w)
    		defer stream.Close()
    
    		clusterKey, err := bytesToPublicKey(getSubnetAdminPublicKey())
    		if err != nil {
    			bugLogIf(ctx, stream.AddError(err.Error()))
    			return
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
Back to top