Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for FailedMessages (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top