Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for encodeResponse (0.21 sec)

  1. cmd/bucket-handlers_test.go

    	encodedSuccessResponse1 := encodeResponse(successResponse1)
    
    	// generate multi objects delete response for errors.
    	// errorRequest := encodeResponse(requestList[1])
    	errorResponse := generateMultiDeleteResponse(requestList[1].Quiet, deletedObjects, nil)
    	encodedErrorResponse := encodeResponse(errorResponse)
    
    	anonRequest := encodeResponse(requestList[0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  2. cmd/veeam-sos-api.go

    			ModelName:       "\"MinIO " + ReleaseTag + "\"",
    		}
    		si.ProtocolCapabilities.CapacityInfo = true
    
    		// Default recommended block size with MinIO
    		si.SystemRecommendations.KBBlockSize = 4096
    
    		buf = encodeResponse(&si)
    	case capacityXMLObject:
    		objAPI := newObjectLayerFn()
    		if objAPI == nil {
    			return nil, errServerNotInitialized
    		}
    
    		q, _ := globalBucketQuotaSys.Get(ctx, bucket)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  3. cmd/sts-handlers.go

    		Result: AssumeRoleResult{
    			Credentials: cred,
    		},
    	}
    
    	assumeRoleResponse.ResponseMetadata.RequestID = w.Header().Get(xhttp.AmzRequestID)
    	writeSuccessResponseXML(w, encodeResponse(assumeRoleResponse))
    }
    
    func (sts *stsAPIHandlers) AssumeRoleWithSSO(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "AssumeRoleSSOCommon")
    
    	claims := stsClaims{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Generate response.
    	encodedSuccessResponse := encodeResponse(LocationResponse{})
    	// Get current region.
    	region := globalSite.Region()
    	if region != globalMinioDefaultRegion {
    		encodedSuccessResponse = encodeResponse(LocationResponse{
    			Location: region,
    		})
    	}
    
    	// Write success response.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  5. cmd/object-multipart-handlers.go

    	}
    
    	response := generateInitiateMultipartUploadResponse(bucket, object, res.UploadID)
    	if res.ChecksumAlgo != "" {
    		w.Header().Set(xhttp.AmzChecksumAlgo, res.ChecksumAlgo)
    	}
    	encodedSuccessResponse := encodeResponse(response)
    
    	// Write success response.
    	writeSuccessResponseXML(w, encodedSuccessResponse)
    }
    
    // CopyObjectPartHandler - uploads a part by copying data from an existing object as data source.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  6. cmd/sts-errors.go

    	if err != nil {
    		stsErrorResponse.Error.Message = err.Error()
    	}
    	switch errCode {
    	case ErrSTSInternalError, ErrSTSUpstreamError:
    		stsLogIf(ctx, err, logger.ErrorKind)
    	}
    	encodedErrorResponse := encodeResponse(stsErrorResponse)
    	writeResponse(w, stsErr.HTTPStatusCode, encodedErrorResponse, mimeXML)
    }
    
    // STSError structure
    type STSError struct {
    	Code           string
    	Description    string
    	HTTPStatusCode int
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. cmd/object-handlers_test.go

    		{
    			bucketName: bucketName,
    			objectName: "abcd",
    			byteRange:  "",
    			accessKey:  credentials.AccessKey,
    			secretKey:  credentials.SecretKey,
    
    			expectedContent: encodeResponse(getAPIErrorResponse(ctx,
    				getAPIError(ErrNoSuchKey),
    				getGetObjectURL("", bucketName, "abcd"), "", "")),
    			expectedRespStatus: http.StatusNotFound,
    		},
    		// Test case - 3.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  8. cmd/api-headers.go

    	}
    	w.Header().Set(xhttp.AcceptRanges, "bytes")
    
    	// Remove sensitive information
    	crypto.RemoveSensitiveHeaders(w.Header())
    }
    
    // Encodes the response headers into XML format.
    func encodeResponse(response interface{}) []byte {
    	var buf bytes.Buffer
    	buf.WriteString(xml.Header)
    	if err := xml.NewEncoder(&buf).Encode(response); err != nil {
    		bugLogIf(GlobalContext, err)
    		return nil
    	}
    	return buf.Bytes()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
  9. cmd/object-handlers.go

    		},
    		actualSize,
    	)
    	defer objectRSC.Close()
    	s3Select, err := s3select.NewS3Select(r.Body)
    	if err != nil {
    		if serr, ok := err.(s3select.SelectError); ok {
    			encodedErrorResponse := encodeResponse(APIErrorResponse{
    				Code:       serr.ErrorCode(),
    				Message:    serr.ErrorMessage(),
    				BucketName: bucket,
    				Key:        object,
    				Resource:   r.URL.Path,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  10. cmd/object-api-options.go

    				ctx,
    				apiErr,
    				r.URL.Path,
    				w.Header().Get(xhttp.AmzRequestID),
    				w.Header().Get(xhttp.AmzRequestHostID),
    			),
    		}
    
    		writeResponse(w, apiErr.HTTPStatusCode, encodeResponse(errResp), mimeXML)
    	}()
    
    	opts, err = getOpts(ctx, r, bucket, object)
    	if err != nil {
    		switch vErr := err.(type) {
    		case InvalidVersionID:
    			apiErr = toAPIError(ctx, vErr)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 14.4K bytes
    - Viewed (0)
Back to top