Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 249 for Header (0.2 sec)

  1. cmd/httprange_test.go

    		if err != nil && !testCase.errExpected || err == nil && testCase.errExpected {
    			t.Errorf("expected error with invalid range: %v", err)
    		}
    		if h != testCase.spec {
    			t.Errorf("Case %d: translated to incorrect header: %s expected: %s",
    				i, h, testCase.spec)
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 3.7K bytes
    - Viewed (0)
  2. internal/crypto/error.go

    	// ErrIncompatibleEncryptionMethod indicates that both SSE-C headers and SSE-S3 headers were specified, and are incompatible
    	// The client needs to remove the SSE-S3 header or the SSE-C headers
    	ErrIncompatibleEncryptionMethod = Errorf("Server side encryption specified with both SSE-C and SSE-S3 headers")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  3. cmd/metacache-set_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 *listPathOptions) 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()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 20:23:12 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    }
    
    // GetObjectNInfo - returns object info and an object
    // Read(Closer). When err != nil, the returned reader is always nil.
    func (er erasureObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, object, &er)
    	}
    
    	var unlockOnDefer bool
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  5. cmd/erasure-server-pool-rebalance.go

    	if err != nil {
    		return err
    	}
    
    	if len(data) == 0 {
    		return nil
    	}
    	if len(data) <= 4 {
    		return fmt.Errorf("rebalanceMeta: no data")
    	}
    
    	// Read header
    	switch binary.LittleEndian.Uint16(data[0:2]) {
    	case rebalMetaFmt:
    	default:
    		return fmt.Errorf("rebalanceMeta: unknown format: %d", binary.LittleEndian.Uint16(data[0:2]))
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  6. cmd/update.go

    	return resp.Body, nil
    }
    
    var updateInProgress atomic.Uint32
    
    // Function to get the reader from an architecture
    func downloadBinary(u *url.URL, mode string) (binCompressed []byte, bin []byte, err error) {
    	transport := getUpdateTransport(30 * time.Second)
    	var reader io.ReadCloser
    	if u.Scheme == "https" || u.Scheme == "http" {
    		reader, err = getUpdateReaderFromURL(u, transport, mode)
    		if err != nil {
    			return nil, nil, err
    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)
  7. cmd/signature-v2.go

    }
    
    // Return canonical headers.
    func canonicalizedAmzHeadersV2(headers http.Header) string {
    	var keys []string
    	keyval := make(map[string]string, len(headers))
    	for key := range headers {
    		lkey := strings.ToLower(key)
    		if !strings.HasPrefix(lkey, "x-amz-") {
    			continue
    		}
    		keys = append(keys, lkey)
    		keyval[lkey] = strings.Join(headers[key], ",")
    	}
    	sort.Strings(keys)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 12.2K bytes
    - Viewed (0)
  8. cmd/streaming-signature-v4.go

    	}, ErrNone
    }
    
    // Represents the overall state that is required for decoding a
    // AWS Signature V4 chunked reader.
    type s3ChunkedReader struct {
    	reader        *bufio.Reader
    	cred          auth.Credentials
    	seedSignature string
    	seedDate      time.Time
    	region        string
    	trailers      http.Header
    
    	chunkSHA256Writer hash.Hash // Calculates sha256 of chunk data.
    	buffer            []byte
    	offset            int
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  9. internal/handlers/proxy_test.go

    		{forwarded, `for=192.0.2.60;proto=http;by=203.0.113.43`, "http"},    // Multiple params
    	}
    	for _, v := range headers {
    		req := &http.Request{
    			Header: http.Header{
    				v.key: []string{v.val},
    			},
    		}
    		res := GetSourceScheme(req)
    		if res != v.expected {
    			t.Errorf("wrong header for %s: got %s want %s", v.key, res,
    				v.expected)
    		}
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  10. cmd/tier-handlers.go

    		return
    	}
    
    	tiers := globalTierConfigMgr.ListTiers()
    	data, err := json.Marshal(tiers)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	w.Header().Set(tierCfgRefreshAtHdr, globalTierConfigMgr.refreshedAt().String())
    	writeSuccessResponseJSON(w, data)
    }
    
    func (api adminAPIHandlers) EditTierHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 15 19:52:44 GMT 2024
    - 7.5K bytes
    - Viewed (0)
Back to top