- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for poolsStatus (0.21 sec)
-
cmd/admin-handlers-pools.go
return } poolsStatus := make([]PoolStatus, len(globalEndpoints)) for idx := range globalEndpoints { status, err := pools.Status(r.Context(), idx) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } poolsStatus[idx] = status } adminLogIf(r.Context(), json.NewEncoder(w).Encode(poolsStatus)) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 00:22:30 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_gen_test.go
} } func BenchmarkMarshalMsgPoolStatus(b *testing.B) { v := PoolStatus{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgPoolStatus(b *testing.B) { v := PoolStatus{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0]) b.SetBytes(int64(len(bts))) b.ReportAllocs()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 12 02:48:43 UTC 2022 - 11K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen.go
if err != nil { err = msgp.WrapError(err, "PoolStats") return } if cap(z.PoolStats) >= int(zb0002) { z.PoolStats = (z.PoolStats)[:zb0002] } else { z.PoolStats = make([]*rebalanceStats, zb0002) } for za0001 := range z.PoolStats { if dc.IsNil() { err = dc.ReadNil() if err != nil { err = msgp.WrapError(err, "PoolStats", za0001) return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 26.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_gen.go
return } // DecodeMsg implements msgp.Decodable func (z *PoolStatus) 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 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 04 21:02:54 UTC 2022 - 26.7K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} // Clone returns a copy of PoolStatus func (ps PoolStatus) Clone() PoolStatus { return PoolStatus{ ID: ps.ID, CmdLine: ps.CmdLine, LastUpdate: ps.LastUpdate, Decommission: ps.Decommission.Clone(), } } //go:generate msgp -file $GOFILE -unexported type poolMeta struct { Version int `msg:"v"` Pools []PoolStatus `msg:"pls"`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 42.2K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
r := z.rebalMeta poolStats := r.PoolStats[poolIdx] if poolStats.Info.Status == rebalCompleted { return true } pfi := float64(poolStats.InitFreeSpace+poolStats.Bytes) / float64(poolStats.InitCapacity) // Mark pool rebalance as done if within 5% from PercentFreeGoal. if diff := math.Abs(pfi - r.PercentFreeGoal); diff <= 0.05 { r.PoolStats[poolIdx].Info.Status = rebalCompleted
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 28.4K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_test.go
pools[1], pools[0], } var nmeta1 poolMeta nmeta1.Version = poolMetaVersion nmeta1.Pools = append(nmeta1.Pools, meta.Pools...) for i, pool := range nmeta1.Pools { if i == 0 { nmeta1.Pools[i] = PoolStatus{ CmdLine: pool.CmdLine, ID: i, LastUpdate: UTCNow(), Decommission: &PoolDecommissionInfo{ Complete: true, }, } } } var nmeta2 poolMeta
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 01 14:38:46 UTC 2024 - 4.8K bytes - Viewed (0) -
cmd/rebalance-admin.go
} stopTime := meta.StoppedAt r = rebalanceAdminStatus{ ID: meta.ID, StoppedAt: meta.StoppedAt, Pools: make([]rebalancePoolStatus, len(meta.PoolStats)), } for i, ps := range meta.PoolStats { r.Pools[i] = rebalancePoolStatus{ ID: i, Status: ps.Info.Status.String(), Used: float64(diskStats[i].TotalSpace-diskStats[i].AvailableSpace) / float64(diskStats[i].TotalSpace), }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Dec 22 00:56:43 UTC 2023 - 3.8K bytes - Viewed (0)