Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 25 for ReqInfo (0.1 sec)

  1. 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)
  2. cmd/update.go

    	if err != nil {
    		// Log errors and return "" as MinIO can be deployed
    		// without Helm charts as well.
    		if !osIsNotExist(err) {
    			reqInfo := (&logger.ReqInfo{}).AppendTags("helmInfoFilePath", helmInfoFilePath)
    			ctx := logger.SetReqInfo(GlobalContext, reqInfo)
    			internalLogIf(ctx, err)
    		}
    		return ""
    	}
    	defer helmInfoFile.Close()
    	scanner := bufio.NewScanner(helmInfoFile)
    	for scanner.Scan() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K 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/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)
  6. 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)
  7. cmd/admin-router.go

    	// Use bitwise-AND and check if the result is non-zero.
    	return h&flag != 0
    }
    
    // adminMiddleware performs some common admin handler functionality for all
    // handlers:
    //
    // - updates request context with `logger.ReqInfo` and api name based on the
    // name of the function handler passed (this handler must be a method of
    // `adminAPIHandlers`).
    //
    // - sets up call to send AuditLog
    //
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  8. internal/logger/logger.go

    	logKind := madmin.LogKindError
    	if len(errKind) > 0 {
    		if ek, ok := errKind[0].(madmin.LogKind); ok {
    			logKind = ek
    		}
    	}
    
    	req := GetReqInfo(ctx)
    	if req == nil {
    		req = &ReqInfo{
    			API:       "SYSTEM",
    			RequestID: fmt.Sprintf("%X", time.Now().UTC().UnixNano()),
    		}
    	}
    	req.RLock()
    	defer req.RUnlock()
    
    	API := "SYSTEM"
    	switch {
    	case req.API != "":
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-decom.go

    		},
    		finished: nil,
    	})
    	return err
    }
    
    func (z *erasureServerPools) decommissionPool(ctx context.Context, idx int, pool *erasureSets, bi decomBucketInfo) error {
    	ctx = logger.SetReqInfo(ctx, &logger.ReqInfo{})
    
    	const envDecomWorkers = "_MINIO_DECOMMISSION_WORKERS"
    	workerSize, err := env.GetInt(envDecomWorkers, len(pool.sets))
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (1)
  10. cmd/erasure-server-pool.go

    // can be used to query scenarios if health may be lost
    // if this node is taken down by an external orchestrator.
    func (z *erasureServerPools) Health(ctx context.Context, opts HealthOptions) HealthResult {
    	reqInfo := (&logger.ReqInfo{}).AppendTags("maintenance", strconv.FormatBool(opts.Maintenance))
    
    	type setInfo struct {
    		online  int
    		healing int
    	}
    
    	var drivesHealing int
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top