Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for targetStats (0.39 sec)

  1. internal/logger/target/http/http.go

    	return atomic.LoadInt32(&h.status) == 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:  atomic.LoadInt64(&h.totalMessages),
    		FailedMessages: atomic.LoadInt64(&h.failedMessages),
    		QueueLength:    queueLength,
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  2. 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,
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.1K bytes
    - Viewed (1)
  3. cmd/bucket-replication-utils.go

    		return VersionPurgeStatusType(rs.VersionPurgeStatusInternal)
    	default:
    		return getCompositeVersionPurgeStatus(rs.PurgeTargets)
    	}
    }
    
    // TargetState returns replicatedInfos struct initialized with the previous state of replication
    func (rs *ReplicationState) targetState(arn string) (r replicatedTargetInfo) {
    	return replicatedTargetInfo{
    		Arn:                   arn,
    		PrevReplicationStatus: rs.Targets[arn],
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
Back to top