Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 208 for newReader (0.09 sec)

  1. internal/s3select/csv/reader_contrib_test.go

    		{"1,2,3\ta,b,c\t", "\t", ","},
    		{"1,2,3\r\na,b,c\r\n", "\r\n", ","},
    	}
    
    	for i, c := range cases {
    		var err error
    		var record sql.Record
    		var result bytes.Buffer
    
    		r, _ := NewReader(io.NopCloser(strings.NewReader(c.content)), &ReaderArgs{
    			FileHeaderInfo:             none,
    			RecordDelimiter:            c.recordDelimiter,
    			FieldDelimiter:             c.fieldDelimiter,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 38.5K bytes
    - Viewed (0)
  2. cmd/post-policy-fan-out.go

    			hopts := hash.Options{
    				Size:       int64(len(fanOutBuf)),
    				MD5Hex:     opts.MD5Hex,
    				SHA256Hex:  "",
    				ActualSize: -1,
    				DisableMD5: true,
    			}
    			hr, err := hash.NewReaderWithOpts(ctx, bytes.NewReader(fanOutBuf), hopts)
    			if err != nil {
    				errs[idx] = err
    				return
    			}
    
    			reader := NewPutObjReader(hr)
    			defer func() {
    				if err := reader.Close(); err != nil {
    					errs[idx] = err
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. internal/etag/reader.go

    	src io.Reader
    
    	md5      hash.Hash
    	checksum ETag
    
    	readN int64
    }
    
    // NewReader returns a new Reader that computes the
    // MD5 checksum of the content read from r as ETag.
    //
    // If the provided etag is not nil the returned
    // Reader compares the etag with the computed
    // MD5 sum once the r returns io.EOF.
    func NewReader(ctx context.Context, r io.Reader, etag ETag, forceMD5 []byte) *Reader {
    	if er, ok := r.(*Reader); ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  4. internal/s3select/json/reader.go

    	for range r.valueCh {
    		// Drain values so we don't leak a goroutine.
    		// Since we have closed the input, it should fail rather quickly.
    	}
    	return err
    }
    
    // NewReader - creates new JSON reader using readCloser.
    func NewReader(readCloser io.ReadCloser, args *ReaderArgs) *Reader {
    	readCloser = &syncReadCloser{rc: readCloser}
    	d := jstream.NewDecoder(io.LimitReader(readCloser, maxDocumentSize), 0).ObjectAsKVS().MaxDepth(100)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. cmd/admin-handlers-config-kv.go

    	if err != nil {
    		return
    	}
    
    	result.Dynamic, err = result.Cfg.ReadConfig(bytes.NewReader(kvBytes))
    	if err != nil {
    		return
    	}
    
    	result.SubSys, _, _, err = config.GetSubSys(string(kvBytes))
    	if err != nil {
    		return
    	}
    
    	tgts, err := config.ParseConfigTargetID(bytes.NewReader(kvBytes))
    	if err != nil {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  6. cmd/streaming-v4-unsigned.go

    		for _, key := range trailers {
    			req.Trailer.Add(key, "")
    		}
    	} else {
    		req.Trailer = nil
    	}
    	return &s3UnsignedChunkedReader{
    		trailers: req.Trailer,
    		reader:   bufio.NewReader(req.Body),
    		buffer:   make([]byte, 64*1024),
    	}, ErrNone
    }
    
    // Represents the overall state that is required for decoding a
    // AWS Signature V4 chunked reader.
    type s3UnsignedChunkedReader struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  7. cmd/data-usage-cache.go

    	case dataUsageCacheVerV2:
    		// Zstd compressed.
    		dec, err := zstd.NewReader(r, zstd.WithDecoderConcurrency(2))
    		if err != nil {
    			return err
    		}
    		defer dec.Close()
    
    		dold := &dataUsageCacheV2{}
    		if err = dold.DecodeMsg(msgp.NewReader(dec)); err != nil {
    			return err
    		}
    		d.Info = dold.Info
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  8. docs/sts/client-grants.go

    }
    
    func getTokenExpiry() (*credentials.ClientGrantsToken, error) {
    	data := url.Values{}
    	data.Set("grant_type", "client_credentials")
    	req, err := http.NewRequest(http.MethodPost, idpEndpoint, strings.NewReader(data.Encode()))
    	if err != nil {
    		return nil, err
    	}
    	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
    	req.SetBasicAuth(clientID, clientSecret)
    	t := &http.Transport{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  9. cmd/server_test.go

    	c.Assert(err, nil)
    	// Verify if downloaded policy matches with previously uploaded.
    	expectedPolicy, err := policy.ParseBucketPolicyConfig(strings.NewReader(bucketPolicyStr), bucketName)
    	c.Assert(err, nil)
    	gotPolicy, err := policy.ParseBucketPolicyConfig(bytes.NewReader(bucketPolicyReadBuf), bucketName)
    	c.Assert(err, nil)
    	c.Assert(reflect.DeepEqual(expectedPolicy, gotPolicy), true)
    
    	// Delete policy.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  10. internal/s3select/select_test.go

    			}
    			s3Select, err := NewS3Select(bytes.NewReader(testReq))
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			if err = s3Select.Open(newStringRSC(input)); err != nil {
    				t.Fatal(err)
    			}
    
    			w := &testResponseWriter{}
    			s3Select.Evaluate(w)
    			s3Select.Close()
    			resp := http.Response{
    				StatusCode:    http.StatusOK,
    				Body:          io.NopCloser(bytes.NewReader(w.response)),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
Back to top