Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for targetStatus (0.1 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  2. internal/event/targetlist.go

    	list.statLock.RLock()
    	defer list.statLock.RUnlock()
    
    	return list.targetStats[id]
    }
    
    func (list *TargetList) incCurrentSendCalls(id TargetID) {
    	list.statLock.Lock()
    	defer list.statLock.Unlock()
    
    	stats, ok := list.targetStats[id]
    	if !ok {
    		stats = targetStat{}
    	}
    
    	stats.currentSendCalls++
    	list.targetStats[id] = stats
    	return
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. internal/logger/target/testlogger/testlogger.go

    	if tb != nil {
    		tbb := *tb
    		return tbb.Name()
    	}
    	return ""
    }
    
    func (t *testLogger) Endpoint() string {
    	return ""
    }
    
    func (t *testLogger) Stats() types.TargetStats {
    	return types.TargetStats{}
    }
    
    func (t *testLogger) Init(ctx context.Context) error {
    	return nil
    }
    
    func (t *testLogger) IsOnline(ctx context.Context) bool {
    	return t.current.Load() != nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  7. internal/logger/target/http/http.go

    	return h.status.Load() == statusOnline
    }
    
    // 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
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top