replace the underline naming in the code with the hump naming method

pkg/protocol/codec/branch_commit_req_codec.go

@@ -57,5 +57,5 @@ func (g *BranchCommitRequestCodec) Encode(in interface{}) []byte {
 }
 
 func (g *BranchCommitRequestCodec) GetMessageType() message.MessageType {
-	return message.MessageType_BranchCommit
+	return message.MessageTypeBranchCommit
 }

pkg/protocol/codec/branch_commit_response_codec.go

@@ -70,5 +70,5 @@ func (g *BranchCommitResponseCodec) Encode(in interface{}) []byte {
 }
 
 func (g *BranchCommitResponseCodec) GetMessageType() message.MessageType {
-	return message.MessageType_BranchCommitResult
+	return message.MessageTypeBranchCommitResult
 }

pkg/protocol/codec/branch_register_req_codec.go

@@ -58,5 +58,5 @@ func (c *BranchRegisterRequestCodec) Encode(in interface{}) []byte {
 }
 
 func (g *BranchRegisterRequestCodec) GetMessageType() message.MessageType {
-	return message.MessageType_BranchRegister
+	return message.MessageTypeBranchRegister
 }

pkg/protocol/codec/branch_register_response_codec.go

@@ -65,5 +65,5 @@ func (c *BranchRegisterResponseCodec) Encode(in interface{}) []byte {
 }
 
 func (g *BranchRegisterResponseCodec) GetMessageType() message.MessageType {
-	return message.MessageType_BranchRegisterResult
+	return message.MessageTypeBranchRegisterResult
 }

pkg/protocol/codec/branch_rollback_req_codec.go

@@ -57,5 +57,5 @@ func (g *BranchRollbackRequestCodec) Encode(in interface{}) []byte {
 }
 
 func (g *BranchRollbackRequestCodec) GetMessageType() message.MessageType {
-	return message.MessageType_BranchRollback
+	return message.MessageTypeBranchRollback
 }

pkg/protocol/codec/branch_rollback_response_codec.go

@@ -70,5 +70,5 @@ func (g *BranchRollbackResponseCodec) Encode(in interface{}) []byte {
 }
 
 func (g *BranchRollbackResponseCodec) GetMessageType() message.MessageType {
-	return message.MessageType_BranchRollbackResult
+	return message.MessageTypeBranchRollbackResult
 }

pkg/protocol/codec/global_begin_request_codec.go

@@ -52,5 +52,5 @@ func (g *GlobalBeginRequestCodec) Decode(in []byte) interface{} {
 }
 
 func (g *GlobalBeginRequestCodec) GetMessageType() message.MessageType {
-	return message.MessageType_GlobalBegin
+	return message.MessageTypeGlobalBegin
 }

pkg/protocol/codec/global_begin_response_codec.go

@@ -67,5 +67,5 @@ func (g *GlobalBeginResponseCodec) Decode(in []byte) interface{} {
 }
 
 func (g *GlobalBeginResponseCodec) GetMessageType() message.MessageType {
-	return message.MessageType_GlobalBeginResult
+	return message.MessageTypeGlobalBeginResult
 }

pkg/protocol/codec/global_commit_req_codec.go

@@ -43,5 +43,5 @@ func (g *GlobalCommitRequestCodec) Encode(in interface{}) []byte {
 }
 
 func (g *GlobalCommitRequestCodec) GetMessageType() message.MessageType {
-	return message.MessageType_GlobalCommit
+	return message.MessageTypeGlobalCommit
 }

pkg/protocol/codec/global_commit_response_codec.go

@@ -43,5 +43,5 @@ func (g *GlobalCommitResponseCodec) Encode(in interface{}) []byte {
 }
 
 func (g *GlobalCommitResponseCodec) GetMessageType() message.MessageType {
-	return message.MessageType_GlobalCommitResult
+	return message.MessageTypeGlobalCommitResult
 }

pkg/protocol/codec/global_report_request_codec.go

