- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for depIdx (0.03 sec)
-
cmd/site-replication.go
depIDs := make([]string, 0, len(c.state.Peers)) for d := range c.state.Peers { depIDs = append(depIDs, d) } errs := make([]error, len(c.state.Peers)) var wg sync.WaitGroup wg.Add(len(depIDs)) for i := range depIDs { go func(i int) { defer wg.Done() if depIDs[i] == globalDeploymentID() { if selfActionFn != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 184.7K bytes - Viewed (1) -
cmd/metrics-realtime.go
c "github.com/shirou/gopsutil/v3/cpu" "github.com/shirou/gopsutil/v3/load" ) type collectMetricsOpts struct { hosts map[string]struct{} disks map[string]struct{} jobID string depID string } func collectLocalMetrics(types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) { if types == madmin.MetricsNone { return } byHostName := globalMinioAddrRegistered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sat Jun 01 05:16:24 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/peer-rest-common.go
peerRESTAccessKey = "access-key" peerRESTMetricsTypes = "types" peerRESTDisk = "disk" peerRESTHost = "host" peerRESTJobID = "job-id" peerRESTDepID = "depID" peerRESTStartRebalance = "start-rebalance" peerRESTMetrics = "metrics" peerRESTDryRun = "dry-run" peerRESTUploadID = "up-id" peerRESTURL = "url"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 3K bytes - Viewed (0) -
cmd/admin-handlers.go
} } } dID := r.Form.Get("by-depID") done := ctx.Done() ticker := time.NewTicker(interval) defer ticker.Stop() w.Header().Set(xhttp.ContentType, string(mimeJSON)) enc := json.NewEncoder(w) for n > 0 { var m madmin.RealtimeMetrics mLocal := collectLocalMetrics(types, collectMetricsOpts{ hosts: hostMap, disks: diskMap, jobID: jobID, depID: dID, }) m.Merge(&mLocal)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 99.6K bytes - Viewed (0) -
cmd/peer-rest-client.go
for disk := range opts.disks { values.Add(peerRESTDisk, disk) } for host := range opts.hosts { values.Add(peerRESTHost, host) } values.Set(peerRESTJobID, opts.jobID) values.Set(peerRESTDepID, opts.depID) v, err := getMetricsRPC.Call(ctx, client.gridConn(), grid.NewURLValuesWith(values)) return v.ValueOrZero(), err } // GetProcInfo - fetch MinIO process information for a remote node.Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 26.1K bytes - Viewed (0) -
cmd/peer-rest-server.go
hostMap[host] = struct{}{} } info := collectLocalMetrics(types, collectMetricsOpts{ disks: diskMap, hosts: hostMap, jobID: values.Get(peerRESTJobID), depID: values.Get(peerRESTDepID), }) return madminRealtimeMetrics.NewJSONWith(&info), nil } // GetSysConfigHandler - returns system config information. // (only the config that are of concern to minio)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 53.4K bytes - Viewed (0)