Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 6,618 for xhttp (0.03 sec)

  1. cmd/storage-rest-server.go

    func (s *storageRESTServer) writeErrorResponse(w http.ResponseWriter, err error) {
    	err = unwrapAll(err)
    	switch err {
    	case errDiskStale:
    		w.WriteHeader(http.StatusPreconditionFailed)
    	case errFileNotFound, errFileVersionNotFound:
    		w.WriteHeader(http.StatusNotFound)
    	case errInvalidAccessKeyID, errAccessKeyDisabled, errNoAuthToken, errMalformedAuth, errAuthentication, errSkewedAuthTime:
    		w.WriteHeader(http.StatusUnauthorized)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  2. cmd/bucket-replication-handlers.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"encoding/json"
    	"encoding/xml"
    	"errors"
    	"fmt"
    	"io"
    	"net/http"
    	"path"
    	"time"
    
    	"github.com/minio/minio-go/v7"
    	objectlock "github.com/minio/minio/internal/bucket/object/lock"
    	"github.com/minio/minio/internal/bucket/replication"
    	xhttp "github.com/minio/minio/internal/http"
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    		userDefined["content-type"] = mimedb.TypeByExtension(path.Ext(object))
    	}
    
    	// if storageClass is standard no need to save it as part of metadata.
    	if userDefined[xhttp.AmzStorageClass] == storageclass.STANDARD {
    		delete(userDefined, xhttp.AmzStorageClass)
    	}
    
    	// Fill all the necessary metadata.
    	// Update `xl.meta` content on each disks.
    	for index := range partsMetadata {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  4. cmd/perf-tests.go

    	}
    	result.Endpoint = rp.String()
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, reqURL.String(), reader)
    	if err != nil {
    		result.Error = err.Error()
    		return
    	}
    	client := &http.Client{
    		Transport: globalRemoteTargetTransport,
    	}
    	resp, err := client.Do(req)
    	if err != nil {
    		result.Error = err.Error()
    		return
    	}
    	defer xhttp.DrainBody(resp.Body)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  5. cmd/streaming-signature-v4.go

    // out of HTTP "chunked" format before returning it.
    // The s3ChunkedReader returns io.EOF when the final 0-length chunk is read.
    //
    // NewChunkedReader is not needed by normal applications. The http package
    // automatically decodes chunking when reading response bodies.
    func newSignV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  6. cmd/signature-v4-utils_test.go

    	}
    
    	for i, testCase := range testCases {
    		// creating an input HTTP request.
    		// Only the headers are relevant for this particular test.
    		inputReq, err := http.NewRequest(http.MethodGet, "http://example.com", nil)
    		if err != nil {
    			t.Fatalf("Error initializing input HTTP request: %v", err)
    		}
    		if testCase.inputQueryKey != "" {
    			q := inputReq.URL.Query()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  7. cmd/encryption-v1.go

    	switch r.Method {
    	case http.MethodGet, http.MethodHead:
    		if crypto.S3.IsRequested(headers) || crypto.S3KMS.IsRequested(headers) {
    			return false, errInvalidEncryptionParameters
    		}
    	}
    
    	_, encrypted = crypto.IsEncrypted(info.UserDefined)
    	if !encrypted && crypto.SSEC.IsRequested(headers) && r.Header.Get(xhttp.AmzCopySource) == "" {
    		return false, errInvalidEncryptionParameters
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  8. cmd/object-handlers_test.go

    			if r.ObjInfo.VersionID != "" {
    				values.Set(xhttp.VersionID, r.ObjInfo.VersionID)
    			}
    		}
    		var req *http.Request
    		var reqV2 *http.Request
    		// initialize HTTP NewRecorder, this records any mutations to response writer inside the handler.
    		rec := httptest.NewRecorder()
    		// construct HTTP request for copy object.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  9. cmd/xl-storage-format-v2_test.go

    	toBeRestored := make(map[string]string)
    	toBeRestored[xhttp.AmzRestore] = ongoingRestoreObj().String()
    
    	restored := make(map[string]string)
    	restored[xhttp.AmzRestore] = completedRestoreObj(time.Now().UTC().Add(time.Hour)).String()
    
    	restoredExpired := make(map[string]string)
    	restoredExpired[xhttp.AmzRestore] = completedRestoreObj(time.Now().UTC().Add(-time.Hour)).String()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v2.go

    	j.MetaSys[metaTierName] = []byte(fi.TransitionTier)
    }
    
    func (j *xlMetaV2Object) RemoveRestoreHdrs() {
    	delete(j.MetaUser, xhttp.AmzRestore)
    	delete(j.MetaUser, xhttp.AmzRestoreExpiryDays)
    	delete(j.MetaUser, xhttp.AmzRestoreRequestDate)
    }
    
    // Signature will return a signature that is expected to be the same across all disks.
    func (j *xlMetaV2Object) Signature() [4]byte {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 65.6K bytes
    - Viewed (1)
Back to top