Emit blocktime as quantile

dydxprotocol · Jul 16, 2024 · cfcf8de · cfcf8de
1 parent b5a530e
commit cfcf8de
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/protocol/lib/metrics/metric_keys.go b/protocol/lib/metrics/metric_keys.go
@@ -49,6 +49,7 @@ const (
 	LiquidationsPercentFilledDistribution                          = "liquidations_percent_filled_distribution"
 	LiquidationsPlacePerpetualLiquidationQuoteQuantumsDistribution = "liquidations_place_perpetual_liquidation_quote_quantums_distribution"
 	RateLimitWithdrawalAmount                                      = "rate_limit_withdrawal_amount"
+	BlockTimeDistribution                                          = "block_time_dist"
 
 	// Measure Since
 	ClobOffsettingSubaccountPerpetualPosition         = "clob_offsetting_subaccount_perpetual_position"

diff --git a/protocol/x/blocktime/keeper/keeper.go b/protocol/x/blocktime/keeper/keeper.go
@@ -103,6 +103,15 @@ func (k Keeper) UpdateAllDowntimeInfo(ctx sdk.Context) {
 		metrics.BlockTimeMs,
 	)
 
+	metrics.AddSampleWithLabels(
+		metrics.BlockTimeDistribution,
+		float32(delta.Milliseconds()),
+		metrics.GetLabelForStringValue(
+			metrics.Proposer,
+			sdk.ConsAddress(ctx.BlockHeader().ProposerAddress).String(),
+		),
+	)
+
 	allInfo := k.GetAllDowntimeInfo(ctx)
 
 	for _, info := range allInfo.Infos {