Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for ReqInfo (0.09 sec)

  1. internal/logger/reqinfo.go

    	return &ReqInfo{
    		RemoteHost:   remoteHost,
    		UserAgent:    userAgent,
    		API:          api,
    		DeploymentID: deploymentID,
    		RequestID:    requestID,
    		BucketName:   bucket,
    		ObjectName:   object,
    	}
    }
    
    // AppendTags - appends key/val to ReqInfo.tags
    func (r *ReqInfo) AppendTags(key, val string) *ReqInfo {
    	if r == nil {
    		return nil
    	}
    	r.Lock()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. internal/logger/audit.go

    			timeToFirstByte = tc.ResponseRecorder.TTFB()
    		}
    
    		entry.AccessKey = reqInfo.Cred.AccessKey
    		entry.ParentUser = reqInfo.Cred.ParentUser
    
    		entry.API.Name = reqInfo.API
    		entry.API.Bucket = reqInfo.BucketName
    		entry.API.Object = reqInfo.ObjectName
    		entry.API.Objects = make([]audit.ObjectVersion, 0, len(reqInfo.Objects))
    		for _, ov := range reqInfo.Objects {
    			entry.API.Objects = append(entry.API.Objects, audit.ObjectVersion{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/notification.go

    					// context already canceled no retries.
    					retryCount = 0
    				}
    
    				// Last iteration log the error.
    				if i == retryCount-1 {
    					reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", addr.String())
    					ctx := logger.SetReqInfo(ctx, reqInfo)
    					peersLogOnceIf(ctx, err, addr.String())
    				}
    
    				// Wait for a minimum of 100ms and dynamically increase this based on number of attempts.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  4. cmd/auth-handler.go

    	reqInfo := logger.GetReqInfo(ctx)
    	if reqInfo == nil {
    		return ErrAccessDenied
    	}
    
    	cred := reqInfo.Cred
    	owner := reqInfo.Owner
    	region := reqInfo.Region
    	bucket := reqInfo.BucketName
    	object := reqInfo.ObjectName
    	versionID := reqInfo.VersionID
    
    	if action != policy.ListAllMyBucketsAction && cred.AccessKey == "" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. cmd/utils.go

    	}
    	return ctx
    }
    
    // Returns context with ReqInfo details set in the context.
    func newContext(r *http.Request, w http.ResponseWriter, api string) context.Context {
    	reqID := w.Header().Get(xhttp.AmzRequestID)
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    	object := likelyUnescapeGeneric(vars["object"], url.PathUnescape)
    	reqInfo := &logger.ReqInfo{
    		DeploymentID: globalDeploymentID(),
    		RequestID:    reqID,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. cmd/http-tracer.go

    			Time:      reqStartTime,
    			Duration:  reqEndTime.Sub(respRecorder.StartTime),
    			Path:      reqPath,
    			Bytes:     int64(inputBytes + respRecorder.Size()),
    			HTTP: &madmin.TraceHTTPStats{
    				ReqInfo: madmin.TraceRequestInfo{
    					Time:     reqStartTime,
    					Proto:    r.Proto,
    					Method:   r.Method,
    					RawQuery: redactLDAPPwd(r.URL.RawQuery),
    					Client:   handlers.GetSourceIP(r),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top