Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for depID (0.04 sec)

  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 := 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top