- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for depID (0.02 sec)
-
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 := globalMinioAddr
Registered: Sun Nov 03 19:28:11 UTC 2024 - 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 Nov 03 19:28:11 UTC 2024 - 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K 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 Nov 03 19:28:11 UTC 2024 - 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0) -
cmd/site-replication.go
} }(i) } wg.Wait() errMap := make(map[string]error, len(c.state.Peers)) for i, depID := range depIDs { errMap[depID] = errs[i] if errs[i] != nil && minio.IsNetworkOrHostDown(errs[i], true) { ep := c.state.Peers[depID].Endpoint epURL, _ := url.Parse(ep) if !globalBucketTargetSys.isOffline(epURL) { globalBucketTargetSys.markOffline(epURL) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0)