Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 98 for metric (0.18 sec)

  1. cmd/storage-datatypes_gen.go

    		return
    	}
    	z.Rotational, err = dc.ReadBool()
    	if err != nil {
    		err = msgp.WrapError(err, "Rotational")
    		return
    	}
    	err = z.Metrics.DecodeMsg(dc)
    	if err != nil {
    		err = msgp.WrapError(err, "Metrics")
    		return
    	}
    	z.Error, err = dc.ReadString()
    	if err != nil {
    		err = msgp.WrapError(err, "Error")
    		return
    	}
    	return
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 127.5K bytes
    - Viewed (0)
  2. cmd/site-replication.go

    		sm.ReplicaSize += peer.ReplicaSize
    		sm.Proxied.Add(madmin.ReplProxyMetric(peer.Proxied))
    		for dID, v := range peer.Metrics {
    			v2, ok := sm.Metrics[dID]
    			if !ok {
    				v2 = madmin.SRMetric{}
    				v2.Failed.ErrCounts = make(map[string]int)
    			}
    
    			// use target endpoint metrics from node which has been up the longest
    			if v2.LastOnline.After(v.LastOnline) || v2.LastOnline.IsZero() {
    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)
  3. cmd/admin-router.go

    		// DataUsageInfo operations
    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/datausageinfo").HandlerFunc(adminMiddleware(adminAPI.DataUsageInfoHandler, traceAllFlag))
    		// Metrics operation
    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/metrics").HandlerFunc(adminMiddleware(adminAPI.MetricsHandler, traceAllFlag))
    
    		if globalIsDistErasure || globalIsErasure {
    			// Heal operations
    
    			// Heal processing endpoint.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    		}
    		return
    	}
    	defer gr.Close()
    
    	objInfo := gr.ObjInfo
    
    	// make sure we have the latest metadata for metrics calculation
    	rinfo.PrevReplicationStatus = objInfo.TargetReplicationStatus(tgt.ARN)
    
    	size, err := objInfo.GetActualSize()
    	if err != nil {
    		replLogIf(ctx, err)
    		sendEvent(eventArgs{
    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/site-replication-metrics_gen.go

    				return
    			}
    		case "Metrics":
    			var zb0002 uint32
    			zb0002, err = dc.ReadMapHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "Metrics")
    				return
    			}
    			if z.Metrics == nil {
    				z.Metrics = make(map[string]SRMetric, zb0002)
    			} else if len(z.Metrics) > 0 {
    				for key := range z.Metrics {
    					delete(z.Metrics, key)
    				}
    			}
    			for zb0002 > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 40.6K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cluster-notification.go

    )
    
    // loadClusterNotificationMetrics - `MetricsLoaderFn` for cluster notification metrics.
    func loadClusterNotificationMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
    	if globalEventNotifier == nil {
    		return nil
    	}
    
    	nstats := globalEventNotifier.targetList.Stats()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:10:35 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  7. cmd/metrics-v3-system-memory.go

    	memSharedMD    = NewGaugeMD(memShared, "Shared memory on the node")
    	memAvailableMD = NewGaugeMD(memAvailable, "Available memory on the node")
    )
    
    // loadMemoryMetrics - `MetricsLoaderFn` for node memory metrics.
    func loadMemoryMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	memMetrics, err := c.memoryMetrics.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:10:25 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  8. cmd/metrics-v2_gen.go

    func (z MetricTypeV2) Msgsize() (s int) {
    	s = msgp.StringPrefixSize + len(string(z))
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *MetricV2) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 6
    	// string "Description"
    	o = append(o, 0x86, 0xab, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 19.2K bytes
    - Viewed (0)
  9. cmd/admin-server-info.go

    )
    
    // getLocalServerProperty - returns madmin.ServerProperties for only the
    // local endpoints from given list of endpoints
    func getLocalServerProperty(endpointServerPools EndpointServerPools, r *http.Request, metrics bool) madmin.ServerProperties {
    	addr := globalLocalNodeName
    	if r != nil {
    		addr = r.Host
    	}
    	if globalIsDistErasure {
    		addr = globalLocalNodeName
    	}
    	poolNumbers := make(map[int]struct{})
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  10. cmd/storage-datatypes.go

    type RenameOptions struct {
    	BaseOptions
    }
    
    // DiskInfoOptions options for requesting custom results.
    type DiskInfoOptions struct {
    	DiskID  string `msg:"id"`
    	Metrics bool   `msg:"m"`
    	NoOp    bool   `msg:"np"`
    }
    
    // DiskInfo is an extended type which returns current
    // disk usage per path.
    // The above means that any added/deleted fields are incompatible.
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
Back to top