optimization: Unified Sorter

cdc/model/kv.go

@@ -11,6 +11,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+//go:generate msgp
+
 package model
 
 import (
@@ -32,6 +34,7 @@ const (
 
 // RegionFeedEvent from the kv layer.
 // Only one of the event will be setted.
+//msgp:ignore RegionFeedEvent
 type RegionFeedEvent struct {
 	Val      *RawKVEntry
 	Resolved *ResolvedSpan
@@ -53,25 +56,26 @@ func (e *RegionFeedEvent) GetValue() interface{} {
 
 // ResolvedSpan guarantees all the KV value event
 // with commit ts less than ResolvedTs has been emitted.
+//msgp:ignore ResolvedSpan
 type ResolvedSpan struct {
 	Span       regionspan.ComparableSpan
 	ResolvedTs uint64
 }
 
 // RawKVEntry notify the KV operator
 type RawKVEntry struct {
-	OpType OpType
-	Key    []byte
+	OpType OpType            `msg:"op_type"`
+	Key    []byte            `msg:"key"`
 	// nil for delete type
-	Value []byte
+	Value []byte             `msg:"value"`
 	// nil for insert type
-	OldValue []byte
-	StartTs  uint64
+	OldValue []byte          `msg:"old_value"`
+	StartTs  uint64          `msg:"start_ts"`
 	// Commit or resolved TS
-	CRTs uint64
+	CRTs uint64              `msg:"crts"`
 
 	// Additonal debug info
-	RegionID uint64
+	RegionID uint64          `msg:"region_id"`
 }
 
 func (v *RawKVEntry) String() string {