Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for targetStatus (0.1 sec)

  1. 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
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K 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. internal/logger/target/types/types.go

    //go:generate stringer -type=TargetType -trimprefix=Target $GOFILE
    
    // Constants for target types
    const (
    	_ TargetType = iota
    	TargetConsole
    	TargetHTTP
    	TargetKafka
    )
    
    // TargetStats contains statistics for a target.
    type TargetStats struct {
    	// QueueLength is the queue length if any messages are queued.
    	QueueLength int
    
    	// TotalMessages is the total number of messages sent in the lifetime of the target
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 10 18:20:21 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  6. 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)
Back to top