- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for FailedMessages (0.17 sec)
-
internal/logger/target/types/types.go
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Nov 10 18:20:21 UTC 2022 - 1.4K bytes - Viewed (0) -
cmd/consolelogger.go
} // 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 func (sys *HTTPConsoleLoggerSys) Content() (logs []log.Entry) { sys.RLock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
cmd/metrics-v3-audit.go
func loadAuditMetrics(_ context.Context, m MetricValues, c *metricsCache) error { 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) -
cmd/metrics-v3-logger-webhook.go
tgts := append(logger.SystemTargets(), logger.AuditTargets()...) for _, t := range tgts { labels := []string{nameL, t.String(), endpointL, t.Endpoint()} m.Set(webhookFailedMessages, float64(t.Stats().FailedMessages), labels...) m.Set(webhookQueueLength, float64(t.Stats().QueueLength), labels...) m.Set(webhookTotalMessages, float64(t.Stats().TotalMessages), labels...) } return nil
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 14 07:27:33 UTC 2024 - 2K bytes - Viewed (0) -
pkg/security/authentication.go
Authenticators: authenticators, } if u := am.authenticate(ctx); u != nil { return u, nil } securityLog.Errorf("Failed to authenticate client from %s: %s", peerInfo.Addr.String(), am.FailedMessages()) return nil, errors.New("authentication failure")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 21 10:09:10 UTC 2023 - 2.2K bytes - Viewed (0)