core: add some metrics for tx pool and blockchain

Author: Miya Chen

core/blockchain.go

@@ -47,6 +47,9 @@ import (
 
 var (
 	blockInsertTimer = metrics.NewTimer("chain/inserts")
+	txInsertCounter  = metrics.NewCounter("chain/tx/inserts")
+	txInsertMeter    = metrics.NewMeter("chain/tx/insert_rate")
+	forkBlockCounter = metrics.NewCounter("chain/forkblocks")
 
 	ErrNoGenesis = errors.New("Genesis not found in chain")
 )
@@ -852,9 +855,12 @@ func (bc *BlockChain) WriteBlock(block *types.Block) (status WriteStatus, err er
 		status = CanonStatTy
 	} else {
 		status = SideStatTy
+		forkBlockCounter.Inc(1)
 	}
 
 	bc.futureBlocks.Remove(block.Hash())
+	txInsertCounter.Inc(int64(len(block.Transactions())))
+	txInsertMeter.Mark(int64(len(block.Transactions())))
 
 	return
 }

eth/api_backend.go

@@ -31,10 +31,15 @@ import (
 	"github.com/ethereum/go-ethereum/eth/gasprice"
 	"github.com/ethereum/go-ethereum/ethdb"
 	"github.com/ethereum/go-ethereum/event"
+	"github.com/ethereum/go-ethereum/metrics"
 	"github.com/ethereum/go-ethereum/params"
 	"github.com/ethereum/go-ethereum/rpc"
 )
 
+var (
+	txSendCounter = metrics.NewCounter("api/txsend")
+)
+
 // EthApiBackend implements ethapi.Backend for full nodes
 type EthApiBackend struct {
 	eth *Ethereum
@@ -116,6 +121,7 @@ func (b *EthApiBackend) GetEVM(ctx context.Context, msg core.Message, state *sta
 }
 
 func (b *EthApiBackend) SendTx(ctx context.Context, signedTx *types.Transaction) error {
+	txSendCounter.Inc(1)
 	return b.eth.txPool.AddLocal(signedTx)
 }