add telemetry

Author: codchen

app/legacyabci/begin_block.go

@@ -56,6 +56,9 @@ func BeginBlock(
 	slashing.BeginBlocker(ctx, votes, *keepers.SlashingKeeper)
 	evidence.BeginBlocker(ctx, byzantineValidators, *keepers.EvidenceKeeper)
 	staking.BeginBlocker(ctx, *keepers.StakingKeeper)
-	ibcclient.BeginBlocker(ctx, keepers.IBCKeeper.ClientKeeper)
+	func() {
+		defer telemetry.ModuleMeasureSince("ibc", time.Now(), telemetry.MetricKeyBeginBlocker)
+		ibcclient.BeginBlocker(ctx, keepers.IBCKeeper.ClientKeeper)
+	}()
 	keepers.EvmKeeper.BeginBlock(ctx)
 }

sei-cosmos/x/accesscontrol/keeper/abci.go

@@ -1,11 +1,16 @@
 package keeper
 
 import (
+	"time"
+
+	"github.com/cosmos/cosmos-sdk/telemetry"
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	"github.com/cosmos/cosmos-sdk/x/accesscontrol/constants"
+	"github.com/cosmos/cosmos-sdk/x/accesscontrol/types"
 )
 
 func (k *Keeper) EndBlock(ctx sdk.Context) {
+	defer telemetry.ModuleMeasureSince(types.ModuleName, time.Now(), telemetry.MetricKeyEndBlocker)
 	badWasmDependencyAddresses := ctx.Context().Value(constants.BadWasmDependencyAddressesKey)
 	if badWasmDependencyAddresses != nil {
 		typedBadWasmDependencyAddresses, ok := badWasmDependencyAddresses.([]sdk.AccAddress)

x/epoch/keeper/abci.go

@@ -2,13 +2,16 @@ package keeper
 
 import (
 	"fmt"
+	"time"
 
+	"github.com/cosmos/cosmos-sdk/telemetry"
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	"github.com/sei-protocol/sei-chain/utils/metrics"
 	"github.com/sei-protocol/sei-chain/x/epoch/types"
 )
 
 func (k Keeper) BeginBlock(ctx sdk.Context) {
+	defer telemetry.ModuleMeasureSince(types.ModuleName, time.Now(), telemetry.MetricKeyBeginBlocker)
 	lastEpoch := k.GetEpoch(ctx)
 	ctx.Logger().Info(fmt.Sprintf("Current block time %s, last %s; duration %d", ctx.BlockTime().String(), lastEpoch.CurrentEpochStartTime.String(), lastEpoch.EpochDuration))
 

x/evm/keeper/abci.go

@@ -3,9 +3,11 @@ package keeper
 import (
 	"fmt"
 	"math"
+	"time"
 
 	ethtypes "github.com/ethereum/go-ethereum/core/types"
 
+	"github.com/cosmos/cosmos-sdk/telemetry"
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	authtypes "github.com/cosmos/cosmos-sdk/x/auth/types"
 	"github.com/ethereum/go-ethereum/common"
@@ -19,6 +21,7 @@ import (
 )
 
 func (k *Keeper) BeginBlock(ctx sdk.Context) {
+	defer telemetry.ModuleMeasureSince(types.ModuleName, time.Now(), telemetry.MetricKeyBeginBlocker)
 	// clear tx/tx responses from last block
 	if !ctx.IsTracing() {
 		k.SetMsgs([]*types.MsgEVMTransaction{})
@@ -57,6 +60,7 @@ func (k *Keeper) BeginBlock(ctx sdk.Context) {
 }
 
 func (k *Keeper) EndBlock(ctx sdk.Context, height int64, blockGasUsed int64) {
+	defer telemetry.ModuleMeasureSince(types.ModuleName, time.Now(), telemetry.MetricKeyEndBlocker)
 	// TODO: remove after all TxHashes have been removed
 	k.RemoveFirstNTxHashes(ctx, DefaultTxHashesToRemove)