Use VersionedCollapsingMergeTree and insert based deletes

Author: iuwqyir

internal/common/block.go

@@ -6,10 +6,10 @@ import (
 
 type Block struct {
 	ChainId          *big.Int `json:"chain_id" ch:"chain_id"`
-	Number           *big.Int `json:"number" ch:"number"`
+	Number           *big.Int `json:"block_number" ch:"block_number"`
 	Hash             string   `json:"hash" ch:"hash"`
 	ParentHash       string   `json:"parent_hash" ch:"parent_hash"`
-	Timestamp        uint64   `json:"timestamp" ch:"timestamp"`
+	Timestamp        uint64   `json:"block_timestamp" ch:"block_timestamp"`
 	Nonce            string   `json:"nonce" ch:"nonce"`
 	Sha3Uncles       string   `json:"sha3_uncles" ch:"sha3_uncles"`
 	MixHash          string   `json:"mix_hash" ch:"mix_hash"`
@@ -27,6 +27,8 @@ type Block struct {
 	GasUsed          *big.Int `json:"gas_used" ch:"gas_used"`
 	WithdrawalsRoot  string   `json:"withdrawals_root" ch:"withdrawals_root"`
 	BaseFeePerGas    uint64   `json:"base_fee_per_gas" ch:"base_fee_per_gas"`
+	Sign             int8     `json:"sign" ch:"sign"`
+	InsertTimestamp  uint64   `json:"insert_timestamp" ch:"insert_timestamp"`
 }
 
 type BlockData struct {

internal/common/log.go

@@ -25,6 +25,8 @@ type Log struct {
 	Topic1           string   `json:"topic_1" ch:"topic_1"`
 	Topic2           string   `json:"topic_2" ch:"topic_2"`
 	Topic3           string   `json:"topic_3" ch:"topic_3"`
+	Sign             int8     `json:"sign" ch:"sign"`
+	InsertTimestamp  uint64   `json:"insert_timestamp" ch:"insert_timestamp"`
 }
 
 func (l *Log) GetTopic(index int) (string, error) {

internal/common/trace.go

@@ -26,6 +26,8 @@ type Trace struct {
 	Author           string   `json:"author" ch:"author"`
 	RewardType       string   `json:"reward_type" ch:"reward_type"`
 	RefundAddress    string   `json:"refund_address" ch:"refund_address"`
+	Sign             int8     `json:"sign" ch:"sign"`
+	InsertTimestamp  uint64   `json:"insert_timestamp" ch:"insert_timestamp"`
 }
 
 type RawTraces = []map[string]interface{}

internal/common/transaction.go

@@ -40,6 +40,8 @@ type Transaction struct {
 	BlobGasPrice         *big.Int `json:"blob_gas_price" ch:"blob_gas_price" swaggertype:"string"`
 	LogsBloom            *string  `json:"logs_bloom" ch:"logs_bloom"`
 	Status               *uint64  `json:"status" ch:"status"`
+	Sign                 int8     `json:"sign" ch:"sign"`
+	InsertTimestamp      uint64   `json:"insert_timestamp" ch:"insert_timestamp"`
 }
 
 type DecodedTransactionData struct {