Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getNodeQueueStats (0.17 sec)

  1. cmd/bucket-stats.go

    	QStats        InQueueMetric                        `json:"queueStats"`
    	MRFStats      ReplicationMRFStats                  `json:"mrfStats"`
    }
    
    // getNodeQueueStats returns replication operational stats at the node level
    func (r *ReplicationStats) getNodeQueueStats(bucket string) (qs ReplQNodeStats) {
    	qs.NodeName = globalLocalNodeName
    	qs.Uptime = UTCNow().Unix() - globalBootTime.Unix()
    	grs := globalReplicationStats.Load()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  2. cmd/notification.go

    	}
    	if st := globalReplicationStats.Load(); st != nil {
    		bucketStats = append(bucketStats, BucketStats{
    			ReplicationStats: st.Get(bucketName),
    			QueueStats:       ReplicationQueueStats{Nodes: []ReplQNodeStats{st.getNodeQueueStats(bucketName)}},
    			ProxyStats:       st.getProxyStats(bucketName),
    		})
    	}
    	return bucketStats
    }
    
    // GetClusterSiteMetrics - calls GetClusterSiteMetrics call on all peers for a cluster statistics view.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  3. cmd/peer-rest-server.go

    	if st == nil {
    		return &BucketStats{}, nil
    	}
    	bs := BucketStats{
    		ReplicationStats: st.Get(bucketName),
    		QueueStats:       ReplicationQueueStats{Nodes: []ReplQNodeStats{st.getNodeQueueStats(bucketName)}},
    		ProxyStats:       st.getProxyStats(bucketName),
    	}
    	return &bs, nil
    }
    
    // GetSRMetricsHandler - fetches current in-memory replication stats at site level from this peer
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top