Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for init (2.15 sec)

  1. cmd/object-handlers.go

    	var update bool
    	if cachedResult {
    		rc := &cache.CondCheck{}
    		h := r.Header.Clone()
    		if opts.PartNumber > 0 {
    			h.Set(xhttp.PartNumber, strconv.Itoa(opts.PartNumber))
    		}
    		rc.Init(bucket, object, h)
    
    		ci, err := globalCacheConfig.Get(rc)
    		if ci != nil {
    			tgs, ok := ci.Metadata[xhttp.AmzObjectTagging]
    			if ok {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  2. cmd/metrics-v2.go

    	clusterCollector        *minioClusterCollector
    	bucketCollector         *minioBucketCollector
    	peerMetricsGroups       []*MetricsGroupV2
    	bucketPeerMetricsGroups []*MetricsGroupV2
    )
    
    func init() {
    	clusterMetricsGroups := []*MetricsGroupV2{
    		getNodeHealthMetrics(MetricsGroupOpts{dependGlobalNotificationSys: true}),
    		getClusterStorageMetrics(MetricsGroupOpts{dependGlobalObjectAPI: true}),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    	Enabled           bool
    	MaxBuckets        int                             // maximum buckets seen across sites
    	MaxUsers          int                             // maximum users seen across sites
    	MaxGroups         int                             // maximum groups seen across sites
    	MaxPolicies       int                             // maximum policies across sites
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  4. cmd/bucket-replication.go

    func (p *ReplicationPool) ActiveWorkers() int {
    	return int(atomic.LoadInt32(&p.activeWorkers))
    }
    
    // ActiveMRFWorkers returns the number of active workers handling replication failures.
    func (p *ReplicationPool) ActiveMRFWorkers() int {
    	return int(atomic.LoadInt32(&p.activeMRFWorkers))
    }
    
    // ResizeWorkers sets replication workers pool to new size.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  5. cmd/admin-handlers.go

    }
    
    func getPoolsInfo(ctx context.Context, allDisks []madmin.Disk) (map[int]map[int]madmin.ErasureSetInfo, error) {
    	objectAPI := newObjectLayerFn()
    	if objectAPI == nil {
    		return nil, errServerNotInitialized
    	}
    
    	z, ok := objectAPI.(*erasureServerPools)
    	if !ok {
    		return nil, errServerNotInitialized
    	}
    
    	poolsInfo := make(map[int]map[int]madmin.ErasureSetInfo)
    	for _, d := range allDisks {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  6. cmd/object-handlers_test.go

    	for _, input := range objectInputs {
    		uploadTestObject(t, apiRouter, credentials, bucketName, input.objectName, input.partLengths, input.metaData, false)
    	}
    
    	mkGetReqWithPartNumber := func(oindex int, oi ObjectInput, partNumber int) {
    		object := oi.objectName
    
    		queries := url.Values{}
    		queries.Add("partNumber", strconv.Itoa(partNumber))
    		targetURL := makeTestTargetURL("", bucketName, object, queries)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top