Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 14 of 14 for SetReqInfo (0.15 sec)

  1. cmd/endpoint.go

    					if timeElapsed > time.Second {
    						reqInfo.AppendTags("elapsedTime",
    							humanize.RelTime(startTime,
    								startTime.Add(timeElapsed),
    								"elapsed",
    								"",
    							))
    						ctx := logger.SetReqInfo(GlobalContext,
    							reqInfo)
    						bootLogOnceIf(ctx, fmt.Errorf("%s resolves to localhost in a containerized deployment, waiting for it to resolve to a valid IP",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    // 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{
    		startTime:   UTCNow(),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  3. cmd/utils.go

    		for _, ov := range objects {
    			req.Objects = append(req.Objects, logger.ObjectVersion{
    				ObjectName: ov.ObjectName,
    				VersionID:  ov.VersionID,
    			})
    		}
    		return logger.SetReqInfo(ctx, req)
    	}
    	return ctx
    }
    
    // Returns context with ReqInfo details set in the context.
    func newContext(r *http.Request, w http.ResponseWriter, api string) context.Context {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  4. cmd/erasure-healing.go

    	} else {
    		newReqInfo = logger.NewReqInfo("", "", globalDeploymentID(), "", "Heal", bucket, object)
    	}
    	healCtx := logger.SetReqInfo(GlobalContext, newReqInfo)
    
    	// Healing directories handle it separately.
    	if HasSuffix(object, SlashSeparator) {
    		hr, err := er.healObjectDir(healCtx, bucket, object, opts.DryRun, opts.Remove)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
Back to top