- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for FailedMessages (0.23 sec)
-
internal/logger/target/http/http.go
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 // which will eventually replace the current 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) -
internal/logger/target/kafka/kafka.go
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 { if !h.kconfig.Enabled { return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/security/security.go
peerInfo, ok := peer.FromContext(ctx) peerAddr := "unknown" if ok { peerAddr = peerInfo.Addr.String() } return peerAddr } func (am *authenticationManager) FailedMessages() string { return strings.Join(am.authFailMsgs, "; ") } func ExtractBearerToken(ctx context.Context) (string, error) { md, ok := metadata.FromIncomingContext(ctx) if !ok {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 19.1K bytes - Viewed (0) -
cmd/metrics-v2.go
Help: "Total number of messages that failed to send since start", Type: counterMetric, }, VariableLabels: map[string]string{"target_id": id}, Value: float64(st.FailedMessages), }) } return metrics }) return mg } func getHTTPMetrics(opts MetricsGroupOpts) *MetricsGroupV2 { mg := &MetricsGroupV2{ cacheInterval: 10 * time.Second,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0)