- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for total_messages (0.12 sec)
-
cmd/metrics-v3-audit.go
package cmd import ( "context" "github.com/minio/minio/internal/logger" ) const ( auditFailedMessages = "failed_messages" auditTargetQueueLength = "target_queue_length" auditTotalMessages = "total_messages" targetID = "target_id" ) var ( auditFailedMessagesMD = NewCounterMD(auditFailedMessages, "Total number of messages that failed to send since start", targetID)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 10 14:50:39 UTC 2024 - 1.9K bytes - Viewed (0) -
cmd/metrics-v3-logger-webhook.go
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 ( allWebhookLabels = []string{nameL, endpointL}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 14 07:27:33 UTC 2024 - 2K bytes - Viewed (0) -
cmd/metrics-v2.go
Namespace: minioNamespace, Subsystem: auditSubsystem, Name: "total_messages", Help: "Total number of messages sent since start", Type: counterMetric, }, VariableLabels: map[string]string{"target_id": id}, Value: float64(st.TotalMessages), }) metrics = append(metrics, MetricV2{ Description: MetricDescription{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K 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: h.totalMessages.Load(), FailedMessages: h.failedMessages.Load(), QueueLength: queueLength, } return stats } // AssignMigrateTarget assigns a target
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
cmd/consolelogger.go
return logger.ConsoleLoggerTgt } // Stats returns the target statistics. 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
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0) -
internal/logger/target/types/types.go
) // 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. FailedMessages int64
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Nov 10 18:20:21 UTC 2022 - 1.4K bytes - Viewed (0)