Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getNodeQueueStats (0.06 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.5K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
Back to top