- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for stats (0.25 sec)
-
cmd/consolelogger.go
} // String - stringer function for interface compatibility 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,
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) -
cmd/metrics-v3-cluster-notification.go
if globalEventNotifier == nil { return nil } nstats := globalEventNotifier.targetList.Stats() m.Set(notificationCurrentSendInProgress, float64(nstats.CurrentSendCalls)) m.Set(notificationEventsErrorsTotal, float64(nstats.EventsErrorsTotal)) m.Set(notificationEventsSentTotal, float64(nstats.TotalEvents)) m.Set(notificationEventsSkippedTotal, float64(nstats.EventsSkipped)) return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:10:35 GMT 2024 - 2.2K bytes - Viewed (0) -
cmd/metrics-v3-system-drive.go
driveRealtimeMetrics := collectLocalMetrics(types, collectMetricsOpts{ hosts: map[string]struct{}{ globalLocalNodeName: {}, }, }) stats := map[string]madmin.DiskIOStats{} for d, m := range driveRealtimeMetrics.ByDisk { stats[d] = m.IOStats } return stats } func (m *MetricValues) setDriveBasicMetrics(drive madmin.Disk, labels []string) { m.Set(driveUsedBytes, float64(drive.UsedSpace), labels...)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 7.8K bytes - Viewed (0) -
cmd/metrics-v3-system-process.go
) func loadProcStatMetrics(ctx context.Context, stat procfs.ProcStat, m MetricValues) { if stat.CPUTime() > 0 { m.Set(processCPUTotalSeconds, float64(stat.CPUTime())) } if stat.ResidentMemory() > 0 { m.Set(processResidentMemoryBytes, float64(stat.ResidentMemory())) } if stat.VirtualMemory() > 0 { m.Set(processVirtualMemoryBytes, float64(stat.VirtualMemory())) } startTime, err := stat.StartTime()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 6.4K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/certificates.go
for _, secret := range secretDump { if strings.Contains(secret.State, "Unavailable") { secret.State = "Unavailable" } if len(secret.CertChain) == 0 { fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\t%v\n", secret.Identity, valueOrNA(""), secret.State, false, valueOrNA(""), valueOrNA(""), valueOrNA("")) } else { for i, ca := range secret.CertChain { t := "Intermediate"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 3.2K bytes - Viewed (0) -
internal/http/listener.go
acceptCh chan acceptResult // channel where all TCP listeners write accepted connection. ctx context.Context ctxCanceler context.CancelFunc } // start - starts separate goroutine for each TCP listener. A valid new connection is passed to httpListener.acceptCh. func (listener *httpListener) start() { // Closure to send acceptResult to acceptCh.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/api.go
Identity string `json:"identity"` State string `json:"state"` CertChain []*Cert `json:"certChain"` } type Cert struct { Pem string `json:"pem"` SerialNumber string `json:"serialNumber"` ValidFrom string `json:"validFrom"` ExpirationTime string `json:"expirationTime"` } type WorkloadState struct { State string `json:"state,omitempty"`
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 02:16:06 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/data-scanner_test.go
<Status>Enabled</Status> <ID>DeleteAllVersions</ID> </Rule> </LifecycleConfiguration>` delMarkerILM := `<LifecycleConfiguration> <Rule> <ID>DelMarkerExpiration</ID> <Filter></Filter> <Status>Enabled</Status>
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
internal/logger/console.go
// of splitting error text and always pretty printing the // red banner along with the error message. Since the error // message itself contains some colored text, we needed // to use some ANSI control escapes to cursor color state // and freely move in the screen. for _, line := range strings.Split(errMsg, "\n") { if len(line) == 0 { // No more text to print, just quit. break } for {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/http/dial_linux.go
/// Enable keep-alive { _ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_KEEPALIVE, 1) // The time (in seconds) the connection needs to remain idle before // TCP starts sending keepalive probes _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPIDLE, 15) // Number of probes. // ~ cat /proc/sys/net/ipv4/tcp_keepalive_probes (defaults to 9, we reduce it to 5)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 4.3K bytes - Viewed (3)