remove Stats

cosmos/runtime/txpool/handler.go

@@ -52,7 +52,6 @@ type SdkTx interface {
 // TxSubProvider.
 type TxSubProvider interface {
 	SubscribeTransactions(ch chan<- core.NewTxsEvent, reorgs bool) event.Subscription
-	Stats() (int, int)
 }
 
 // TxSerializer provides an interface to Serialize Geth Transactions to Bytes (via sdk.Tx).
@@ -153,9 +152,6 @@ func (h *handler) mainLoop() {
 		case err = <-h.txsSub.Err():
 			h.stopCh <- struct{}{}
 		case event := <-h.txsCh:
-			pending, queue := h.txPool.Stats()
-			telemetry.SetGauge(float32(pending), MetricKeyTxPoolPending)
-			telemetry.SetGauge(float32(queue), MetricKeyTxPoolQueue)
 			telemetry.IncrCounter(float32(len(event.Txs)), MetricKeyCometLocalTxs)
 			h.broadcastTransactions(event.Txs)
 		}

cosmos/runtime/txpool/mempool.go

@@ -108,10 +108,6 @@ func (m *Mempool) Stop() error {
 
 // Insert attempts to insert a Tx into the app-side mempool returning an error upon failure.
 func (m *Mempool) Insert(ctx context.Context, sdkTx sdk.Tx) error {
-	txPoolPending, txPoolQueue := m.TxPool.Stats()
-	telemetry.SetGauge(float32(txPoolPending), MetricKeyTxPoolPending)
-	telemetry.SetGauge(float32(txPoolQueue), MetricKeyTxPoolQueue)
-
 	sCtx := sdk.UnwrapSDKContext(ctx)
 	msgs := sdkTx.GetMsgs()
 	if len(msgs) != 1 {
@@ -130,7 +126,6 @@ func (m *Mempool) Insert(ctx context.Context, sdkTx sdk.Tx) error {
 	// Insert the tx into the txpool as a remote.
 	m.blockBuilderMu.RLock()
 	errs := m.TxPool.Add([]*ethtypes.Transaction{ethTx}, false, false)
-	telemetry.SetGauge(float32(m.CountTx()), MetricKeyMempoolSize)
 	m.blockBuilderMu.RUnlock()
 	if len(errs) > 0 {
 		// Handle case where a node broadcasts to itself, we don't want it to fail CheckTx.