diff --git a/test/grpc_msg_test.go b/test/msg_grpc_test.go similarity index 92% rename from test/grpc_msg_test.go rename to test/msg_grpc_test.go index 2314d28..deffd90 100644 --- a/test/grpc_msg_test.go +++ b/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)) diff --git a/test/grpc_saga_barrier_test.go b/test/saga_grpc_barrier_test.go similarity index 93% rename from test/grpc_saga_barrier_test.go rename to test/saga_grpc_barrier_test.go index d1394c5..9b5506d 100644 --- a/test/grpc_saga_barrier_test.go +++ b/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). diff --git a/test/grpc_saga_test.go b/test/saga_grpc_test.go similarity index 93% rename from test/grpc_saga_test.go rename to test/saga_grpc_test.go index efc3615..f41a996 100644 --- a/test/grpc_saga_test.go +++ b/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() diff --git a/test/grpc_tcc_test.go b/test/tcc_grpc_test.go similarity index 95% rename from test/grpc_tcc_test.go rename to test/tcc_grpc_test.go index adae071..ca117d0 100644 --- a/test/grpc_tcc_test.go +++ b/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 { diff --git a/test/grpc_xa_test.go b/test/xa_grpc_test.go similarity index 92% rename from test/grpc_xa_test.go rename to test/xa_grpc_test.go index 8d1f085..9534e60 100644 --- a/test/grpc_xa_test.go +++ b/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 {