cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

more metrics!

Browse Source
This commit is contained in:
whyrusleeping 2020-09-01 15:11:02 -07:00
parent 7d1d690eb7
commit 8414aa6e4b
1 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
cmd/lotus-shed/mempool-stats.go
View File

@ -20,9 +20,11 @@ import (
) )
var ( var (
MpoolAge = stats.Float64("mpoolage", "Age of messages in the mempool", stats.UnitSeconds) MpoolAge = stats.Float64("mpoolage", "Age of messages in the mempool", stats.UnitSeconds)
MpoolSize = stats.Int64("mpoolsize", "Number of messages in mempool", stats.UnitDimensionless) MpoolSize = stats.Int64("mpoolsize", "Number of messages in mempool", stats.UnitDimensionless)
MpoolInboundRate = stats.Int64("inbound", "Counter for inbound messages", stats.UnitDimensionless) MpoolInboundRate = stats.Int64("inbound", "Counter for inbound messages", stats.UnitDimensionless)
BlockInclusionRate = stats.Int64("inclusion", "Counter for message included in blocks", stats.UnitDimensionless)
MsgWaitTime = stats.Float64("msg-wait-time", "Wait time of messages to make it into a block", stats.UnitSeconds)
) )
var ( var (
@ -46,6 +48,16 @@ var (
Measure: MpoolInboundRate, Measure: MpoolInboundRate,
Aggregation: view.Count(), Aggregation: view.Count(),
} }
InclusionRate = &view.View{
Name: "msg-inclusion",
Measure: BlockInclusionRate,
Aggregation: view.Count(),
}
MsgWait = &view.View{
Name: "msg-wait",
Measure: MsgWaitTime,
Aggregation: view.Distribution(10, 30, 60, 120, 240, 600, 1800, 3600),
}
) )
type msgInfo struct { type msgInfo struct {
@ -58,7 +70,7 @@ var mpoolStatsCmd = &cli.Command{
Action: func(cctx *cli.Context) error { Action: func(cctx *cli.Context) error {
logging.SetLogLevel("rpc", "ERROR") logging.SetLogLevel("rpc", "ERROR")
if err := view.Register(AgeView); err != nil { if err := view.Register(AgeView, SizeView, InboundRate, InclusionRate, MsgWait); err != nil {
return err return err
} }
@ -108,6 +120,8 @@ var mpoolStatsCmd = &cli.Command{
continue continue
} }
fmt.Printf("%s was in the mempool for %s (feecap=%s, prem=%s)\n", u.Message.Cid(), time.Since(mi.seen), u.Message.Message.GasFeeCap, u.Message.Message.GasPremium) fmt.Printf("%s was in the mempool for %s (feecap=%s, prem=%s)\n", u.Message.Cid(), time.Since(mi.seen), u.Message.Message.GasFeeCap, u.Message.Message.GasPremium)
stats.Record(ctx, BlockInclusionRate.M(1))
stats.Record(ctx, MsgWaitTime.M(time.Since(mi.seen).Seconds()))
delete(tracker, u.Message.Cid()) delete(tracker, u.Message.Cid())
default: default:
return fmt.Errorf("unrecognized mpool update state: %d", u.Type) return fmt.Errorf("unrecognized mpool update state: %d", u.Type)