Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for targetStatus (0.04 sec)

  1. cmd/admin-handlers.go

    		if tgt.Endpoint() != "" {
    			loggerInfo = append(loggerInfo, madmin.Logger{tgt.String(): targetStatus(ctx, tgt)})
    		}
    	}
    
    	for _, tgt := range logger.AuditTargets() {
    		if tgt.Endpoint() != "" {
    			auditloggerInfo = append(auditloggerInfo, madmin.Audit{tgt.String(): targetStatus(ctx, tgt)})
    		}
    	}
    
    	return loggerInfo, auditloggerInfo
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 99.7K bytes
    - Viewed (0)
  2. internal/logger/targets.go

    func AuditTargets() []Target {
    	return auditTargets.get()
    }
    
    // CurrentStats returns the current statistics.
    func CurrentStats() map[string]types.TargetStats {
    	sys := SystemTargets()
    	audit := AuditTargets()
    	res := make(map[string]types.TargetStats, len(sys)+len(audit))
    	cnt := make(map[string]int, len(sys)+len(audit))
    
    	// Add system and audit.
    	for _, t := range sys {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 6K bytes
    - Viewed (0)
  3. cmd/consolelogger.go

    func (sys *HTTPConsoleLoggerSys) String() string {
    	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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  4. internal/logger/target/kafka/kafka.go

    // String - kafka string
    func (h *Target) String() string {
    	return "kafka"
    }
    
    // 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,
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    					Type:      counterMetric,
    				},
    				Value: float64(nstats.TotalEvents),
    			})
    			for id, st := range nstats.TargetStats {
    				metrics = append(metrics, MetricV2{
    					Description: MetricDescription{
    						Namespace: minioNamespace,
    						Subsystem: notifySubsystem,
    						Name:      "target_total_events",
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 133.6K bytes
    - Viewed (0)
Back to top