Add Checksum Basic Function to Support Later Checksum Validation for Heartbeats

api/v2/changefeed.go

@@ -1541,12 +1541,12 @@ func getVerifiedTables(
 
 func GetKeyspaceValueWithDefault(c *gin.Context) string {
 	if kerneltype.IsClassic() {
-		return common.DefaultKeyspaceNamme
+		return common.DefaultKeyspaceName
 	}
 
 	keyspace := c.Query(api.APIOpVarKeyspace)
 	if keyspace == "" {
-		keyspace = common.DefaultKeyspaceNamme
+		keyspace = common.DefaultKeyspaceName
 	}
 	return keyspace
 }

cmd/kafka-consumer/writer.go

@@ -130,7 +130,7 @@ func newWriter(ctx context.Context, o *option) *writer {
 	log.Info("event router created", zap.Any("protocol", o.protocol),
 		zap.Any("topic", o.topic), zap.Any("dispatcherRules", o.sinkConfig.DispatchRules))
 
-	changefeedID := commonType.NewChangeFeedIDWithName("kafka-consumer", commonType.DefaultKeyspaceNamme)
+	changefeedID := commonType.NewChangeFeedIDWithName("kafka-consumer", commonType.DefaultKeyspaceName)
 	cfg := &config.ChangefeedConfig{
 		ChangefeedID: changefeedID,
 		SinkURI:      o.downstreamURI,

cmd/pulsar-consumer/writer.go

@@ -121,7 +121,7 @@ func newWriter(ctx context.Context, o *option) *writer {
 	log.Info("event router created", zap.Any("protocol", o.protocol),
 		zap.Any("topic", o.topic), zap.Any("dispatcherRules", o.replicaConfig.Sink.DispatchRules))
 
-	changefeedID := commonType.NewChangeFeedIDWithName("pulsar-consumer", commonType.DefaultKeyspaceNamme)
+	changefeedID := commonType.NewChangeFeedIDWithName("pulsar-consumer", commonType.DefaultKeyspaceName)
 	cfg := &config.ChangefeedConfig{
 		ChangefeedID: changefeedID,
 		SinkURI:      o.downstreamURI,

cmd/storage-consumer/consumer.go

@@ -134,7 +134,7 @@ func newConsumer(ctx context.Context) (*consumer, error) {
 		SinkURI:    downstreamURIStr,
 		SinkConfig: replicaConfig.Sink,
 	}
-	sink, err := sink.New(stdCtx, cfg, commonType.NewChangeFeedIDWithName(defaultChangefeedName, commonType.DefaultKeyspaceNamme))
+	sink, err := sink.New(stdCtx, cfg, commonType.NewChangeFeedIDWithName(defaultChangefeedName, commonType.DefaultKeyspaceName))
 	if err != nil {
 		log.Error("failed to create sink", zap.Error(err))
 		return nil, err

downstreamadapter/sink/redo/meta.go

@@ -521,7 +521,7 @@ func getChangefeedMatcher(changeFeedID common.ChangeFeedID) string {
 }
 
 func getDeletedChangefeedMarker(changeFeedID common.ChangeFeedID) string {
-	if changeFeedID.Keyspace() == common.DefaultKeyspaceNamme {
+	if changeFeedID.Keyspace() == common.DefaultKeyspaceName {
 		return fmt.Sprintf("delete_%s", changeFeedID.Name())
 	}
 	return fmt.Sprintf("delete_%s_%s", changeFeedID.Keyspace(), changeFeedID.Name())