- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,470 for statx (0.06 sec)
-
pilot/pkg/networking/core/networkfilter.go
func buildRedisFilter(statPrefix, clusterName string) *listener.Filter { redisProxy := &redis.RedisProxy{ LatencyInMicros: true, // redis latency stats are captured in micro seconds which is typically the case. StatPrefix: statPrefix, // redis stats are prefixed with redis.<statPrefix> by Envoy Settings: &redis.RedisProxy_ConnPoolSettings{ OpTimeout: durationpb.New(redisOpTimeout), },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
src/internal/trace/summary.go
// Necessarily overlaps with other stats. TotalTime time.Duration // Total time the goroutine spent in certain ranges; may overlap // with other stats. RangeTime map[string]time.Duration } func (s GoroutineExecStats) NonOverlappingStats() map[string]time.Duration { stats := map[string]time.Duration{ "Execution time": s.ExecTime,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 20.7K bytes - Viewed (0) -
pkg/envoy/agent.go
activeConnectionsURL := fmt.Sprintf("http://%s/stats?usedonly&filter=downstream_cx_active$", adminHost) stats, err := http.DoHTTPGetWithTimeout(activeConnectionsURL, 2*time.Second) if err != nil { return -1, fmt.Errorf("unable to get listener stats from Envoy : %v", err) } if stats.Len() == 0 { return -1, nil } activeConnections := 0 for stats.Len() > 0 { line, _ := stats.ReadString('\n')
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
src/runtime/mgcsweep.go
if sl.sweepGen != mheap_.sweepgen { throw("sweeper left outstanding across sweep generations") } for { state := a.state.Load() if (state&^sweepDrainedMask)-1 >= sweepDrainedMask { throw("mismatched begin/end of activeSweep") } if a.state.CompareAndSwap(state, state-1) { if state != sweepDrainedMask { return } if debug.gcpacertrace > 0 { live := gcController.heapLive.Load()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:52:18 UTC 2024 - 32.9K bytes - Viewed (0) -
platforms/core-runtime/native/src/jmh/java/org/gradle/internal/nativeintegration/filesystem/FileMetadataAccessorBenchmark.java
bh.consume(getAccessor(accessorClassName).stat(missing)); } @Benchmark public void stat_directory(Blackhole bh) { bh.consume(getAccessor(accessorClassName).stat(directory)); } @Benchmark public void stat_existing(Blackhole bh) { bh.consume(getAccessor(accessorClassName).stat(realFile)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:50:56 UTC 2024 - 5.2K bytes - Viewed (0) -
cmd/site-replication.go
return err } var state srState if !unlinkSelf { state = srState{ Name: c.state.Name, Peers: updatedPeers, ServiceAccountAccessKey: c.state.ServiceAccountAccessKey, } } if err := c.saveToDisk(ctx, state); err != nil { return errSRBackendIssue(fmt.Errorf("unable to save cluster-replication state to drive on %s: %v", ourName, err)) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_test.go
NewFakeHostStatsProvider(), false, ) stats, containerStats, err := provider.ImageFsStats(ctx) assert := assert.New(t) assert.NoError(err) assert.Equal(imageFsUsage.Timestamp, stats.Time.UnixNano()) assert.Equal(imageFsInfo.Available, *stats.AvailableBytes) assert.Equal(imageFsInfo.Capacity, *stats.CapacityBytes) assert.Equal(imageFsInfo.InodesFree, stats.InodesFree) assert.Equal(imageFsInfo.Inodes, stats.Inodes)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0) -
cmd/admin-server-info.go
gcStats := debug.GCStats{ // If stats.PauseQuantiles is non-empty, ReadGCStats fills // it with quantiles summarizing the distribution of pause time. // For example, if len(stats.PauseQuantiles) is 5, it will be // filled with the minimum, 25%, 50%, 75%, and maximum pause times. PauseQuantiles: make([]time.Duration, 5), } debug.ReadGCStats(&gcStats) // Truncate GC stats to max 5 entries. if len(gcStats.PauseEnd) > 5 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.9K bytes - Viewed (0) -
src/runtime/mstats.go
stats.GCSys = memstats.gcMiscSys.load() + gcWorkBufInUse + gcProgPtrScalarBitsInUse stats.OtherSys = memstats.other_sys.load() stats.NextGC = heapGoal stats.LastGC = memstats.last_gc_unix stats.PauseTotalNs = memstats.pause_total_ns stats.PauseNs = memstats.pause_ns stats.PauseEnd = memstats.pause_end stats.NumGC = memstats.numgc stats.NumForcedGC = memstats.numforcedgc
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 21:03:13 UTC 2024 - 34.2K bytes - Viewed (0) -
pkg/kubelet/logs/container_log_manager_test.go
c := &containerLogManager{osInterface: container.RealOS{}} require.NoError(t, c.compressLog(testLog)) _, err = os.Stat(testLog + compressSuffix) assert.NoError(t, err, "log should be compressed") _, err = os.Stat(testLog + tmpSuffix) assert.Error(t, err, "temporary log should be renamed") _, err = os.Stat(testLog) assert.Error(t, err, "original log should be removed") rc, err := UncompressLog(testLog + compressSuffix)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.7K bytes - Viewed (0)