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

Export Mpool-count

Browse Source 
Record the current size of the mpool and export through Prometheus
This commit is contained in:
Phi 2023-10-30 08:07:09 +00:00
parent 3f00691f26
commit d1b8af338e
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
chain/messagepool/messagepool.go
View File

@ -21,6 +21,7 @@ import (
pubsub "github.com/libp2p/go-libp2p-pubsub"
"github.com/minio/blake2b-simd"
"github.com/raulk/clock"
"go.opencensus.io/stats"
"golang.org/x/xerrors"
ffi "github.com/filecoin-project/filecoin-ffi"
@ -1213,6 +1214,9 @@ func (mp *MessagePool) remove(ctx context.Context, from address.Address, nonce u
return
}
}
// Record the current size of the Mpool
stats.Record(ctx, metrics.MpoolMessageCount.M(int64(mp.currentSize)))
}
func (mp *MessagePool) Pending(ctx context.Context) ([]*types.SignedMessage, *types.TipSet) {

6
metrics/metrics.go
View File

@ -106,6 +106,7 @@ var (
MpoolAddTsDuration = stats.Float64("mpool/addts_ms", "Duration of addTs in mpool", stats.UnitMilliseconds)
MpoolAddDuration = stats.Float64("mpool/add_ms", "Duration of Add in mpool", stats.UnitMilliseconds)
MpoolPushDuration = stats.Float64("mpool/push_ms", "Duration of Push in mpool", stats.UnitMilliseconds)
MpoolMessageCount = stats.Int64("mpool/message_count", "Number of messages in the mpool", stats.UnitDimensionless)
BlockPublished = stats.Int64("block/published", "Counter for total locally published blocks", stats.UnitDimensionless)
BlockReceived = stats.Int64("block/received", "Counter for total received blocks", stats.UnitDimensionless)
BlockValidationFailure = stats.Int64("block/failure", "Counter for block validation failures", stats.UnitDimensionless)
@ -307,6 +308,10 @@ var (
Measure: MpoolPushDuration,
Aggregation: defaultMillisecondsDistribution,
}
MpoolMessageCountView = &view.View{
Measure: MpoolMessageCount,
Aggregation: view.LastValue(),
}
PeerCountView = &view.View{
Measure: PeerCount,
Aggregation: view.LastValue(),
@ -761,6 +766,7 @@ var ChainNodeViews = append([]*view.View{
MpoolAddTsDurationView,
MpoolAddDurationView,
MpoolPushDurationView,
MpoolMessageCountView,
PubsubPublishMessageView,
PubsubDeliverMessageView,
PubsubRejectMessageView,