- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for targetStats (0.2 sec)
-
internal/config/lambda/event/targetlist.go
ID() TargetID IsActive() (bool, error) Send(Event) (*http.Response, error) Stat() TargetStat Close() error } // TargetStats is a collection of stats for multiple targets. type TargetStats struct { TargetStats map[string]TargetStat } // TargetStat is the stats of a single target. type TargetStat struct { ID TargetID ActiveRequests int64 TotalRequests int64 FailedRequests int64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 4.3K bytes - Viewed (0) -
internal/event/targetlist.go
stats, ok := list.targetStats[id] if !ok { // should not happen return } stats.currentSendCalls-- list.targetStats[id] = stats return } func (list *TargetList) incFailedEvents(id TargetID) { list.statLock.Lock() defer list.statLock.Unlock() stats, ok := list.targetStats[id] if !ok { stats = targetStat{} } stats.failedEvents++ list.targetStats[id] = stats
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 10 18:20:21 GMT 2022 - 1.4K bytes - Viewed (0) -
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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/logger/targets.go
defer swapAuditMuRW.RUnlock() res := auditTargets return res } // 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 { key := strings.ToLower(t.Type().String())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 22:56:14 GMT 2024 - 6.1K bytes - Viewed (0) -
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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4K bytes - Viewed (0) -
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) -
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) -
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",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
} // Stat - returns lamdba webhook target statistics such as // current calls in progress, successfully completed functions // failed functions. func (target *WebhookTarget) Stat() event.TargetStat { return event.TargetStat{ ID: target.id, ActiveRequests: atomic.LoadInt64(&target.activeRequests), TotalRequests: atomic.LoadInt64(&target.totalRequests),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 17 20:02:26 GMT 2023 - 6.7K bytes - Viewed (0)