|
|
@ -92,7 +92,7 @@ func TestSagaGrpcEmptyUrl(t *testing.T) { |
|
|
assert.Equal(t, StatusSucceed, getTransStatus(saga.Gid)) |
|
|
assert.Equal(t, StatusSucceed, getTransStatus(saga.Gid)) |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
//nolint: unparam
|
|
|
// nolint: unparam
|
|
|
func genSagaGrpc(gid string, outFailed bool, inFailed bool) *dtmgrpc.SagaGrpc { |
|
|
func genSagaGrpc(gid string, outFailed bool, inFailed bool) *dtmgrpc.SagaGrpc { |
|
|
saga := dtmgrpc.NewSagaGrpc(dtmutil.DefaultGrpcServer, gid) |
|
|
saga := dtmgrpc.NewSagaGrpc(dtmutil.DefaultGrpcServer, gid) |
|
|
req := busi.GenReqGrpc(30, outFailed, inFailed) |
|
|
req := busi.GenReqGrpc(30, outFailed, inFailed) |
|
|
|