Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 26 of 26 for ReqInfo (1.54 seconds)

  1. 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,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 16 07:34:24 GMT 2025
    - 93K bytes
    - Click Count (3)
  2. 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
    //
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  3. cmd/admin-handlers-users.go

    // setReqInfoPolicyName will set the given policyName as a tag on the context's request info,
    // so that it appears in audit logs.
    func setReqInfoPolicyName(ctx context.Context, policyName string) {
    	reqInfo := logger.GetReqInfo(ctx)
    	reqInfo.SetTags("policyName", policyName)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 90.6K bytes
    - Click Count (0)
  4. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  5. cmd/erasure-server-pool-rebalance.go

    }
    
    // rebalanceBucket rebalances objects under bucket in poolIdx pool
    func (z *erasureServerPools) rebalanceBucket(ctx context.Context, bucket string, poolIdx int) (err error) {
    	ctx = logger.SetReqInfo(ctx, &logger.ReqInfo{})
    
    	var vc *versioning.Versioning
    	var lc *lifecycle.Lifecycle
    	var lr objectlock.Retention
    	var rcfg *replication.Config
    	if bucket != minioMetaBucket {
    		vc, err = globalBucketVersioningSys.Get(bucket)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  6. 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.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
Back to Top