Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 187 for reader_r (0.17 sec)

  1. cmd/storage-datatypes_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BaseOptions) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  2. cmd/storage-rest-server.go

    // has been used.
    // The returned reader contains the payload.
    func waitForHTTPResponse(respBody io.Reader) (io.Reader, error) {
    	reader := bufio.NewReader(respBody)
    	for {
    		b, err := reader.ReadByte()
    		if err != nil {
    			return nil, err
    		}
    		// Check if we have a response ready or a filler byte.
    		switch b {
    		case 0:
    			return reader, nil
    		case 1:
    			errorText, err := io.ReadAll(reader)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    		apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, err)
    		writeErrorResponse(ctx, w, apiErr, r.URL)
    		return
    	}
    
    	const mapEntryOverhead = 200
    
    	var (
    		reader        io.Reader
    		actualSize    int64 = -1
    		fileName      string
    		fanOutEntries = make([]minio.PutObjectFanOutEntry, 0, 100)
    	)
    
    	maxParts := 1000
    	// Canonicalize the form values into http.Header.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  4. docs/debugging/inspect/decrypt-v2.go

    package main
    
    import (
    	"errors"
    	"fmt"
    	"io"
    	"os"
    
    	"github.com/minio/madmin-go/v3/estream"
    )
    
    type keepFileErr struct {
    	error
    }
    
    func extractInspectV2(pk []byte, r io.Reader, w io.Writer, okMsg string) error {
    	privKey, err := bytesToPrivateKey(pk)
    	if err != nil {
    		return fmt.Errorf("decoding key returned: %w", err)
    	}
    
    	sr, err := estream.NewReader(r)
    	if err != nil {
    		return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 11 21:22:47 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  5. cmd/bucket-replication-utils_gen.go

    import (
    	"github.com/minio/minio/internal/bucket/replication"
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BucketReplicationResyncStatus) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 61.1K bytes
    - Viewed (0)
  6. cmd/bucket-encryption.go

    	return sseCfg, err
    }
    
    // validateBucketSSEConfig parses bucket encryption configuration and validates if it is supported by MinIO.
    func validateBucketSSEConfig(r io.Reader) (*sse.BucketSSEConfig, error) {
    	encConfig, err := sse.ParseBucketSSEConfig(r)
    	if err != nil {
    		return nil, err
    	}
    
    	if len(encConfig.Rules) == 1 {
    		return encConfig, nil
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  7. docs/debugging/inspect/decrypt-v1.go

    package main
    
    import (
    	"encoding/binary"
    	"encoding/hex"
    	"fmt"
    	"hash/crc32"
    	"io"
    
    	"github.com/secure-io/sio-go"
    )
    
    func extractInspectV1(keyHex string, r io.Reader, w io.Writer, okMsg string) error {
    	id, err := hex.DecodeString(keyHex[:8])
    	if err != nil {
    		return err
    	}
    	key, err := hex.DecodeString(keyHex[8:])
    	if err != nil {
    		return err
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 11 21:22:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  8. cmd/storage-rest-common_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *nsScannerOptions) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    			srcInfo.Reader.Close() // We are not interested in the reader stream at this point close it.
    			return srcSet.CopyObject(ctx, srcBucket, srcObject, dstBucket, dstObject, srcInfo, srcOpts, dstOpts)
    		}
    		// Destination is not versioned and source version ID is empty
    		// perform an in-place update.
    		if !dstOpts.Versioned && srcOpts.VersionID == "" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
  10. api/go1.txt

    pkg testing/iotest, func DataErrReader(io.Reader) io.Reader
    pkg testing/iotest, func HalfReader(io.Reader) io.Reader
    pkg testing/iotest, func NewReadLogger(string, io.Reader) io.Reader
    pkg testing/iotest, func NewWriteLogger(string, io.Writer) io.Writer
    pkg testing/iotest, func OneByteReader(io.Reader) io.Reader
    pkg testing/iotest, func TimeoutReader(io.Reader) io.Reader
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top