Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 422 for loader (0.02 sec)

  1. cmd/bootstrap-peer-server.go

    			if retries >= 20 {
    				logger.Info(fmt.Sprintf("Waiting for at least %d remote servers with valid configuration to be online", len(clnts)/2))
    				if len(offlineEndpoints) > 0 {
    					logger.Info(fmt.Sprintf("Following servers are currently offline or unreachable %s", offlineEndpoints))
    				}
    				if len(incorrectConfigs) > 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. 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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  3. cmd/signature-v4-parser.go

    	"strings"
    	"time"
    
    	"github.com/minio/minio/internal/auth"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    // credentialHeader data type represents structured form of Credential
    // string from authorization header.
    type credentialHeader struct {
    	accessKey string
    	scope     struct {
    		date    time.Time
    		region  string
    		service string
    		request string
    	}
    }
    
    // Return scope string.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. cmd/object-multipart-handlers.go

    	var idxCb func() []byte
    	if isCompressed {
    		wantEncryption := crypto.Requested(r.Header) || isEncrypted
    		s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption)
    		idxCb = cb
    		defer s2c.Close()
    		reader = etag.Wrap(s2c, reader)
    		length = -1
    	}
    
    	srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  5. cmd/signature-v4-utils.go

    			// Adding a *TODO* to remove this later when Golang server
    			// doesn't filter out the 'Expect' header.
    			extractedSignedHeaders.Set(header, "100-continue")
    		case "host":
    			// Go http server removes "host" from Request.Header
    			extractedSignedHeaders.Set(header, r.Host)
    		case "transfer-encoding":
    			// Go http server removes "host" from Request.Header
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Nov 25 17:10:22 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v2.go

    					case !strict && ver.header.matchesNotStrict(latest.header):
    						latestCount++
    					default:
    						latestCount = 1
    					}
    					latest = ver
    					continue
    				}
    
    				// Mismatch, but older.
    				if latestCount > 0 && !strict && ver.header.matchesNotStrict(latest.header) {
    					latestCount++
    					continue
    				}
    				if latestCount > 0 && ver.header.VersionID == latest.header.VersionID {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 65.6K bytes
    - Viewed (1)
  7. docs/bucket/versioning/DESIGN.md

    | xlHeaderVersion | msgp uint                   | header version identifier
    | xlMetaVersion   | msgp uint                   | metadata version identifier
    | versions        | msgp int                    | Number of versions following
    | header_1        | msgp bin array              | Header of version 1
    | metadata_1      | msgp bin array              | Metadata of version 1
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Jul 17 15:43:14 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  8. docs/debugging/inspect/export.go

    			}
    			type version struct {
    				Idx      int
    				Header   json.RawMessage
    				Metadata json.RawMessage
    			}
    			versions := make([]version, nVers)
    			e = decodeVersions(v, nVers, func(idx int, hdr, meta []byte) error {
    				var header xlMetaV2VersionHeaderV2
    				if _, e := header.UnmarshalMsg(hdr); e != nil {
    					return e
    				}
    				b, e := header.MarshalJSON()
    				if e != nil {
    					return e
    				}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:38:44 UTC 2025
    - 9.1K bytes
    - Viewed (1)
  9. cmd/generic-handlers.go

    			return true
    		}
    	}
    	return false
    }
    
    // isHTTPHeaderSizeTooLarge returns true if the provided
    // header is larger than 8 KB or the user-defined metadata
    // is larger than 2 KB.
    func isHTTPHeaderSizeTooLarge(header http.Header) bool {
    	var size, usersize int
    	for key := range header {
    		length := len(key) + len(header.Get(key))
    		size += length
    		for _, prefix := range userMetadataKeyPrefixes {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.7K bytes
    - Viewed (1)
  10. cmd/signature-v2_test.go

    		},
    	}
    
    	for i, testCase := range testCases {
    		t.Run(fmt.Sprintf("Case %d AuthStr \"%s\".", i+1, testCase.authString), func(t *testing.T) {
    			req := &http.Request{
    				Header: make(http.Header),
    				URL:    &url.URL{},
    			}
    			req.Header.Set("Authorization", testCase.authString)
    			_, actualErrCode := validateV2AuthHeader(req)
    
    			if testCase.expectedError != actualErrCode {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8K bytes
    - Viewed (0)
Back to top