grpc test renamed

test/grpc_msg_test.go → test/msg_grpc_test.go

@@ -11,7 +11,7 @@ import (
 	"github.com/yedf/dtm/examples"
 )
 
-func TestGrpcMsgNormal(t *testing.T) {
+func TestMsgGrpcNormal(t *testing.T) {
 	msg := genGrpcMsg(dtmimp.GetFuncName())
 	err := msg.Submit()
 	assert.Nil(t, err)
@@ -19,7 +19,7 @@ func TestGrpcMsgNormal(t *testing.T) {
 	assert.Equal(t, StatusSucceed, getTransStatus(msg.Gid))
 }
 
-func TestGrpcMsgOngoingSuccess(t *testing.T) {
+func TestMsgGrpcOngoingSuccess(t *testing.T) {
 	msg := genGrpcMsg(dtmimp.GetFuncName())
 	err := msg.Prepare("")
 	assert.Nil(t, err)
@@ -33,7 +33,7 @@ func TestGrpcMsgOngoingSuccess(t *testing.T) {
 	assert.Equal(t, StatusSucceed, getTransStatus(msg.Gid))
 }
 
-func TestGrpcMsgOngoingFailed(t *testing.T) {
+func TestMsgGrpcOngoingFailed(t *testing.T) {
 	msg := genGrpcMsg(dtmimp.GetFuncName())
 	msg.Prepare("")
 	assert.Equal(t, StatusPrepared, getTransStatus(msg.Gid))

test/grpc_saga_barrier_test.go → test/saga_grpc_barrier_test.go

@@ -9,7 +9,7 @@ import (
 	"github.com/yedf/dtm/examples"
 )
 
-func TestGrpcSagaBarrierNormal(t *testing.T) {
+func TestSagaGrpcBarrierNormal(t *testing.T) {
 	req := examples.GenBusiReq(30, false, false)
 	saga := dtmgrpc.NewSagaGrpc(examples.DtmGrpcServer, dtmimp.GetFuncName()).
 		Add(examples.BusiGrpc+"/examples.Busi/TransOutBSaga", examples.BusiGrpc+"/examples.Busi/TransOutRevertBSaga", req).
@@ -20,7 +20,7 @@ func TestGrpcSagaBarrierNormal(t *testing.T) {
 	assert.Equal(t, []string{StatusPrepared, StatusSucceed, StatusPrepared, StatusSucceed}, getBranchesStatus(saga.Gid))
 }
 
-func TestGrpcSagaBarrierRollback(t *testing.T) {
+func TestSagaGrpcBarrierRollback(t *testing.T) {
 	req := examples.GenBusiReq(30, false, true)
 	saga := dtmgrpc.NewSagaGrpc(examples.DtmGrpcServer, dtmimp.GetFuncName()).
 		Add(examples.BusiGrpc+"/examples.Busi/TransOutBSaga", examples.BusiGrpc+"/examples.Busi/TransOutRevertBSaga", req).

test/grpc_saga_test.go → test/saga_grpc_test.go

@@ -10,7 +10,7 @@ import (
 	"github.com/yedf/dtm/examples"
 )
 
-func TestGrpcSagaNormal(t *testing.T) {
+func TestSagaGrpcNormal(t *testing.T) {
 	saga := genSagaGrpc(dtmimp.GetFuncName(), false, false)
 	saga.Submit()
 	waitTransProcessed(saga.Gid)
@@ -18,7 +18,7 @@ func TestGrpcSagaNormal(t *testing.T) {
 	assert.Equal(t, StatusSucceed, getTransStatus(saga.Gid))
 }
 
-func TestGrpcSagaCommittedOngoing(t *testing.T) {
+func TestSagaGrpcCommittedOngoing(t *testing.T) {
 	saga := genSagaGrpc(dtmimp.GetFuncName(), false, false)
 	examples.MainSwitch.TransOutResult.SetOnce(dtmcli.ResultOngoing)
 	saga.Submit()
@@ -29,7 +29,7 @@ func TestGrpcSagaCommittedOngoing(t *testing.T) {
 	assert.Equal(t, StatusSucceed, getTransStatus(saga.Gid))
 }
 
-func TestGrpcSagaRollback(t *testing.T) {
+func TestSagaGrpcRollback(t *testing.T) {
 	saga := genSagaGrpc(dtmimp.GetFuncName(), false, true)
 	examples.MainSwitch.TransOutRevertResult.SetOnce(dtmcli.ResultOngoing)
 	saga.Submit()

test/grpc_tcc_test.go → test/tcc_grpc_test.go

@@ -12,14 +12,14 @@ import (
 	"google.golang.org/protobuf/types/known/emptypb"
 )
 
-func TestGrpcTccType(t *testing.T) {
+func TestTccGrpcType(t *testing.T) {
 	_, err := dtmgrpc.TccFromGrpc(context.Background())
 	assert.Error(t, err)
 	dtmimp.Logf("expecting dtmgrpcserver error")
 	err = dtmgrpc.TccGlobalTransaction("-", "", func(tcc *dtmgrpc.TccGrpc) error { return nil })
 	assert.Error(t, err)
 }
-func TestGrpcTccNormal(t *testing.T) {
+func TestTccGrpcNormal(t *testing.T) {
 	data := &examples.BusiReq{Amount: 30}
 	gid := dtmimp.GetFuncName()
 	err := dtmgrpc.TccGlobalTransaction(examples.DtmGrpcServer, gid, func(tcc *dtmgrpc.TccGrpc) error {
@@ -45,7 +45,7 @@ func TestGrpcTestNested(t *testing.T) {
 	assert.Nil(t, err)
 }
 
-func TestGrpcTccRollback(t *testing.T) {
+func TestTccGrpcRollback(t *testing.T) {
 	gid := dtmimp.GetFuncName()
 	data := &examples.BusiReq{Amount: 30, TransInResult: dtmcli.ResultFailure}
 	err := dtmgrpc.TccGlobalTransaction(examples.DtmGrpcServer, gid, func(tcc *dtmgrpc.TccGrpc) error {

test/grpc_xa_test.go → test/xa_grpc_test.go

@@ -13,7 +13,7 @@ import (
 	"google.golang.org/protobuf/types/known/emptypb"
 )
 
-func TestGrpcXaType(t *testing.T) {
+func TestXaGrpcType(t *testing.T) {
 	_, err := dtmgrpc.XaGrpcFromRequest(context.Background())
 	assert.Error(t, err)
 
@@ -26,7 +26,7 @@ func TestGrpcXaType(t *testing.T) {
 	assert.Error(t, err)
 }
 
-func TestGrpcXaLocalError(t *testing.T) {
+func TestXaGrpcLocalError(t *testing.T) {
 	xc := examples.XaGrpcClient
 	err := xc.XaGlobalTransaction(dtmimp.GetFuncName(), func(xa *dtmgrpc.XaGrpc) error {
 		return fmt.Errorf("an error")
@@ -34,7 +34,7 @@ func TestGrpcXaLocalError(t *testing.T) {
 	assert.Error(t, err, fmt.Errorf("an error"))
 }
 
-func TestGrpcXaNormal(t *testing.T) {
+func TestXaGrpcNormal(t *testing.T) {
 	xc := examples.XaGrpcClient
 	gid := dtmimp.GetFuncName()
 	err := xc.XaGlobalTransaction(gid, func(xa *dtmgrpc.XaGrpc) error {
@@ -52,7 +52,7 @@ func TestGrpcXaNormal(t *testing.T) {
 	assert.Equal(t, []string{StatusPrepared, StatusSucceed, StatusPrepared, StatusSucceed}, getBranchesStatus(gid))
 }
 
-func TestGrpcXaRollback(t *testing.T) {
+func TestXaGrpcRollback(t *testing.T) {
 	xc := examples.XaGrpcClient
 	gid := dtmimp.GetFuncName()
 	err := xc.XaGlobalTransaction(gid, func(xa *dtmgrpc.XaGrpc) error {