- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 73 for Stats (0.18 sec)
-
internal/disk/disk.go
Used uint64 Files uint64 Ffree uint64 FSType string Major uint32 Minor uint32 Name string Rotational *bool NRRequests uint64 } // IOStats contains stats of a single drive type IOStats struct { ReadIOs uint64 ReadMerges uint64 ReadSectors uint64 ReadTicks uint64 WriteIOs uint64 WriteMerges uint64 WriteSectors uint64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 1.7K bytes - Viewed (0) -
internal/s3select/select.go
} func (s3Select *S3Select) getProgress() (bytesScanned, bytesProcessed int64) { if s3Select.progressReader != nil { return s3Select.progressReader.Stats() } return -1, -1 } // Open - opens S3 object by using callback for SQL selection query. // Currently CSV, JSON and Apache Parquet formats are supported.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
internal/disk/stat_solaris.go
} info.Used = info.Total - info.Free return info, nil } // GetDriveStats returns IO stats of the drive by its major:minor func GetDriveStats(major, minor uint32) (iostats IOStats, err error) { return IOStats{}, errors.New("operation unsupported")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 1.8K bytes - Viewed (0) -
internal/disk/stat_bsd.go
} info.Used = info.Total - info.Free return info, nil } // GetDriveStats returns IO stats of the drive by its major:minor func GetDriveStats(major, minor uint32) (iostats IOStats, err error) { return IOStats{}, errors.New("operation unsupported")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 1.7K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
PercentFreeGoal float64 `msg:"pf"` // Computed from total free space and capacity at the start of rebalance PoolStats []*rebalanceStats `msg:"rss"` // Per-pool rebalance stats keyed by pool index } var errRebalanceNotStarted = errors.New("rebalance not started") func (z *erasureServerPools) loadRebalanceMeta(ctx context.Context) error { r := &rebalanceMeta{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
func (h *Target) Endpoint() string { return "kafka" } // 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),
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) -
internal/logger/target/testlogger/testlogger.go
tb := t.current.Load() 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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4K bytes - Viewed (0) -
cmd/erasure-server-pool.go
for _, set := range s.sets { for _, disk := range set.getDisks() { if disk == OfflineDisk { continue } stats, err := disk.StatInfoFile(ctx, volume, file, true) if err != nil { continue } for _, si := range stats { found++ var r io.ReadCloser if !si.Dir { r, err = disk.ReadFileStream(ctx, volume, si.Name, 0, si.Size) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
internal/s3select/genmessage.go
buf.WriteByte(7) buf.Write([]byte{0, 8}) buf.WriteString("text/xml") buf.WriteByte(11) buf.WriteString(":event-type") buf.WriteByte(7) buf.Write([]byte{0, 5}) buf.WriteString("Stats") fmt.Println(buf.Bytes()) } // End Message // =========== // Header specification // -------------------- // End messages contain two headers, as follows:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 4.4K bytes - Viewed (0) -
cmd/peer-rest-server.go
bucketStatsMap[k] = BucketStats{ ReplicationStats: v, ProxyStats: globalReplicationStats.getProxyStats(k), } } return &BucketStatsMap{Stats: bucketStatsMap, Timestamp: time.Now()}, nil } // GetBucketStatsHandler - fetches current in-memory bucket stats, currently only // returns BucketStats, that currently includes ReplicationStats.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0)