[go.mod] bump for throughput metrics and metrics fix (#801)

* [go.mod] bump for throughput metrics and metrics fix

* bump

Author: BrandonWeng

app/app.go

@@ -1001,32 +1001,13 @@ func (app *App) FinalizeBlocker(ctx sdk.Context, req *abci.RequestFinalizeBlock)
 	return &resp, nil
 }
 
-func (app *App) RecordAndEmitMetrics(ctx sdk.Context) {
-	height := float32(ctx.BlockHeight())
-	if (*app.metricCounter)["last_updated_height"] == height {
-		app.Logger().Debug("Metrics already recorded for this block", "height", height)
-		return
-	}
-
-	for metricName, value := range *ctx.ContextMemCache().GetMetricCounters() {
-		(*app.metricCounter)[metricName] += float32(value)
-	}
-	(*app.metricCounter)["last_updated_height"] = height
-
-	for metricName, value := range *(app.metricCounter) {
-		metrics.SetThroughputMetric(metricName, value)
-	}
-
-	ctx.ContextMemCache().Clear()
-}
-
 func (app *App) DeliverTxWithResult(ctx sdk.Context, tx []byte) *abci.ExecTxResult {
 	deliverTxResp := app.DeliverTx(ctx, abci.RequestDeliverTx{
 		Tx: tx,
 	})
 
-	ctx.ContextMemCache().IncrMetricCounter(uint32(deliverTxResp.GasWanted), "gas_wanted")
-	ctx.ContextMemCache().IncrMetricCounter(uint32(deliverTxResp.GasUsed), "gas_used")
+	metrics.IncrGasCounter("gas_used", deliverTxResp.GasUsed)
+	metrics.IncrGasCounter("gas_wanted", deliverTxResp.GasWanted)
 
 	return &abci.ExecTxResult{
 		Code:      deliverTxResp.Code,
@@ -1345,7 +1326,6 @@ func (app *App) ProcessBlock(ctx sdk.Context, txs [][]byte, req BlockProcessRequ
 	})
 
 	events = append(events, endBlockResp.Events...)
-	app.RecordAndEmitMetrics(ctx)
 	return events, txResults, endBlockResp, nil
 }
 

go.mod

@@ -269,7 +269,7 @@ require (
 replace (
 	github.com/CosmWasm/wasmd => github.com/sei-protocol/sei-wasmd v0.0.2
 	github.com/confio/ics23/go => github.com/cosmos/cosmos-sdk/ics23/go v0.8.0
-	github.com/cosmos/cosmos-sdk => github.com/sei-protocol/sei-cosmos v0.2.34
+	github.com/cosmos/cosmos-sdk => github.com/sei-protocol/sei-cosmos v0.2.35
 	github.com/cosmos/iavl => github.com/sei-protocol/sei-iavl v0.1.4
 	github.com/gogo/protobuf => github.com/regen-network/protobuf v1.3.3-alpha.regen.1
 	github.com/keybase/go-keychain => github.com/99designs/go-keychain v0.0.0-20191008050251-8e49817e8af4

go.sum

@@ -1067,8 +1067,8 @@ github.com/seccomp/libseccomp-golang v0.9.2-0.20220502022130-f33da4d89646/go.mod
 github.com/securego/gosec/v2 v2.11.0 h1:+PDkpzR41OI2jrw1q6AdXZCbsNGNGT7pQjal0H0cArI=
 github.com/securego/gosec/v2 v2.11.0/go.mod h1:SX8bptShuG8reGC0XS09+a4H2BoWSJi+fscA+Pulbpo=
 github.com/segmentio/fasthash v1.0.3/go.mod h1:waKX8l2N8yckOgmSsXJi7x1ZfdKZ4x7KRMzBtS3oedY=
-github.com/sei-protocol/sei-cosmos v0.2.34 h1:7VYsZn4W8FMlP7gEu8JTYAhD4JGYCGOY70AFRVwCUwg=
-github.com/sei-protocol/sei-cosmos v0.2.34/go.mod h1:eV7NmvcXn1D6A3EDvOFZ894tqm+/JW4CWUiohnamjfM=
+github.com/sei-protocol/sei-cosmos v0.2.35 h1:VfbkGXP2GJBi+/7Eu1pbV4ea+g1KzjatrAXLVrZR+Q4=
+github.com/sei-protocol/sei-cosmos v0.2.35/go.mod h1:eV7NmvcXn1D6A3EDvOFZ894tqm+/JW4CWUiohnamjfM=
 github.com/sei-protocol/sei-iavl v0.1.4 h1:lT5doPDTBq/UlbofQbM5iS01FbTSJttmA22+d0PJj5o=
 github.com/sei-protocol/sei-iavl v0.1.4/go.mod h1:7PfkEVT5dcoQE+s/9KWdoXJ8VVVP1QpYYPLdxlkSXFk=
 github.com/sei-protocol/sei-tendermint v0.2.17 h1:TwOVyF8F+Of2G8UEt0ShHDFQcFNmbGy4/c5Uui5UHqg=

utils/metrics/metrics_util.go

@@ -197,3 +197,15 @@ func SetCoinsMinted(amount uint64, denom string) {
 		[]metrics.Label{telemetry.NewLabel("denom", denom)},
 	)
 }
+
+// Measures the number of times the total block gas wanted in the proposal exceeds the max
+// Metric Name:
+//
+//	sei_tx_gas_counter
+func IncrGasCounter(gasType string, value int64) {
+	telemetry.IncrCounterWithLabels(
+		[]string{"sei", "tx", "gas", "counter"},
+		float32(value),
+		[]metrics.Label{telemetry.NewLabel("type", gasType)},
+	)
+}

x/dex/keeper/msgserver/msg_server_place_orders.go

@@ -45,8 +45,6 @@ func (k msgServer) transferFunds(goCtx context.Context, msg *types.MsgPlaceOrder
 func (k msgServer) PlaceOrders(goCtx context.Context, msg *types.MsgPlaceOrders) (*types.MsgPlaceOrdersResponse, error) {
 	ctx := sdk.UnwrapSDKContext(goCtx)
 
-	defer ctx.ContextMemCache().IncrMetricCounter(uint32(len(msg.Orders)), sdk.ORDER_COUNT)
-
 	if err := msg.ValidateBasic(); err != nil {
 		ctx.Logger().Error(fmt.Sprintf("request invalid: %s", err))
 		return nil, err