feat: traces block height and timestamp for InfluxDB

consensus/state.go

@@ -1712,6 +1712,9 @@ func (cs *State) finalizeCommit(height int64) {
 	// must be called before we update state
 	cs.recordMetrics(height, block)
 
+	// trace some metadata about the block
+	schema.WriteBlock(cs.traceClient, block.Header.Height, block.Header.Time)
+
 	// NewHeightStep!
 	cs.updateToState(stateCopy)
 

pkg/trace/schema/consensus.go

@@ -1,6 +1,8 @@
 package schema
 
 import (
+	"time"
+
 	cstypes "github.com/tendermint/tendermint/consensus/types"
 	"github.com/tendermint/tendermint/p2p"
 	"github.com/tendermint/tendermint/pkg/trace"
@@ -12,6 +14,7 @@ func ConsensusTables() []string {
 	return []string{
 		RoundStateTable,
 		BlockPartsTable,
+		BlockTable,
 	}
 }
 
@@ -81,3 +84,22 @@ func WriteBlockPart(
 		TransferTypeFieldKey:   transferType,
 	})
 }
+
+const (
+	// BlockTable is the name of the table that stores metadata about consensus blocks.
+	// following schema:
+	//
+	//  | time  | height | timestamp |
+	BlockTable = "consensus_block_time"
+
+	// TimestampFieldKey is the name of the field that stores the time at which
+	// the block is proposed.
+	TimestampFieldKey = "timestamp"
+)
+
+func WriteBlock(client *trace.Client, height int64, blockTimestamp time.Time) {
+	client.WritePoint(BlockTable, map[string]interface{}{
+		HeightFieldKey:    height,
+		TimestampFieldKey: blockTimestamp,
+	})
+}