Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 224 for collect (0.25 sec)

  1. cmd/erasure.go

    func (er erasureObjects) nsScanner(ctx context.Context, buckets []BucketInfo, wantCycle uint32, updates chan<- dataUsageCache, healScanMode madmin.HealScanMode) error {
    	if len(buckets) == 0 {
    		return nil
    	}
    
    	// Collect disks we can use.
    	disks, healing := er.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    		scannerLogIf(ctx, errors.New("data-scanner: all drives are offline or being healed, skipping scanner cycle"))
    		return nil
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  2. docs/LICENSE

           3. To the extent possible, the Licensor waives any right to
              collect royalties from You for the exercise of the Licensed
              Rights, whether directly or through a collecting society
              under any voluntary or waivable statutory or compulsory
              licensing scheme. In all other cases the Licensor expressly
              reserves any right to collect such royalties.
    
    
    Section 3 -- License Conditions.
    
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon May 10 16:50:06 GMT 2021
    - 18.2K bytes
    - Viewed (0)
  3. cmd/metrics-v3-types.go

    	return mg.bucketLoader != nil
    }
    
    // Describe - implements prometheus.Collector interface.
    func (mg *MetricsGroup) Describe(ch chan<- *prometheus.Desc) {
    	for _, desc := range mg.Descriptors {
    		ch <- desc.toPromDesc(mg.CollectorPath.metricPrefix(), mg.ExtraLabels)
    	}
    }
    
    // Collect - implements prometheus.Collector interface.
    func (mg *MetricsGroup) Collect(ch chan<- prometheus.Metric) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  4. cmd/perf-tests.go

    	}, nil
    }
    
    // To collect RX stats during "mc support perf net"
    // RXSample holds the RX bytes for the duration between
    // the last peer to connect and the first peer to disconnect.
    // This is to improve the RX throughput accuracy.
    type netPerfRX struct {
    	RX                uint64    // RX bytes
    	lastToConnect     time.Time // time at which last peer to connect to us
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Jan 28 18:04:17 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  5. docs/debugging/README.md

    `mc support inspect` allows collecting files based on *path* from all backend drives. Matching files will be collected in a zip file with their respective host+drive+path. A MinIO host from October 2021 or later is required for full functionality. Syntax is `mc support inspect ALIAS/path/to/files`. This can for example be used to collect `xl.meta` from objects that are misbehaving. To collect `xl.meta` from a specific object, for example placed at `ALIAS/bucket/path/to/file.txt` append `/xl.meta`,...
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Feb 25 01:17:53 GMT 2022
    - 8.7K bytes
    - Viewed (0)
  6. cmd/metrics-v3-api.go

    //
    // This function currently ignores `opts`.
    func loadAPIRequestsHTTPMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	// Collect node level S3 HTTP metrics.
    	httpStats := globalHTTPStats.toServerHTTPStats(false)
    
    	// Currently we only collect S3 API related stats, so we set the "type"
    	// label to "s3".
    
    	m.Set(apiRejectedAuthTotal, float64(httpStats.TotalS3RejectedAuth), "type", "s3")
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  7. cmd/metrics-v3-cache.go

    }
    
    func newDataUsageInfoCache() *cachevalue.Cache[DataUsageInfo] {
    	loadDataUsage := func() (u DataUsageInfo, err error) {
    		objLayer := newObjectLayerFn()
    		if objLayer == nil {
    			return
    		}
    
    		// Collect cluster level object metrics.
    		u, err = loadDataUsageFromBackend(GlobalContext, objLayer)
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadDataUsage)
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.StorageInfoAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    	storageInfo := objectAPI.StorageInfo(ctx, true)
    
    	// Collect any disk healing.
    	healing, _ := getAggregatedBackgroundHealState(ctx, nil)
    	healDisks := make(map[string]struct{}, len(healing.HealDisks))
    	for _, disk := range healing.HealDisks {
    		healDisks[disk] = struct{}{}
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  9. cmd/metacache-set.go

    		console.Debugf(format+"\n", data...)
    	}
    }
    
    func (o *listPathOptions) debugln(data ...interface{}) {
    	if serverDebugLog {
    		console.Debugln(data...)
    	}
    }
    
    // gatherResults will collect all results on the input channel and filter results according
    // to the options or to the current bucket ILM expiry rules.
    // Caller should close the channel when done.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  10. cmd/erasure-metadata-utils.go

    			continue
    		}
    		if meta.XLV1 != fi.XLV1 {
    			inconsistent++
    			continue
    		}
    		// check if erasure distribution order matches the index
    		// position if this is not correct we discard the disk
    		// and move to collect others
    		if distribution[i] != meta.Erasure.Index {
    			inconsistent++ // keep track of inconsistent entries
    			continue
    		}
    		shuffledDisks[meta.Erasure.Index-1] = disks[i]
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 11.3K bytes
    - Viewed (0)
Back to top