- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for queue_length (0.18 sec)
-
cmd/metrics-v3-logger-webhook.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "github.com/minio/minio/internal/logger" ) const ( webhookQueueLength = "queue_length" webhookTotalMessages = "total_messages" webhookFailedMessages = "failed_messages" nameL = "name" endpointL = "endpoint" ) var (
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 14 07:27:33 UTC 2024 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux.go
watchQueueLength: queueLength, fullChannelBehavior: fullChannelBehavior, } m.distributing.Add(1) go m.loop() return m } // NewLongQueueBroadcaster functions nearly identically to NewBroadcaster, // except that the incoming queue is the same size as the outgoing queues // (specified by queueLength). func NewLongQueueBroadcaster(queueLength int, fullChannelBehavior FullChannelBehavior) *Broadcaster {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:36 UTC 2022 - 9.4K bytes - Viewed (0) -
internal/logger/target/types/types.go
const ( _ TargetType = iota TargetConsole TargetHTTP TargetKafka ) // TargetStats contains statistics for a target. type TargetStats struct { // QueueLength is the queue length if any messages are queued. QueueLength int // TotalMessages is the total number of messages sent in the lifetime of the target TotalMessages int64 // FailedMessages should log message count that failed to send.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Nov 10 18:20:21 UTC 2022 - 1.4K bytes - Viewed (0) -
cmd/metrics-v3-audit.go
audit := logger.CurrentStats() for id, st := range audit { labels := []string{targetID, id} m.Set(auditFailedMessages, float64(st.FailedMessages), labels...) m.Set(auditTargetQueueLength, float64(st.QueueLength), labels...) m.Set(auditTotalMessages, float64(st.TotalMessages), labels...) } return nil
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 10 14:50:39 UTC 2024 - 1.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
// Stats returns the target statistics. func (h *Target) Stats() types.TargetStats { h.logChMu.RLock() queueLength := len(h.logCh) h.logChMu.RUnlock() return types.TargetStats{ TotalMessages: atomic.LoadInt64(&h.totalMessages), FailedMessages: atomic.LoadInt64(&h.failedMessages), QueueLength: queueLength, } } // Init initialize kafka target func (h *Target) Init(ctx context.Context) error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
internal/logger/target/http/http.go
// Stats returns the target statistics. func (h *Target) Stats() types.TargetStats { h.logChMu.RLock() queueLength := len(h.logCh) h.logChMu.RUnlock() stats := types.TargetStats{ TotalMessages: atomic.LoadInt64(&h.totalMessages), FailedMessages: atomic.LoadInt64(&h.failedMessages), QueueLength: queueLength, } return stats } // AssignMigrateTarget assigns a target
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/test/loadbalancersim/mesh/node.go
q: timer.NewQueue(), serviceTime: serviceTime, qLatencyEnabled: enableQueueLatency, } } func (n *Node) Name() string { return n.helper.Name() } func (n *Node) QueueLength() *timeseries.Instance { return &n.qLength } func (n *Node) QueueLatency() *timeseries.Instance { return &n.qLatency } func (n *Node) calcRequestDuration() time.Duration {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 03 18:19:25 UTC 2022 - 3.7K bytes - Viewed (0) -
cmd/consolelogger.go
func (sys *HTTPConsoleLoggerSys) Stats() types.TargetStats { return types.TargetStats{ TotalMessages: atomic.LoadInt64(&sys.totalMessages), FailedMessages: atomic.LoadInt64(&sys.failedMessages), QueueLength: 0, } } // Content returns the console stdout log func (sys *HTTPConsoleLoggerSys) Content() (logs []log.Entry) { sys.RLock() sys.logBuf.Do(func(p interface{}) { if p != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller_test.go
if time.Now().After(timeout) { t.Errorf("Test %q: timed out", test.name) break } if ctrl.queue.Len() > 0 { logger.V(5).Info("Non-empty events queue, processing one", "test", test.name, "queueLength", ctrl.queue.Len()) ctrl.processNextWorkItem(context.TODO()) } if ctrl.queue.Len() > 0 { // There is still some work in the queue, process it now continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
plName = "test-pl" serverConcurrency, plConcurrencyShares, plConcurrency, queueLength = 1, 1, 1, 1 ) apfConfiguration := newConfiguration(fsName, plName, userName, plConcurrencyShares, queueLength) stopCh := make(chan struct{}) controller, controllerCompletedCh := startAPFController(t, stopCh, apfConfiguration, serverConcurrency, plName, plConcurrency)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0)