Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for targetStatus (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  2. internal/config/lambda/event/targetlist.go

    }
    
    // Stats returns stats for targets.
    func (list *TargetList) Stats() TargetStats {
    	t := TargetStats{}
    	if list == nil {
    		return t
    	}
    	list.RLock()
    	defer list.RUnlock()
    	t.TargetStats = make(map[string]TargetStat, len(list.targets))
    	for id, target := range list.targets {
    		t.TargetStats[strings.ReplaceAll(id.String(), ":", "_")] = target.Stat()
    	}
    	return t
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  3. 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
    }
    
    func (list *TargetList) decCurrentSendCalls(id TargetID) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  4. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6K bytes
    - Click Count (0)
  5. 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
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4K bytes
    - Click Count (0)
  6. 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
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  7. 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",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
Back to Top