- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for logEntry (0.33 sec)
-
cmd/dynamic-timeouts.go
// did not hit the timeout func (dt *dynamicTimeout) LogSuccess(duration time.Duration) { dt.logEntry(duration) } // LogFailure logs an action that hit the timeout func (dt *dynamicTimeout) LogFailure() { dt.logEntry(maxDuration) } // logEntry stores a log entry func (dt *dynamicTimeout) logEntry(duration time.Duration) { if duration < 0 { return } entries := int(atomic.AddInt64(&dt.entries, 1))
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Aug 19 23:21:05 GMT 2022 - 4.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchLogHelper.java
final int queryMaxLength = fessConfig.getQueryMaxLengthAsInteger(); for (final Map.Entry<String, List<String>> logEntry : fieldLogMap.entrySet()) { for (final String value : logEntry.getValue()) { searchLog.addSearchFieldLogValue(logEntry.getKey(), StringUtils.abbreviate(value, queryMaxLength)); } } }
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 20.8K bytes - Viewed (1) -
internal/logger/target/kafka/kafka.go
h.logChMu.RUnlock() if logCh == nil { return } // Create a routine which sends json logs received // from an internal channel. for entry := range logCh { h.logEntry(entry) } } func (h *Target) logEntry(entry interface{}) { atomic.AddInt64(&h.totalMessages, 1) if err := h.send(entry); err != nil { atomic.AddInt64(&h.failedMessages, 1)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1)