Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for appendArgs (0.3 sec)

  1. cmd/admin-heal-ops.go

    	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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 09 18:04:41 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    			globalTierMetrics.Observe(tier, since)
    			globalTierMetrics.logSuccess(tier)
    		} else {
    			op.Error = err.Error()
    			globalTierMetrics.logFailure(tier)
    		}
    
    		logger.GetReqInfo(ctx).AppendTags("tierStats", op)
    	}
    }
    
    // getTransitionedObjectReader returns a reader from the transitioned tier.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  3. cmd/encryption-v1.go

    	size, err := sio.EncryptedSize(uint64(o.Size))
    	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)
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    		return
    	}
    
    	op := auditObjectOp{
    		Name:   decodeDirObject(object),
    		Pool:   set.poolIndex + 1,
    		Set:    set.setIndex + 1,
    		Drives: set.getEndpointStrings(),
    	}
    
    	logger.GetReqInfo(ctx).AppendTags("objectLocation", op)
    }
    
    // NewNSLock - initialize a new namespace RWLocker instance.
    func (s *erasureSets) NewNSLock(bucket string, objects ...string) RWLocker {
    	if len(objects) == 1 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    // 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 82.5K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    		resp.Results[i] = convPartErrToInt(err)
    
    		// Only log unknown errors
    		if resp.Results[i] == checkPartUnknown && err != errFileAccessDenied {
    			logger.GetReqInfo(ctx).AppendTags("disk", s.String())
    			storageLogOnceIf(ctx, err, partPath)
    		}
    	}
    
    	return &resp, nil
    }
    
    // ReadMultiple will read multiple files and send each back as response.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
Back to top