- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 193 for qstat (0.19 sec)
-
cmd/bucket-replication-metrics.go
Max: a.Max, } return w } // QStat holds queue stats for replication type QStat struct { Count float64 `json:"count"` Bytes float64 `json:"bytes"` } func (q *QStat) add(o QStat) QStat { return QStat{Bytes: q.Bytes + o.Bytes, Count: q.Count + o.Count} } // InQueueMetric holds queue stats for replication type InQueueMetric struct { Curr QStat `json:"curr" msg:"cq"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/bucket-stats_gen.go
} case "ReplicaCount": z.ReplicaCount, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "ReplicaCount") return } case "QStat": err = z.QStat.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "QStat") return } case "PendingSize": z.PendingSize, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "PendingSize") return
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 57.5K bytes - Viewed (0) -
cmd/bucket-replication-metrics_gen_test.go
t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgQStat(b *testing.B) { v := QStat{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgQStat(b *testing.B) { v := QStat{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0]) b.SetBytes(int64(len(bts))) b.ReportAllocs()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 17.4K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
ReplicatedSize: stat.ReplicatedSize + oldst.ReplicatedSize, ReplicatedCount: stat.ReplicatedCount + oldst.ReplicatedCount, Latency: stat.Latency.merge(oldst.Latency), XferRateLrg: &lrg, XferRateSml: &sml, } totReplicatedSize += stat.ReplicatedSize totReplicatedCount += stat.ReplicatedCount totFailed = totFailed.merge(stat.FailStats) } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cmd/bucket-replication-metrics_gen.go
return } // DecodeMsg implements msgp.Decodable func (z *QStat) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 33.3K bytes - Viewed (0) -
cmd/bucket-stats.go
// Total number of completed operations ReplicatedCount int64 `json:"replicationCount"` // Total number of replica received ReplicaCount int64 `json:"replicaCount"` // in Queue stats for bucket - from qCache QStat InQueueMetric `json:"queued"` // Deprecated fields // Pending size in bytes PendingSize int64 `json:"pendingReplicationSize"` // Failed size in bytes FailedSize int64 `json:"failedReplicationSize"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
internal/disk/stat_linux.go
if err == nil { devName := "" diskstats, _ := bfs.ProcDiskstats() for _, dstat := range diskstats { // ignore all loop devices if strings.HasPrefix(dstat.DeviceName, "loop") { continue } if dstat.MajorNumber == info.Major && dstat.MinorNumber == info.Minor { devName = dstat.DeviceName break } } if devName != "" { info.Name = devName
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0) -
api/except.txt
pkg syscall (freebsd-386), type Stat_t struct, Blksize uint32 pkg syscall (freebsd-386), type Stat_t struct, Dev uint32 pkg syscall (freebsd-386), type Stat_t struct, Gen uint32 pkg syscall (freebsd-386), type Stat_t struct, Ino uint32 pkg syscall (freebsd-386), type Stat_t struct, Lspare int32 pkg syscall (freebsd-386), type Stat_t struct, Nlink uint16 pkg syscall (freebsd-386), type Stat_t struct, Pad_cgo_0 [8]uint8
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu May 25 00:13:30 GMT 2023 - 34.6K bytes - Viewed (0) -
src/archive/tar/stat_actime1.go
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 28 18:17:57 GMT 2021 - 431 bytes - Viewed (0) -
internal/disk/stat_test.go
"testing" ) func TestReadDriveStats(t *testing.T) { if runtime.GOOS == "windows" { t.Skip("skipping this test in windows") } testCases := []struct { stat string expectedIOStats IOStats expectErr bool }{ { stat: "1432553 420084 66247626 2398227 7077314 8720147 157049224 7469810 0 7580552 9869354 46037 0 41695120 1315 0 0", expectedIOStats: IOStats{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 3.6K bytes - Viewed (0)