@@ -52,5 +52,5 @@ func (g *GlobalReportRequestCodec) Encode(in interface{}) []byte {
 
 // GetMessageType get global report request's message type
 func (g *GlobalReportRequestCodec) GetMessageType() message.MessageType {
-	return message.MessageType_GlobalReportResult
+	return message.MessageTypeGlobalReportResult
 }

pkg/protocol/codec/global_report_response_codec.go

@@ -43,5 +43,5 @@ func (g *GlobalReportResponseCodec) Encode(in interface{}) []byte {
 }
 
 func (g *GlobalReportResponseCodec) GetMessageType() message.MessageType {
-	return message.MessageType_GlobalReportResult
+	return message.MessageTypeGlobalReportResult
 }

pkg/protocol/codec/global_rollback_req_codec.go

@@ -43,5 +43,5 @@ func (g *GlobalRollbackRequestCodec) Encode(in interface{}) []byte {
 }
 
 func (g *GlobalRollbackRequestCodec) GetMessageType() message.MessageType {
-	return message.MessageType_GlobalRollback
+	return message.MessageTypeGlobalRollback
 }

pkg/protocol/codec/global_rollback_response_codec.go

@@ -43,5 +43,5 @@ func (g *GlobalRollbackResponseCodec) Encode(in interface{}) []byte {
 }
 
 func (g *GlobalRollbackResponseCodec) GetMessageType() message.MessageType {
-	return message.MessageType_GlobalRollbackResult
+	return message.MessageTypeGlobalRollbackResult
 }

pkg/protocol/codec/global_status_req_codec.go

@@ -43,5 +43,5 @@ func (g *GlobalStatusRequestCodec) Encode(in interface{}) []byte {
 }
 
 func (g *GlobalStatusRequestCodec) GetMessageType() message.MessageType {
-	return message.MessageType_GlobalStatus
+	return message.MessageTypeGlobalStatus
 }

pkg/protocol/codec/global_status_response_codec.go

@@ -43,5 +43,5 @@ func (g *GlobalStatusResponseCodec) Encode(in interface{}) []byte {
 }
 
 func (g *GlobalStatusResponseCodec) GetMessageType() message.MessageType {
-	return message.MessageType_GlobalStatusResult
+	return message.MessageTypeGlobalStatusResult
 }

pkg/protocol/codec/register_rm_request_codec.go

@@ -56,5 +56,5 @@ func (c *RegisterRMRequestCodec) Encode(in interface{}) []byte {
 }
 
 func (g *RegisterRMRequestCodec) GetMessageType() message.MessageType {
-	return message.MessageType_RegRm
+	return message.MessageTypeRegRm
 }

pkg/protocol/codec/register_rm_response_codec.go

@@ -43,5 +43,5 @@ func (c *RegisterRMResponseCodec) Encode(in interface{}) []byte {
 }
 
 func (g *RegisterRMResponseCodec) GetMessageType() message.MessageType {
-	return message.MessageType_RegRmResult
+	return message.MessageTypeRegRmResult
 }

pkg/protocol/codec/register_tm_request_codec.go

@@ -43,5 +43,5 @@ func (c *RegisterTMRequestCodec) Encode(in interface{}) []byte {
 }
 
 func (g *RegisterTMRequestCodec) GetMessageType() message.MessageType {
-	return message.MessageType_RegClt
+	return message.MessageTypeRegClt
 }

pkg/protocol/codec/register_tm_response_codec.go

@@ -43,5 +43,5 @@ func (c *RegisterTMResponseCodec) Encode(in interface{}) []byte {
 }
 
 func (g *RegisterTMResponseCodec) GetMessageType() message.MessageType {
-	return message.MessageType_RegCltResult
+	return message.MessageTypeRegCltResult
 }

pkg/protocol/message/constant.go

@@ -17,7 +17,7 @@
 
 package message
 
-var MAGIC_CODE_BYTES = [2]byte{0xda, 0xda}
+var MagicCodeBytes = [2]byte{0xda, 0xda}
 
 type (
 	MessageType      int
@@ -27,125 +27,127 @@ type (
 
 const (
 	/**
-	 * The constant TYPE_GLOBAL_BEGIN.
+	 * The constant TypeGlobalBegin.
 	 */
-	MessageType_GlobalBegin MessageType = 1
+	MessageTypeGlobalBegin MessageType = 1
 	/**
-	 * The constant TYPE_GLOBAL_BEGIN_RESULT.
+	 * The constant TypeGlobalBeginResult.
 	 */
-	MessageType_GlobalBeginResult MessageType = 2
+	MessageTypeGlobalBeginResult MessageType = 2
 	/**
-	 * The constant TYPE_GLOBAL_COMMIT.
+	 * The constant TypeGlobalCommit.
 	 */
-	MessageType_GlobalCommit MessageType = 7
+	MessageTypeGlobalCommit MessageType = 7
 	/**
-	 * The constant TYPE_GLOBAL_COMMIT_RESULT.
+	 * The constant TypeGlobalCommitResult.
 	 */
-	MessageType_GlobalCommitResult MessageType = 8
+	MessageTypeGlobalCommitResult MessageType = 8
 	/**
-	 * The constant TYPE_GLOBAL_ROLLBACK.
+	 * The constant TypeGlobalRollback.
 	 */
-	MessageType_GlobalRollback MessageType = 9
+	MessageTypeGlobalRollback MessageType = 9
 	/**
-	 * The constant TYPE_GLOBAL_ROLLBACK_RESULT.
+	 * The constant TypeGlobalRollbackResult.
 	 */
-	MessageType_GlobalRollbackResult MessageType = 10
+	MessageTypeGlobalRollbackResult MessageType = 10
 	/**
-	 * The constant TYPE_GLOBAL_STATUS.
+	 * The constant TypeGlobalStatus.
 	 */
-	MessageType_GlobalStatus MessageType = 15
+	MessageTypeGlobalStatus MessageType = 15
 	/**
-	 * The constant TYPE_GLOBAL_STATUS_RESULT.
+	 * The constant TypeGlobalStatusResult.
 	 */
-	MessageType_GlobalStatusResult MessageType = 16
+	MessageTypeGlobalStatusResult MessageType = 16
 	/**
-	 * The constant TYPE_GLOBAL_REPORT.
+	 * The constant TypeGlobalReport.
 	 */
-	MessageType_GlobalReport MessageType = 17
+	MessageTypeGlobalReport MessageType = 17
 	/**
-	 * The constant TYPE_GLOBAL_REPORT_RESULT.
+	 * The constant TypeGlobalReportResult.
 	 */
-	MessageType_GlobalReportResult MessageType = 18
+	MessageTypeGlobalReportResult MessageType = 18
 	/**
-	 * The constant TYPE_GLOBAL_LOCK_QUERY.
+	 * The constant TypeGlobalLockQuery.
 	 */
-	MessageType_GlobalLockQuery MessageType = 21
+	MessageTypeGlobalLockQuery MessageType = 21
 	/**
-	 * The constant TYPE_GLOBAL_LOCK_QUERY_RESULT.
+	 * The constant TypeGlobalLockQueryResult.
 	 */
-	MessageType_GlobalLockQueryResult MessageType = 22
+	MessageTypeGlobalLockQueryResult MessageType = 22
 
 	/**
-	 * The constant TYPE_BRANCH_COMMIT.
+	 * The constant TypeBranchCommit.
 	 */
-	MessageType_BranchCommit MessageType = 3
+	MessageTypeBranchCommit MessageType = 3
 	/**
-	 * The constant TYPE_BRANCH_COMMIT_RESULT.
+	 * The constant TypeBranchCommitResult.
 	 */
-	MessageType_BranchCommitResult MessageType = 4
+	MessageTypeBranchCommitResult MessageType = 4
 	/**
-	 * The constant TYPE_BRANCH_ROLLBACK.
+	 * The constant TypeBranchRollback.
 	 */
-	MessageType_BranchRollback MessageType = 5
+	MessageTypeBranchRollback MessageType = 5
 	/**
-	 * The constant TYPE_BRANCH_ROLLBACK_RESULT.
+	 * The constant TypeBranchRollbackResult.
 	 */
-	MessageType_BranchRollbackResult MessageType = 6
+	MessageTypeBranchRollbackResult MessageType = 6
 	/**
-	 * The constant TYPE_BRANCH_REGISTER.
+	 * The constant TypeBranchRegister.
 	 */
-	MessageType_BranchRegister MessageType = 11
+	MessageTypeBranchRegister MessageType = 11
 	/**
-	 * The constant TYPE_BRANCH_REGISTER_RESULT.
+	 * The constant TypeBranchRegisterResult.
 	 */
-	MessageType_BranchRegisterResult MessageType = 12
+	MessageTypeBranchRegisterResult MessageType = 12
 	/**
-	 * The constant TYPE_BRANCH_STATUS_REPORT.
+	 * The constant TypeBranchStatusReport.
 	 */
-	MessageType_BranchStatusReport MessageType = 13
+	MessageTypeBranchStatusReport MessageType = 13
 	/**
-	 * The constant TYPE_BRANCH_STATUS_REPORT_RESULT.
+	 * The constant TypeBranchStatusReportResult.
 	 */
-	MessageType_BranchStatusReportResult MessageType = 14
+	MessageTypeBranchStatusReportResult MessageType = 14
 
 	/**
-	 * The constant TYPE_SEATA_MERGE.
+	 * The constant TypeSeataMerge.
 	 */
-	MessageType_SeataMerge MessageType = 59
+	MessageTypeSeataMerge MessageType = 59
 	/**
-	 * The constant TYPE_SEATA_MERGE_RESULT.
+	 * The constant TypeSeataMergeResult.
 	 */
-	MessageType_SeataMergeResult MessageType = 60
+	MessageTypeSeataMergeResult MessageType = 60
 
 	/**
-	 * The constant TYPE_REG_CLT.
+	 * The constant TypeRegClt.
 	 */
-	MessageType_RegClt MessageType = 101
+	MessageTypeRegClt MessageType = 101
 	/**
-	 * The constant TYPE_REG_CLT_RESULT.
+	 * The constant TypeRegCltResult.
 	 */
-	MessageType_RegCltResult MessageType = 102
+	MessageTypeRegCltResult MessageType = 102
 	/**
-	 * The constant TYPE_REG_RM.
+	 * The constant TypeRegRm.
 	 */
-	MessageType_RegRm MessageType = 103
+	MessageTypeRegRm MessageType = 103
 	/**
-	 * The constant TYPE_REG_RM_RESULT.
+	 * The constant TypeRegRmResult.
 	 */
-	MessageType_RegRmResult MessageType = 104
+
+	MessageTypeRegRmResult MessageType = 104
 	/**
-	 * The constant TYPE_RM_DELETE_UNDOLOG.
+	 * The constant TypeRmDeleteUndolog.
 	 */
-	MessageType_RmDeleteUndolog MessageType = 111
+	MessageTypeRmDeleteUndolog MessageType = 111
 	/**
-	 * the constant TYPE_HEARTBEAT_MSG
+	 * the constant TypeHeartbeatMsg
 	 */
-	MessageType_HeartbeatMsg MessageType = 120
+	MessageTypeHeartbeatMsg MessageType = 120
 
 	/**
-	 * the constant MessageType_BatchResultMsg
+	 * the constant MessageTypeBatchResultMsg
 	 */
-	MessageType_BatchResultMsg MessageType = 121
+
+	MessageTypeBatchResultMsg MessageType = 121
 )
 
 const (
@@ -158,19 +160,19 @@ const (
 	V1HeadLength = 16
 
 	// Request message type
-	GettyRequestType_RequestSync GettyRequestType = 0
+	GettyRequestTypeRequestSync GettyRequestType = 0
 
 	// Response message type
-	GettyRequestType_Response GettyRequestType = 1
+	GettyRequestTypeResponse GettyRequestType = 1
 
 	// Request which no need response
-	GettyRequestType_RequestOneway GettyRequestType = 2
+	GettyRequestTypeRequestOneway GettyRequestType = 2
 
 	// Heartbeat Request
-	GettyRequestType_HeartbeatRequest GettyRequestType = 3
+	GettyRequestTypeHeartbeatRequest GettyRequestType = 3
 
 	// Heartbeat Response
-	GettyRequestType_HeartbeatResponse GettyRequestType = 4
+	GettyRequestTypeHeartbeatResponse GettyRequestType = 4
 )
 
 const (

pkg/protocol/message/message_apis.go

@@ -46,15 +46,15 @@ type MergedWarpMessage struct {
 }
 
 func (req MergedWarpMessage) GetTypeCode() MessageType {
-	return MessageType_SeataMerge
+	return MessageTypeSeataMerge
 }
 
 type MergeResultMessage struct {
 	Msgs []MessageTypeAware
 }
 
 func (resp MergeResultMessage) GetTypeCode() MessageType {
-	return MessageType_SeataMergeResult
+	return MessageTypeSeataMergeResult
 }
 
 type ResultCode byte

pkg/protocol/message/message_apis_test.go

@@ -24,9 +24,9 @@ import (
 )
 
 func TestMergedWarpMessage_GetTypeCode(t *testing.T) {
-	assert.Equal(t, MessageType_SeataMerge, MergedWarpMessage{}.GetTypeCode())
+	assert.Equal(t, MessageTypeSeataMerge, MergedWarpMessage{}.GetTypeCode())
 }
 
 func TestMergedResultMessage_GetTYpeCode(t *testing.T) {
-	assert.Equal(t, MessageType_SeataMergeResult, MergeResultMessage{}.GetTypeCode())
+	assert.Equal(t, MessageTypeSeataMergeResult, MergeResultMessage{}.GetTypeCode())
 }

pkg/protocol/message/other_message.go

@@ -58,5 +58,5 @@ func (msg HeartBeatMessage) ToString() string {
 }
 
 func (resp HeartBeatMessage) GetTypeCode() MessageType {
-	return MessageType_HeartbeatMsg
+	return MessageTypeHeartbeatMsg
 }