Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for ReqInfo (0.12 sec)

  1. cmd/global-heal.go

    )
    
    // NewBgHealSequence creates a background healing sequence
    // operation which scans all objects and heal them.
    func newBgHealSequence() *healSequence {
    	reqInfo := &logger.ReqInfo{API: "BackgroundHeal"}
    	ctx, cancelCtx := context.WithCancel(logger.SetReqInfo(GlobalContext, reqInfo))
    
    	hs := madmin.HealOpts{
    		// Remove objects that do not have read-quorum
    		Remove: healDeleteDangling,
    	}
    
    	return &healSequence{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  2. cmd/erasure-healing.go

    	// The top level handler might not have this information.
    	reqInfo := logger.GetReqInfo(ctx)
    	var newReqInfo *logger.ReqInfo
    	if reqInfo != nil {
    		newReqInfo = logger.NewReqInfo(reqInfo.RemoteHost, reqInfo.UserAgent, reqInfo.DeploymentID, reqInfo.RequestID, reqInfo.API, bucket, object)
    	} else {
    		newReqInfo = logger.NewReqInfo("", "", globalDeploymentID(), "", "Heal", bucket, object)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    func newHealSequence(ctx context.Context, bucket, objPrefix, clientAddr string,
    	hs madmin.HealOpts, forceStart bool,
    ) *healSequence {
    	reqInfo := &logger.ReqInfo{RemoteHost: clientAddr, API: "Heal", BucketName: bucket}
    	reqInfo.AppendTags("prefix", objPrefix)
    	ctx, cancel := context.WithCancel(logger.SetReqInfo(ctx, reqInfo))
    
    	clientToken := mustGetUUID()
    
    	return &healSequence{
    		bucket:         bucket,
    		object:         objPrefix,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. cmd/api-response.go

    	errBody string, reqURL *url.URL,
    ) {
    	reqInfo := logger.GetReqInfo(ctx)
    	errorResponse := APIErrorResponse{
    		Code:       err.Code,
    		Message:    errBody,
    		Resource:   reqURL.Path,
    		BucketName: reqInfo.BucketName,
    		Key:        reqInfo.ObjectName,
    		RequestID:  w.Header().Get(xhttp.AmzRequestID),
    		HostID:     globalDeploymentID(),
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 25 02:13:19 UTC 2024
    - 33.6K bytes
    - Viewed (0)
  5. cmd/encryption-v1.go

    	if err != nil {
    		// This cannot happen since AWS S3 allows parts to be 5GB at most
    		// sio max. size is 256 TB
    		reqInfo := (&logger.ReqInfo{}).AppendTags("size", strconv.FormatUint(size, 10))
    		ctx := logger.SetReqInfo(GlobalContext, reqInfo)
    		logger.CriticalIf(ctx, err)
    	}
    	return int64(size)
    }
    
    // DecryptObjectInfo tries to decrypt the provided object if it is encrypted.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  6. cmd/api-errors.go

    func getAPIErrorResponse(ctx context.Context, err APIError, resource, requestID, hostID string) APIErrorResponse {
    	reqInfo := logger.GetReqInfo(ctx)
    	return APIErrorResponse{
    		Code:             err.Code,
    		Message:          err.Description,
    		BucketName:       reqInfo.BucketName,
    		Key:              reqInfo.ObjectName,
    		Resource:         resource,
    		Region:           globalSite.Region(),
    		RequestID:        requestID,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 92.1K bytes
    - Viewed (1)
  7. cmd/object-handlers.go

    			w.Header()[xhttp.AmzDeleteMarker] = []string{strconv.FormatBool(gr.ObjInfo.DeleteMarker)}
    		}
    
    		// Update context bucket & object names for correct S3 XML error response
    		reqInfo := logger.GetReqInfo(ctx)
    		reqInfo.BucketName = srcBucket
    		reqInfo.ObjectName = srcObject
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	defer gr.Close()
    	srcInfo := gr.ObjInfo
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    	// Check latency...
    	if opts.Threshold > 0 && trcInfo.Duration < opts.Threshold {
    		return false
    	}
    
    	// Check internal path
    	isInternal := isHTTP && HasPrefix(trcInfo.HTTP.ReqInfo.Path, minioReservedBucketPath+SlashSeparator)
    	if isInternal && !opts.Internal {
    		return false
    	}
    
    	// Filter non-errors.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
Back to top