| 
| dtm 0.1 is released from 20210604 and under fast development |
+| Star count | 
| | dtm 0.1 is released from 20210604 and under fast development |
From the features' comparison above, if your language stack includes languages other than Java, then dtm is the one for you.
If your language stack is Java, you can also choose to access dtm and use sub-transaction barrier technology to simplify your business development.
@@ -73,7 +73,7 @@ If your language stack is Java, you can also choose to access dtm and use sub-tr
### Install
-`git clone https://github.com/yedf/dtm`
+`git clone https://github.com/dtm-labs/dtm`
### Configure Mysql
diff --git a/README.md b/README.md
index 527e771..85eb559 100644
--- a/README.md
+++ b/README.md
@@ -1,8 +1,8 @@
-
-
-[](https://codecov.io/gh/yedf/dtm)
-[](https://goreportcard.com/report/github.com/yedf/dtm)
-[](https://pkg.go.dev/github.com/yedf/dtm)
+
+
+[](https://codecov.io/gh/dtm-labs/dtm)
+[](https://goreportcard.com/report/github.com/dtm-labs/dtm)
+[](https://pkg.go.dev/github.com/dtm-labs/dtm)
[](https://github.com/avelino/awesome-go#database)
# [English Docs](https://en.dtm.pub)
@@ -55,7 +55,7 @@ DTM是一款golang开发的分布式事务管理器，解决了跨数据库、
|事务消息|✓|✗|dtm提供类似rocketmq的事务消息|
|单服务多数据源|✓|✗||
|通信协议|HTTP、gRPC、go-zero|dubbo等协议|dtm对云原生更加友好|
-|star数量|||dtm从20210604发布0.1，发展快|
+|star数量|||dtm从20210604发布0.1，发展快|
从上面对比的特性来看，如果您的语言栈包含了Java之外的语言，那么dtm是您的首选。如果您的语言栈是Java，您也可以选择接入dtm，使用子事务屏障技术，简化您的业务编写。
@@ -75,7 +75,7 @@ DTM是一款golang开发的分布式事务管理器，解决了跨数据库、
### 获取代码
-`git clone https://github.com/yedf/dtm && cd dtm`
+`git clone https://github.com/dtm-labs/dtm && cd dtm`
### dtm依赖于mysql
@@ -126,7 +126,7 @@ DTM是一款golang开发的分布式事务管理器，解决了跨数据库、
-欢迎使用[dtm](https://github.com/yedf/dtm)，或者通过dtm学习实践分布式事务相关知识，欢迎star支持我们
+欢迎使用[dtm](https://github.com/dtm-labs/dtm)，或者通过dtm学习实践分布式事务相关知识，欢迎star支持我们
## 谁在使用
diff --git a/app/main.go b/app/main.go
index edd4b9a..c0e5c5d 100644
--- a/app/main.go
+++ b/app/main.go
@@ -13,12 +13,12 @@ import (
_ "go.uber.org/automaxprocs"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmsvr"
- "github.com/yedf/dtm/dtmsvr/storage/registry"
- "github.com/yedf/dtm/examples"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmsvr"
+ "github.com/dtm-labs/dtm/dtmsvr/storage/registry"
+ "github.com/dtm-labs/dtm/examples"
)
var Version, Commit, Date string
diff --git a/bench/http.go b/bench/http.go
index 403abd3..4682271 100644
--- a/bench/http.go
+++ b/bench/http.go
@@ -13,13 +13,13 @@ import (
"sync/atomic"
"time"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmsvr"
+ "github.com/dtm-labs/dtm/examples"
"github.com/gin-gonic/gin"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmsvr"
- "github.com/yedf/dtm/examples"
)
// launch command：go run app/main.go qs
diff --git a/bench/main.go b/bench/main.go
index ebd604d..9bff1b0 100644
--- a/bench/main.go
+++ b/bench/main.go
@@ -4,12 +4,12 @@ import (
"fmt"
"os"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmsvr"
- "github.com/yedf/dtm/dtmsvr/storage/registry"
- "github.com/yedf/dtm/examples"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmsvr"
+ "github.com/dtm-labs/dtm/dtmsvr/storage/registry"
+ "github.com/dtm-labs/dtm/examples"
)
var hint = `To start the bench server, you need to specify the parameters:
diff --git a/common/config.go b/common/config.go
index 6044305..68bf312 100644
--- a/common/config.go
+++ b/common/config.go
@@ -6,8 +6,8 @@ import (
"io/ioutil"
"path/filepath"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"gopkg.in/yaml.v2"
)
diff --git a/common/config_utils.go b/common/config_utils.go
index e54a834..60069b8 100644
--- a/common/config_utils.go
+++ b/common/config_utils.go
@@ -7,7 +7,7 @@ import (
"regexp"
"strings"
- "github.com/yedf/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
)
func loadFromEnv(prefix string, conf interface{}) {
diff --git a/common/db.go b/common/db.go
index f2d1c66..009725e 100644
--- a/common/db.go
+++ b/common/db.go
@@ -7,11 +7,11 @@ import (
"sync"
"time"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
_ "github.com/go-sql-driver/mysql" // register mysql driver
_ "github.com/lib/pq" // register postgres driver
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
"gorm.io/driver/mysql"
"gorm.io/driver/postgres"
"gorm.io/gorm"
diff --git a/common/types.go b/common/types.go
index 19bd8ea..8949021 100644
--- a/common/types.go
+++ b/common/types.go
@@ -10,8 +10,8 @@ import (
"fmt"
"sync"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/go-redis/redis/v8"
- "github.com/yedf/dtm/dtmcli/logger"
)
var rdb *redis.Client
diff --git a/common/types_test.go b/common/types_test.go
index 8aea076..7bb5500 100644
--- a/common/types_test.go
+++ b/common/types_test.go
@@ -9,8 +9,8 @@ package common
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli/dtmimp"
)
func TestGeneralDB(t *testing.T) {
diff --git a/common/utils.go b/common/utils.go
index a712f6d..4af5c1b 100644
--- a/common/utils.go
+++ b/common/utils.go
@@ -18,9 +18,9 @@ import (
"github.com/gin-gonic/gin"
"github.com/go-resty/resty/v2"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
)
// GetGinApp init and return gin
diff --git a/dtmcli/barrier.go b/dtmcli/barrier.go
index ede7080..ff14336 100644
--- a/dtmcli/barrier.go
+++ b/dtmcli/barrier.go
@@ -11,8 +11,8 @@ import (
"fmt"
"net/url"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
)
// BarrierBusiFunc type for busi func
diff --git a/dtmcli/consts.go b/dtmcli/consts.go
index 5b538a7..b27b90a 100644
--- a/dtmcli/consts.go
+++ b/dtmcli/consts.go
@@ -7,7 +7,7 @@
package dtmcli
import (
- "github.com/yedf/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
)
const (
diff --git a/dtmcli/dtmimp/utils.go b/dtmcli/dtmimp/utils.go
index eb264bf..242089d 100644
--- a/dtmcli/dtmimp/utils.go
+++ b/dtmcli/dtmimp/utils.go
@@ -18,8 +18,8 @@ import (
"sync"
"time"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/go-resty/resty/v2"
- "github.com/yedf/dtm/dtmcli/logger"
)
// Logf an alias of Infof
diff --git a/dtmcli/dtmimp/vars.go b/dtmcli/dtmimp/vars.go
index c7af1ff..eea02ad 100644
--- a/dtmcli/dtmimp/vars.go
+++ b/dtmcli/dtmimp/vars.go
@@ -9,8 +9,8 @@ package dtmimp
import (
"errors"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/go-resty/resty/v2"
- "github.com/yedf/dtm/dtmcli/logger"
)
// ErrFailure error of FAILURE
diff --git a/dtmcli/msg.go b/dtmcli/msg.go
index e7dc97c..a461ea2 100644
--- a/dtmcli/msg.go
+++ b/dtmcli/msg.go
@@ -6,7 +6,7 @@
package dtmcli
-import "github.com/yedf/dtm/dtmcli/dtmimp"
+import "github.com/dtm-labs/dtm/dtmcli/dtmimp"
// Msg reliable msg type
type Msg struct {
diff --git a/dtmcli/saga.go b/dtmcli/saga.go
index 05ad6f9..2ac9c1c 100644
--- a/dtmcli/saga.go
+++ b/dtmcli/saga.go
@@ -7,7 +7,7 @@
package dtmcli
import (
- "github.com/yedf/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
)
// Saga struct of saga
diff --git a/dtmcli/tcc.go b/dtmcli/tcc.go
index d1f85b0..9df1bd4 100644
--- a/dtmcli/tcc.go
+++ b/dtmcli/tcc.go
@@ -10,8 +10,8 @@ import (
"fmt"
"net/url"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
"github.com/go-resty/resty/v2"
- "github.com/yedf/dtm/dtmcli/dtmimp"
)
// Tcc struct of tcc
diff --git a/dtmcli/types.go b/dtmcli/types.go
index 3726e56..e0e54e2 100644
--- a/dtmcli/types.go
+++ b/dtmcli/types.go
@@ -9,7 +9,7 @@ package dtmcli
import (
"fmt"
- "github.com/yedf/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
)
// MustGenGid generate a new gid
diff --git a/dtmcli/types_test.go b/dtmcli/types_test.go
index 8128e7d..b37ba9a 100644
--- a/dtmcli/types_test.go
+++ b/dtmcli/types_test.go
@@ -10,8 +10,8 @@ import (
"net/url"
"testing"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli/dtmimp"
)
func TestTypes(t *testing.T) {
diff --git a/dtmcli/xa.go b/dtmcli/xa.go
index cd9ca48..d28bed7 100644
--- a/dtmcli/xa.go
+++ b/dtmcli/xa.go
@@ -11,8 +11,8 @@ import (
"fmt"
"net/url"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
"github.com/go-resty/resty/v2"
- "github.com/yedf/dtm/dtmcli/dtmimp"
)
// XaGlobalFunc type of xa global function
diff --git a/dtmgrpc/barrier.go b/dtmgrpc/barrier.go
index 05cf5ee..973c14a 100644
--- a/dtmgrpc/barrier.go
+++ b/dtmgrpc/barrier.go
@@ -9,8 +9,8 @@ package dtmgrpc
import (
"context"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmgrpc/dtmgimp"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgimp"
)
// BarrierFromGrpc generate a Barrier from grpc context
diff --git a/dtmgrpc/dtmgimp/grpc_clients.go b/dtmgrpc/dtmgimp/grpc_clients.go
index e437054..d2c63a0 100644
--- a/dtmgrpc/dtmgimp/grpc_clients.go
+++ b/dtmgrpc/dtmgimp/grpc_clients.go
@@ -10,9 +10,9 @@ import (
"fmt"
"sync"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmgrpc/dtmgpb"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgpb"
grpc "google.golang.org/grpc"
)
diff --git a/dtmgrpc/dtmgimp/types.go b/dtmgrpc/dtmgimp/types.go
index 594c6c9..3b8048d 100644
--- a/dtmgrpc/dtmgimp/types.go
+++ b/dtmgrpc/dtmgimp/types.go
@@ -11,9 +11,9 @@ import (
"fmt"
"time"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"google.golang.org/grpc"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
diff --git a/dtmgrpc/dtmgimp/utils.go b/dtmgrpc/dtmgimp/utils.go
index e600166..bb49f39 100644
--- a/dtmgrpc/dtmgimp/utils.go
+++ b/dtmgrpc/dtmgimp/utils.go
@@ -9,9 +9,9 @@ package dtmgimp
import (
context "context"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmgrpc/dtmgpb"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgpb"
"google.golang.org/grpc/metadata"
"google.golang.org/protobuf/proto"
emptypb "google.golang.org/protobuf/types/known/emptypb"
diff --git a/dtmgrpc/msg.go b/dtmgrpc/msg.go
index 31448a9..e112713 100644
--- a/dtmgrpc/msg.go
+++ b/dtmgrpc/msg.go
@@ -7,9 +7,9 @@
package dtmgrpc
import (
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmgrpc/dtmgimp"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgimp"
"google.golang.org/protobuf/proto"
)
diff --git a/dtmgrpc/saga.go b/dtmgrpc/saga.go
index feb0879..af09038 100644
--- a/dtmgrpc/saga.go
+++ b/dtmgrpc/saga.go
@@ -7,8 +7,8 @@
package dtmgrpc
import (
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmgrpc/dtmgimp"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgimp"
"google.golang.org/protobuf/proto"
)
diff --git a/dtmgrpc/tcc.go b/dtmgrpc/tcc.go
index 1b8bebd..d4c0592 100644
--- a/dtmgrpc/tcc.go
+++ b/dtmgrpc/tcc.go
@@ -10,10 +10,10 @@ import (
context "context"
"fmt"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmgrpc/dtmgimp"
- "github.com/yedf/dtm/dtmgrpc/dtmgpb"
- "github.com/yedf/dtmdriver"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgimp"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgpb"
+ "github.com/dtm-labs/dtmdriver"
"google.golang.org/protobuf/proto"
)
diff --git a/dtmgrpc/type.go b/dtmgrpc/type.go
index 3990261..c2b7fa7 100644
--- a/dtmgrpc/type.go
+++ b/dtmgrpc/type.go
@@ -9,10 +9,10 @@ package dtmgrpc
import (
context "context"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmgrpc/dtmgimp"
- "github.com/yedf/dtmdriver"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgimp"
+ "github.com/dtm-labs/dtmdriver"
emptypb "google.golang.org/protobuf/types/known/emptypb"
)
diff --git a/dtmgrpc/type_test.go b/dtmgrpc/type_test.go
index 9440905..7c44e4a 100644
--- a/dtmgrpc/type_test.go
+++ b/dtmgrpc/type_test.go
@@ -10,8 +10,8 @@ import (
"context"
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
)
func TestType(t *testing.T) {
diff --git a/dtmgrpc/xa.go b/dtmgrpc/xa.go
index 23ba33c..95a97a1 100644
--- a/dtmgrpc/xa.go
+++ b/dtmgrpc/xa.go
@@ -11,11 +11,11 @@ import (
"database/sql"
"fmt"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmgrpc/dtmgimp"
- "github.com/yedf/dtm/dtmgrpc/dtmgpb"
- "github.com/yedf/dtmdriver"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgimp"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgpb"
+ "github.com/dtm-labs/dtmdriver"
grpc "google.golang.org/grpc"
"google.golang.org/protobuf/proto"
emptypb "google.golang.org/protobuf/types/known/emptypb"
diff --git a/dtmsvr/api.go b/dtmsvr/api.go
index 5ca0e9e..5c61a8d 100644
--- a/dtmsvr/api.go
+++ b/dtmsvr/api.go
@@ -9,10 +9,10 @@ package dtmsvr
import (
"fmt"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmsvr/storage"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmsvr/storage"
)
func svcSubmit(t *TransGlobal) (interface{}, error) {
diff --git a/dtmsvr/api_grpc.go b/dtmsvr/api_grpc.go
index 4d4daf8..461b251 100644
--- a/dtmsvr/api_grpc.go
+++ b/dtmsvr/api_grpc.go
@@ -9,9 +9,9 @@ package dtmsvr
import (
"context"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmgrpc/dtmgimp"
- pb "github.com/yedf/dtm/dtmgrpc/dtmgpb"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgimp"
+ pb "github.com/dtm-labs/dtm/dtmgrpc/dtmgpb"
"google.golang.org/protobuf/types/known/emptypb"
)
diff --git a/dtmsvr/api_http.go b/dtmsvr/api_http.go
index 5102506..bbd09de 100644
--- a/dtmsvr/api_http.go
+++ b/dtmsvr/api_http.go
@@ -9,11 +9,11 @@ package dtmsvr
import (
"errors"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
"github.com/gin-gonic/gin"
"github.com/prometheus/client_golang/prometheus/promhttp"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
)
func addRoute(engine *gin.Engine) {
diff --git a/dtmsvr/cron.go b/dtmsvr/cron.go
index 120b74c..c718840 100644
--- a/dtmsvr/cron.go
+++ b/dtmsvr/cron.go
@@ -12,8 +12,8 @@ import (
"runtime/debug"
"time"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
)
// NowForwardDuration will be set in test, trans may be timeout
diff --git a/dtmsvr/storage/boltdb/boltdb.go b/dtmsvr/storage/boltdb/boltdb.go
index d02ba5c..e1af190 100644
--- a/dtmsvr/storage/boltdb/boltdb.go
+++ b/dtmsvr/storage/boltdb/boltdb.go
@@ -9,10 +9,10 @@ import (
bolt "go.etcd.io/bbolt"
"gorm.io/gorm"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmsvr/storage"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmsvr/storage"
)
var config = &common.Config
diff --git a/dtmsvr/storage/boltdb/boltdb_test.go b/dtmsvr/storage/boltdb/boltdb_test.go
index 7388222..2e96a7c 100644
--- a/dtmsvr/storage/boltdb/boltdb_test.go
+++ b/dtmsvr/storage/boltdb/boltdb_test.go
@@ -8,8 +8,8 @@ import (
. "github.com/onsi/gomega"
bolt "go.etcd.io/bbolt"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmsvr/storage"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmsvr/storage"
)
func TestInitializeBuckets(t *testing.T) {
diff --git a/dtmsvr/storage/redis/redis.go b/dtmsvr/storage/redis/redis.go
index 001b849..8dca435 100644
--- a/dtmsvr/storage/redis/redis.go
+++ b/dtmsvr/storage/redis/redis.go
@@ -8,10 +8,10 @@ import (
"github.com/go-redis/redis/v8"
"gorm.io/gorm"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmsvr/storage"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmsvr/storage"
)
var config = &common.Config
diff --git a/dtmsvr/storage/registry/registry.go b/dtmsvr/storage/registry/registry.go
index e0fbe93..2fc349c 100644
--- a/dtmsvr/storage/registry/registry.go
+++ b/dtmsvr/storage/registry/registry.go
@@ -3,11 +3,11 @@ package registry
import (
"time"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmsvr/storage"
- "github.com/yedf/dtm/dtmsvr/storage/boltdb"
- "github.com/yedf/dtm/dtmsvr/storage/redis"
- "github.com/yedf/dtm/dtmsvr/storage/sql"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmsvr/storage"
+ "github.com/dtm-labs/dtm/dtmsvr/storage/boltdb"
+ "github.com/dtm-labs/dtm/dtmsvr/storage/redis"
+ "github.com/dtm-labs/dtm/dtmsvr/storage/sql"
)
var config = &common.Config
diff --git a/dtmsvr/storage/sql/sql.go b/dtmsvr/storage/sql/sql.go
index db4ad26..3b246ba 100644
--- a/dtmsvr/storage/sql/sql.go
+++ b/dtmsvr/storage/sql/sql.go
@@ -9,9 +9,9 @@ import (
"gorm.io/gorm"
"gorm.io/gorm/clause"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmsvr/storage"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmsvr/storage"
)
var config = &common.Config
diff --git a/dtmsvr/storage/trans.go b/dtmsvr/storage/trans.go
index 24abd58..cb85ee1 100644
--- a/dtmsvr/storage/trans.go
+++ b/dtmsvr/storage/trans.go
@@ -3,9 +3,9 @@ package storage
import (
"time"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
)
type TransGlobalStore struct {
diff --git a/dtmsvr/svr.go b/dtmsvr/svr.go
index 2aa8950..e2c739d 100644
--- a/dtmsvr/svr.go
+++ b/dtmsvr/svr.go
@@ -11,12 +11,12 @@ import (
"net"
"time"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgimp"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgpb"
+ "github.com/dtm-labs/dtmdriver"
grpc_middleware "github.com/grpc-ecosystem/go-grpc-middleware"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmgrpc/dtmgimp"
- "github.com/yedf/dtm/dtmgrpc/dtmgpb"
- "github.com/yedf/dtmdriver"
"google.golang.org/grpc"
)
diff --git a/dtmsvr/svr_imports.go b/dtmsvr/svr_imports.go
index f708b1f..7cc1bea 100644
--- a/dtmsvr/svr_imports.go
+++ b/dtmsvr/svr_imports.go
@@ -1,7 +1,7 @@
package dtmsvr
import (
- _ "github.com/ychensha/dtmdriver-polaris"
- _ "github.com/yedf/dtmdriver-gozero"
- _ "github.com/yedf/dtmdriver-protocol1"
+ _ "github.com/dtm-labs/dtmdriver-gozero"
+ _ "github.com/dtm-labs/dtmdriver-polaris"
+ _ "github.com/dtm-labs/dtmdriver-protocol1"
)
diff --git a/dtmsvr/trans_class.go b/dtmsvr/trans_class.go
index faf3125..977f44b 100644
--- a/dtmsvr/trans_class.go
+++ b/dtmsvr/trans_class.go
@@ -9,12 +9,12 @@ package dtmsvr
import (
"time"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgpb"
+ "github.com/dtm-labs/dtm/dtmsvr/storage"
"github.com/gin-gonic/gin"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmgrpc/dtmgpb"
- "github.com/yedf/dtm/dtmsvr/storage"
)
// TransGlobal global transaction
diff --git a/dtmsvr/trans_process.go b/dtmsvr/trans_process.go
index 721919e..8165e50 100644
--- a/dtmsvr/trans_process.go
+++ b/dtmsvr/trans_process.go
@@ -9,10 +9,10 @@ package dtmsvr
import (
"time"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
)
// Process process global transaction once
diff --git a/dtmsvr/trans_status.go b/dtmsvr/trans_status.go
index 371bef8..bf14e43 100644
--- a/dtmsvr/trans_status.go
+++ b/dtmsvr/trans_status.go
@@ -11,11 +11,11 @@ import (
"strings"
"time"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmgrpc/dtmgimp"
- "github.com/yedf/dtmdriver"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgimp"
+ "github.com/dtm-labs/dtmdriver"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
)
diff --git a/dtmsvr/trans_type_msg.go b/dtmsvr/trans_type_msg.go
index 63a62b6..3f62f74 100644
--- a/dtmsvr/trans_type_msg.go
+++ b/dtmsvr/trans_type_msg.go
@@ -10,8 +10,8 @@ import (
"fmt"
"strings"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
)
type transMsgProcessor struct {
diff --git a/dtmsvr/trans_type_saga.go b/dtmsvr/trans_type_saga.go
index e710d46..b74dce4 100644
--- a/dtmsvr/trans_type_saga.go
+++ b/dtmsvr/trans_type_saga.go
@@ -10,9 +10,9 @@ import (
"fmt"
"time"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
)
type transSagaProcessor struct {
diff --git a/dtmsvr/trans_type_tcc.go b/dtmsvr/trans_type_tcc.go
index 2c32ab6..31ae557 100644
--- a/dtmsvr/trans_type_tcc.go
+++ b/dtmsvr/trans_type_tcc.go
@@ -7,9 +7,9 @@
package dtmsvr
import (
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
)
type transTccProcessor struct {
diff --git a/dtmsvr/trans_type_xa.go b/dtmsvr/trans_type_xa.go
index ad44dd0..4f45205 100644
--- a/dtmsvr/trans_type_xa.go
+++ b/dtmsvr/trans_type_xa.go
@@ -7,8 +7,8 @@
package dtmsvr
import (
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
)
type transXaProcessor struct {
diff --git a/dtmsvr/utils.go b/dtmsvr/utils.go
index 07e017a..b711d40 100644
--- a/dtmsvr/utils.go
+++ b/dtmsvr/utils.go
@@ -12,10 +12,10 @@ import (
"github.com/google/uuid"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmsvr/storage"
- "github.com/yedf/dtm/dtmsvr/storage/registry"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmsvr/storage"
+ "github.com/dtm-labs/dtm/dtmsvr/storage/registry"
)
type branchStatus struct {
diff --git a/examples/base_grpc.go b/examples/base_grpc.go
index 07eb749..38cda95 100644
--- a/examples/base_grpc.go
+++ b/examples/base_grpc.go
@@ -13,14 +13,14 @@ import (
"net"
"time"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmgrpc"
"github.com/gin-gonic/gin"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmgrpc"
- "github.com/yedf/dtm/dtmgrpc/dtmgimp"
- "github.com/yedf/dtm/dtmgrpc/dtmgpb"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgimp"
+ "github.com/dtm-labs/dtm/dtmgrpc/dtmgpb"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
diff --git a/examples/base_http.go b/examples/base_http.go
index 401d1f3..cad5834 100644
--- a/examples/base_http.go
+++ b/examples/base_http.go
@@ -13,11 +13,11 @@ import (
"strings"
"time"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/gin-gonic/gin"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
"gorm.io/driver/mysql"
"gorm.io/driver/postgres"
"gorm.io/gorm"
diff --git a/examples/base_types.go b/examples/base_types.go
index f906b4a..f7a4392 100644
--- a/examples/base_types.go
+++ b/examples/base_types.go
@@ -11,12 +11,12 @@ import (
"database/sql"
"fmt"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmgrpc"
"github.com/gin-gonic/gin"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmgrpc"
)
// DtmHttpServer dtm service address
diff --git a/examples/data.go b/examples/data.go
index 0a4f52c..c865ba7 100644
--- a/examples/data.go
+++ b/examples/data.go
@@ -9,8 +9,8 @@ package examples
import (
"fmt"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
)
var config = &common.Config
diff --git a/examples/grpc_msg.go b/examples/grpc_msg.go
index 2bbe650..5e89058 100644
--- a/examples/grpc_msg.go
+++ b/examples/grpc_msg.go
@@ -7,8 +7,8 @@
package examples
import (
- "github.com/yedf/dtm/dtmcli/logger"
- dtmgrpc "github.com/yedf/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ dtmgrpc "github.com/dtm-labs/dtm/dtmgrpc"
)
func init() {
diff --git a/examples/grpc_saga.go b/examples/grpc_saga.go
index 3a29de4..395976b 100644
--- a/examples/grpc_saga.go
+++ b/examples/grpc_saga.go
@@ -7,8 +7,8 @@
package examples
import (
- "github.com/yedf/dtm/dtmcli/logger"
- dtmgrpc "github.com/yedf/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ dtmgrpc "github.com/dtm-labs/dtm/dtmgrpc"
)
func init() {
diff --git a/examples/grpc_saga_barrier.go b/examples/grpc_saga_barrier.go
index 892e140..d838181 100644
--- a/examples/grpc_saga_barrier.go
+++ b/examples/grpc_saga_barrier.go
@@ -10,10 +10,10 @@ import (
"context"
"database/sql"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmgrpc"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
emptypb "google.golang.org/protobuf/types/known/emptypb"
diff --git a/examples/grpc_tcc.go b/examples/grpc_tcc.go
index 5a6c4fd..411a3e8 100644
--- a/examples/grpc_tcc.go
+++ b/examples/grpc_tcc.go
@@ -7,8 +7,8 @@
package examples
import (
- "github.com/yedf/dtm/dtmcli/logger"
- dtmgrpc "github.com/yedf/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ dtmgrpc "github.com/dtm-labs/dtm/dtmgrpc"
emptypb "google.golang.org/protobuf/types/known/emptypb"
)
diff --git a/examples/grpc_xa.go b/examples/grpc_xa.go
index c4f9d3c..c55e953 100644
--- a/examples/grpc_xa.go
+++ b/examples/grpc_xa.go
@@ -9,8 +9,8 @@ package examples
import (
context "context"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmgrpc"
"google.golang.org/protobuf/types/known/emptypb"
)
diff --git a/examples/http_gorm_xa.go b/examples/http_gorm_xa.go
index caacb79..b77e7dd 100644
--- a/examples/http_gorm_xa.go
+++ b/examples/http_gorm_xa.go
@@ -7,9 +7,9 @@
package examples
import (
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/go-resty/resty/v2"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/logger"
)
func init() {
diff --git a/examples/http_msg.go b/examples/http_msg.go
index 3f40805..34bbc82 100644
--- a/examples/http_msg.go
+++ b/examples/http_msg.go
@@ -7,8 +7,8 @@
package examples
import (
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
)
func init() {
diff --git a/examples/http_saga.go b/examples/http_saga.go
index d7dd59b..398f045 100644
--- a/examples/http_saga.go
+++ b/examples/http_saga.go
@@ -7,8 +7,8 @@
package examples
import (
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
)
func init() {
diff --git a/examples/http_saga_barrier.go b/examples/http_saga_barrier.go
index c633c58..53af51d 100644
--- a/examples/http_saga_barrier.go
+++ b/examples/http_saga_barrier.go
@@ -9,11 +9,11 @@ package examples
import (
"database/sql"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/gin-gonic/gin"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
)
func init() {
diff --git a/examples/http_saga_gorm_barrier.go b/examples/http_saga_gorm_barrier.go
index 9499506..0eda05e 100644
--- a/examples/http_saga_gorm_barrier.go
+++ b/examples/http_saga_gorm_barrier.go
@@ -9,10 +9,10 @@ package examples
import (
"database/sql"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/gin-gonic/gin"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/logger"
)
func init() {
diff --git a/examples/http_tcc.go b/examples/http_tcc.go
index 76dff2f..3055d44 100644
--- a/examples/http_tcc.go
+++ b/examples/http_tcc.go
@@ -7,11 +7,11 @@
package examples
import (
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/gin-gonic/gin"
"github.com/go-resty/resty/v2"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/logger"
)
func init() {
diff --git a/examples/http_tcc_barrier.go b/examples/http_tcc_barrier.go
index 56a0467..70b018a 100644
--- a/examples/http_tcc_barrier.go
+++ b/examples/http_tcc_barrier.go
@@ -10,12 +10,12 @@ import (
"database/sql"
"fmt"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/gin-gonic/gin"
"github.com/go-resty/resty/v2"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
)
func init() {
diff --git a/examples/http_xa.go b/examples/http_xa.go
index a288b45..6ba6f2d 100644
--- a/examples/http_xa.go
+++ b/examples/http_xa.go
@@ -7,11 +7,11 @@
package examples
import (
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/gin-gonic/gin"
"github.com/go-resty/resty/v2"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/logger"
)
// XaClient XA client connection
diff --git a/examples/quick_start.go b/examples/quick_start.go
index 47329ed..8115c89 100644
--- a/examples/quick_start.go
+++ b/examples/quick_start.go
@@ -10,11 +10,11 @@ import (
"fmt"
"time"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
"github.com/gin-gonic/gin"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
)
// 启动命令：go run app/main.go qs
diff --git a/go.mod b/go.mod
index 5982ea1..fdd8107 100644
--- a/go.mod
+++ b/go.mod
@@ -1,8 +1,12 @@
-module github.com/yedf/dtm
+module github.com/dtm-labs/dtm
go 1.15
require (
+ github.com/dtm-labs/dtmdriver v0.0.1
+ github.com/dtm-labs/dtmdriver-gozero v0.0.1
+ github.com/dtm-labs/dtmdriver-polaris v0.0.2
+ github.com/dtm-labs/dtmdriver-protocol1 v0.0.1
github.com/gin-gonic/gin v1.6.3
github.com/go-playground/assert/v2 v2.0.1
github.com/go-redis/redis/v8 v8.11.4
@@ -15,10 +19,6 @@ require (
github.com/polarismesh/grpc-go-polaris v0.0.0-20211128162137-1a59cd7b5733 // indirect
github.com/prometheus/client_golang v1.11.0
github.com/stretchr/testify v1.7.0
- github.com/ychensha/dtmdriver-polaris v0.0.1
- github.com/yedf/dtmdriver v0.0.0-20211203060147-29426c663b6e
- github.com/yedf/dtmdriver-gozero v0.0.0-20211204083751-a14485949435
- github.com/yedf/dtmdriver-protocol1 v0.0.0-20211205112411-d7a7052dc90e
go.etcd.io/bbolt v1.3.6
go.uber.org/atomic v1.9.0 // indirect
go.uber.org/automaxprocs v1.4.1-0.20210525221652-0180b04c18a7
diff --git a/go.sum b/go.sum
index a652bd4..1aa3c42 100644
--- a/go.sum
+++ b/go.sum
@@ -31,6 +31,8 @@ github.com/Azure/go-autorest/logger v0.2.0/go.mod h1:T9E3cAhj2VqvPOtCYAvby9aBXkZ
github.com/Azure/go-autorest/tracing v0.6.0/go.mod h1:+vhtPC754Xsa23ID7GlGsrdKBpUA79WCAKPPZVC2DeU=
github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ=
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
+github.com/BurntSushi/toml v0.4.1 h1:GaI7EiDXDRfa8VshkTj7Fym7ha+y8/XxIgD2okUIjLw=
+github.com/BurntSushi/toml v0.4.1/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ=
github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
github.com/ClickHouse/clickhouse-go v1.5.1/go.mod h1:EaI/sW7Azgz9UATzd5ZdZHRUhHgv5+JMS9NSr2smCJI=
github.com/DATA-DOG/go-sqlmock v1.5.0/go.mod h1:f/Ixk793poVmq4qj/V1dPUg2JEAKC73Q5eFN3EC/SaM=
@@ -92,6 +94,20 @@ github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/r
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
github.com/docker/spdystream v0.0.0-20160310174837-449fdfce4d96/go.mod h1:Qh8CwZgvJUkLughtfhJv5dyTYa91l1fOUCrgjqmcifM=
github.com/docopt/docopt-go v0.0.0-20180111231733-ee0de3bc6815/go.mod h1:WwZ+bS3ebgob9U8Nd0kOddGdZWjyMGR8Wziv+TBNwSE=
+github.com/dtm-labs/dtmdriver v0.0.0-20211203060147-29426c663b6e h1:xXyb4mr46T5KqR5SXd37ivXNJ33k/MSAAwsGP6btmh8=
+github.com/dtm-labs/dtmdriver v0.0.0-20211203060147-29426c663b6e/go.mod h1:aeo6ZWiVI0x8P8O18r6uB1cG2uw9BCQyYZaH15MlRDI=
+github.com/dtm-labs/dtmdriver v0.0.1 h1:dHUZQ6g2ZN6eRUqds9kKq/3K7u9bcUGatUlbthD92fA=
+github.com/dtm-labs/dtmdriver v0.0.1/go.mod h1:fLiEeD2BPwM9Yq96TfcP9KpbTwFsn5nTxa/PP0jmFuk=
+github.com/dtm-labs/dtmdriver-gozero v0.0.0-20211204083751-a14485949435 h1:qLBNU16bK1ZeaZ6tmfarf49qx9O9sUJAe7/IzoXpuEg=
+github.com/dtm-labs/dtmdriver-gozero v0.0.0-20211204083751-a14485949435/go.mod h1:RYtA6oZny6LzlIRb1tPGt5bHfgqws/JaU6ogFly8ByQ=
+github.com/dtm-labs/dtmdriver-gozero v0.0.1 h1:ExDhMsn3MJCd+psSmIJVDgGUqbFrQGP0IpKL8x900AE=
+github.com/dtm-labs/dtmdriver-gozero v0.0.1/go.mod h1:uIiAMkG/Vp4jvINk5XfVMT0mSCzRqIYyXgpmqAQfqbA=
+github.com/dtm-labs/dtmdriver-polaris v0.0.2 h1:bh8u7bLWhairwpiA688dZMAX/OWcRoQk7a5bVcGzsjo=
+github.com/dtm-labs/dtmdriver-polaris v0.0.2/go.mod h1:vyXDTRj3CpROiRnI0dqM/lHFfZaKY9JAS1MSey2azIQ=
+github.com/dtm-labs/dtmdriver-protocol1 v0.0.0-20211205112411-d7a7052dc90e h1:hNSfnVdE46i45HS6aneN+6umk+12EqI3AErbbzeLsoo=
+github.com/dtm-labs/dtmdriver-protocol1 v0.0.0-20211205112411-d7a7052dc90e/go.mod h1:kB3NPnDKSGioVjgdfj6qgbqYJinOml45GnlHqR46Ycc=
+github.com/dtm-labs/dtmdriver-protocol1 v0.0.1 h1:nwGpGWi7XlUAcDhEw1qZ3TheBskqCvfE96n1uVjmDf4=
+github.com/dtm-labs/dtmdriver-protocol1 v0.0.1/go.mod h1:x3bRe8x7pAfHIIQBTK+LibVq96gBSzMzsgRYe85zxAc=
github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
github.com/eapache/go-resiliency v1.1.0/go.mod h1:kFI+JgMyC7bLPUVY133qvEBtVayf5mFgVsvEsIPBvNs=
github.com/eapache/go-resiliency v1.2.0/go.mod h1:kFI+JgMyC7bLPUVY133qvEBtVayf5mFgVsvEsIPBvNs=
@@ -495,12 +511,6 @@ github.com/xdg-go/scram v1.0.2/go.mod h1:1WAq6h33pAW+iRreB34OORO2Nf7qel3VV3fjBj+
github.com/xdg-go/stringprep v1.0.2/go.mod h1:8F9zXuvzgwmyT5DUm4GUfZGDdT3W+LCvS6+da4O5kxM=
github.com/ychensha/dtmdriver-polaris v0.0.1 h1:+gYWFma5pflxNyV1HkcXmhzVHpijMSW9G4qTDcs63xc=
github.com/ychensha/dtmdriver-polaris v0.0.1/go.mod h1:0BdQvxXlGOlF6YVlsDoVvu8jyxdTlJZ9Kyh5t9lRA94=
-github.com/yedf/dtmdriver v0.0.0-20211203060147-29426c663b6e h1:xXyb4mr46T5KqR5SXd37ivXNJ33k/MSAAwsGP6btmh8=
-github.com/yedf/dtmdriver v0.0.0-20211203060147-29426c663b6e/go.mod h1:aeo6ZWiVI0x8P8O18r6uB1cG2uw9BCQyYZaH15MlRDI=
-github.com/yedf/dtmdriver-gozero v0.0.0-20211204083751-a14485949435 h1:qLBNU16bK1ZeaZ6tmfarf49qx9O9sUJAe7/IzoXpuEg=
-github.com/yedf/dtmdriver-gozero v0.0.0-20211204083751-a14485949435/go.mod h1:RYtA6oZny6LzlIRb1tPGt5bHfgqws/JaU6ogFly8ByQ=
-github.com/yedf/dtmdriver-protocol1 v0.0.0-20211205112411-d7a7052dc90e h1:hNSfnVdE46i45HS6aneN+6umk+12EqI3AErbbzeLsoo=
-github.com/yedf/dtmdriver-protocol1 v0.0.0-20211205112411-d7a7052dc90e/go.mod h1:kB3NPnDKSGioVjgdfj6qgbqYJinOml45GnlHqR46Ycc=
github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=
@@ -892,4 +902,3 @@ sigs.k8s.io/structured-merge-diff/v4 v4.1.2/go.mod h1:j/nl6xW8vLS49O8YvXW1ocPhZa
sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o=
sigs.k8s.io/yaml v1.2.0 h1:kr/MCeFWJWTwyaHoR9c8EjH9OumOmoF9YGiZd7lFm/Q=
sigs.k8s.io/yaml v1.2.0/go.mod h1:yfXDCHCao9+ENCvLSE62v9VSji2MKu5jeNfTrofGhJc=
-
diff --git a/helper/sync-dtmcli.sh b/helper/sync-dtmcli.sh
index 7f809d0..25a0d51 100755
--- a/helper/sync-dtmcli.sh
+++ b/helper/sync-dtmcli.sh
@@ -24,7 +24,7 @@ git tag $ver
git push --tags
cd ../dtmcli-go-sample
-go get -u github.com/yedf/dtmcli@$ver
+go get -u github.com/dtm-labs/dtmcli@$ver
go mod tidy
go build || exit 1
git add .
@@ -37,7 +37,7 @@ git push --tags
cd ../dtmgrpc
rm -rf *.go dtmgimp
cp -r ../dtm/dtmgrpc/* ./
-go get github.com/yedf/dtmcli@$ver
+go get github.com/dtm-labs/dtmcli@$ver
sed -i '' -e 's/yedf\/dtm\//yedf\//g' *.go
sed -i '' -e 's/yedf\/dtm\//yedf\//g' dtmgimp/*.go dtmgimp/*.proto
rm -rf *_test.go
@@ -50,8 +50,8 @@ git tag $ver
git push --tags
cd ../dtmgrpc-go-sample
-go get github.com/yedf/dtmcli@$ver
-go get github.com/yedf/dtmgrpc@$ver
+go get github.com/dtm-labs/dtmcli@$ver
+go get github.com/dtm-labs/dtmgrpc@$ver
protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative busi/*.proto || exit 1
go build || exit 1
git add .
diff --git a/helper/test-cover.sh b/helper/test-cover.sh
index b94a361..c462626 100644
--- a/helper/test-cover.sh
+++ b/helper/test-cover.sh
@@ -2,7 +2,7 @@ set -x
echo "" > coverage.txt
for store in redis mysql boltdb; do
for d in $(go list ./... | grep -v vendor); do
- TEST_STORE=$store go test -covermode count -coverprofile=profile.out -coverpkg=github.com/yedf/dtm/common,github.com/yedf/dtm/dtmcli,github.com/yedf/dtm/dtmcli/dtmimp,github.com/yedf/dtm/dtmgrpc,github.com/yedf/dtm/dtmgrpc/dtmgimp,github.com/yedf/dtm/dtmsvr,github.com/yedf/dtm/dtmsvr/storage,github.com/yedf/dtm/dtmsvr/storage/boltdb,github.com/yedf/dtm/dtmsvr/storage/redis,github.com/yedf/dtm/dtmsvr/storage/registry,github.com/yedf/dtm/dtmsvr/storage/sql,github.com/yedf/dtm/dtmsvr/storage/boltdb,github.com/yedf/dtm/dtmsvr/storage/registry -gcflags=-l $d
+ TEST_STORE=$store go test -covermode count -coverprofile=profile.out -coverpkg=github.com/dtm-labs/dtm/common,github.com/dtm-labs/dtm/dtmcli,github.com/dtm-labs/dtm/dtmcli/dtmimp,github.com/dtm-labs/dtm/dtmgrpc,github.com/dtm-labs/dtm/dtmgrpc/dtmgimp,github.com/dtm-labs/dtm/dtmsvr,github.com/dtm-labs/dtm/dtmsvr/storage,github.com/dtm-labs/dtm/dtmsvr/storage/boltdb,github.com/dtm-labs/dtm/dtmsvr/storage/redis,github.com/dtm-labs/dtm/dtmsvr/storage/registry,github.com/dtm-labs/dtm/dtmsvr/storage/sql,github.com/dtm-labs/dtm/dtmsvr/storage/boltdb,github.com/dtm-labs/dtm/dtmsvr/storage/registry -gcflags=-l $d
if [ -f profile.out ]; then
cat profile.out >> coverage.txt
echo > profile.out
diff --git a/test/api_test.go b/test/api_test.go
index e44ed14..bb37e40 100644
--- a/test/api_test.go
+++ b/test/api_test.go
@@ -10,9 +10,9 @@ import (
"fmt"
"testing"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func TestAPIQuery(t *testing.T) {
diff --git a/test/base_test.go b/test/base_test.go
index deffa8d..3748802 100644
--- a/test/base_test.go
+++ b/test/base_test.go
@@ -11,12 +11,12 @@ import (
"fmt"
"testing"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/examples"
)
// BarrierModel barrier model for gorm
diff --git a/test/dtmsvr_test.go b/test/dtmsvr_test.go
index 52ac6ae..b855e79 100644
--- a/test/dtmsvr_test.go
+++ b/test/dtmsvr_test.go
@@ -10,13 +10,13 @@ import (
"testing"
"time"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmsvr"
+ "github.com/dtm-labs/dtm/examples"
"github.com/gin-gonic/gin"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmsvr"
- "github.com/yedf/dtm/examples"
)
var DtmServer = examples.DtmHttpServer
diff --git a/test/examples_test.go b/test/examples_test.go
index e7c70cf..0ed0ca2 100644
--- a/test/examples_test.go
+++ b/test/examples_test.go
@@ -9,7 +9,7 @@ package test
import (
"testing"
- "github.com/yedf/dtm/examples"
+ "github.com/dtm-labs/dtm/examples"
)
func TestExamples(t *testing.T) {
diff --git a/test/main_test.go b/test/main_test.go
index 306a10c..5aa62d5 100644
--- a/test/main_test.go
+++ b/test/main_test.go
@@ -11,11 +11,11 @@ import (
"testing"
"time"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmsvr"
+ "github.com/dtm-labs/dtm/examples"
"github.com/gin-gonic/gin"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmsvr"
- "github.com/yedf/dtm/examples"
)
func exitIf(code int) {
diff --git a/test/msg_grpc_test.go b/test/msg_grpc_test.go
index 3ae048d..1869be9 100644
--- a/test/msg_grpc_test.go
+++ b/test/msg_grpc_test.go
@@ -10,11 +10,11 @@ import (
"fmt"
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmgrpc"
- "github.com/yedf/dtm/examples"
)
func TestMsgGrpcNormal(t *testing.T) {
diff --git a/test/msg_options_test.go b/test/msg_options_test.go
index 85e57ff..49e6265 100644
--- a/test/msg_options_test.go
+++ b/test/msg_options_test.go
@@ -9,10 +9,10 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func TestMsgOptionsTimeout(t *testing.T) {
diff --git a/test/msg_test.go b/test/msg_test.go
index 1fd9c4f..40d5dc2 100644
--- a/test/msg_test.go
+++ b/test/msg_test.go
@@ -9,10 +9,10 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func TestMsgNormal(t *testing.T) {
diff --git a/test/saga_barrier_test.go b/test/saga_barrier_test.go
index 6d8842c..59a84dd 100644
--- a/test/saga_barrier_test.go
+++ b/test/saga_barrier_test.go
@@ -9,10 +9,10 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func TestSagaBarrierNormal(t *testing.T) {
diff --git a/test/saga_compatible_test.go b/test/saga_compatible_test.go
index c7e29f9..20ea21f 100644
--- a/test/saga_compatible_test.go
+++ b/test/saga_compatible_test.go
@@ -10,9 +10,9 @@ import (
"fmt"
"testing"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func TestSagaCompatibleNormal(t *testing.T) { // compatible with old http, which put payload in steps.data
diff --git a/test/saga_concurrent_test.go b/test/saga_concurrent_test.go
index dda6aaf..a629510 100644
--- a/test/saga_concurrent_test.go
+++ b/test/saga_concurrent_test.go
@@ -9,10 +9,10 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func genSagaCon(gid string, outFailed bool, inFailed bool) *dtmcli.Saga {
diff --git a/test/saga_grpc_barrier_test.go b/test/saga_grpc_barrier_test.go
index 589eb32..1078368 100644
--- a/test/saga_grpc_barrier_test.go
+++ b/test/saga_grpc_barrier_test.go
@@ -9,10 +9,10 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmgrpc"
- "github.com/yedf/dtm/examples"
)
func TestSagaGrpcBarrierNormal(t *testing.T) {
diff --git a/test/saga_grpc_test.go b/test/saga_grpc_test.go
index d611241..61a114c 100644
--- a/test/saga_grpc_test.go
+++ b/test/saga_grpc_test.go
@@ -9,11 +9,11 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmgrpc"
- "github.com/yedf/dtm/examples"
)
func TestSagaGrpcNormal(t *testing.T) {
diff --git a/test/saga_options_test.go b/test/saga_options_test.go
index 7a11fcf..c82bd56 100644
--- a/test/saga_options_test.go
+++ b/test/saga_options_test.go
@@ -9,10 +9,10 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func TestSagaOptionsRetryOngoing(t *testing.T) {
diff --git a/test/saga_test.go b/test/saga_test.go
index 5fbc166..5093ec5 100644
--- a/test/saga_test.go
+++ b/test/saga_test.go
@@ -9,10 +9,10 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func TestSagaNormal(t *testing.T) {
diff --git a/test/store_test.go b/test/store_test.go
index 49549c0..08c9966 100644
--- a/test/store_test.go
+++ b/test/store_test.go
@@ -6,9 +6,9 @@ import (
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmsvr/storage"
- "github.com/yedf/dtm/dtmsvr/storage/registry"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmsvr/storage"
+ "github.com/dtm-labs/dtm/dtmsvr/storage/registry"
)
func initTransGlobal(gid string) (*storage.TransGlobalStore, storage.Store) {
diff --git a/test/tcc_barrier_test.go b/test/tcc_barrier_test.go
index 238a70d..6194b64 100644
--- a/test/tcc_barrier_test.go
+++ b/test/tcc_barrier_test.go
@@ -14,13 +14,13 @@ import (
"testing"
"time"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/examples"
"github.com/gin-gonic/gin"
"github.com/go-resty/resty/v2"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/examples"
)
func TestTccBarrierNormal(t *testing.T) {
diff --git a/test/tcc_cover_test.go b/test/tcc_cover_test.go
index 12e5a32..d865395 100644
--- a/test/tcc_cover_test.go
+++ b/test/tcc_cover_test.go
@@ -3,11 +3,11 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/go-resty/resty/v2"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func TestTccCoverNotConnected(t *testing.T) {
diff --git a/test/tcc_grpc_cover_test.go b/test/tcc_grpc_cover_test.go
index f4c3fef..c23c160 100644
--- a/test/tcc_grpc_cover_test.go
+++ b/test/tcc_grpc_cover_test.go
@@ -3,10 +3,10 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmgrpc"
- "github.com/yedf/dtm/examples"
"google.golang.org/protobuf/types/known/emptypb"
)
diff --git a/test/tcc_grpc_test.go b/test/tcc_grpc_test.go
index 16ba193..c2c919d 100644
--- a/test/tcc_grpc_test.go
+++ b/test/tcc_grpc_test.go
@@ -10,12 +10,12 @@ import (
"context"
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmgrpc"
- "github.com/yedf/dtm/examples"
"google.golang.org/protobuf/types/known/emptypb"
)
diff --git a/test/tcc_test.go b/test/tcc_test.go
index 0697f4e..b2cf9c3 100644
--- a/test/tcc_test.go
+++ b/test/tcc_test.go
@@ -9,11 +9,11 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/go-resty/resty/v2"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func TestTccNormal(t *testing.T) {
diff --git a/test/types.go b/test/types.go
index bef96cc..923cc35 100644
--- a/test/types.go
+++ b/test/types.go
@@ -9,11 +9,11 @@ package test
import (
"time"
- "github.com/yedf/dtm/common"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmcli/logger"
- "github.com/yedf/dtm/dtmsvr"
+ "github.com/dtm-labs/dtm/common"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmcli/logger"
+ "github.com/dtm-labs/dtm/dtmsvr"
)
var config = &common.Config
diff --git a/test/xa_cover_test.go b/test/xa_cover_test.go
index bd6d8be..6c61700 100644
--- a/test/xa_cover_test.go
+++ b/test/xa_cover_test.go
@@ -3,11 +3,11 @@ package test
import (
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/go-resty/resty/v2"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func TestXaCoverDBError(t *testing.T) {
diff --git a/test/xa_grpc_test.go b/test/xa_grpc_test.go
index 76e1111..283df1b 100644
--- a/test/xa_grpc_test.go
+++ b/test/xa_grpc_test.go
@@ -11,10 +11,10 @@ import (
"fmt"
"testing"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/dtmgrpc"
+ "github.com/dtm-labs/dtm/examples"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/dtmgrpc"
- "github.com/yedf/dtm/examples"
"google.golang.org/protobuf/types/known/emptypb"
)
diff --git a/test/xa_test.go b/test/xa_test.go
index 7122910..929d80d 100644
--- a/test/xa_test.go
+++ b/test/xa_test.go
@@ -10,11 +10,11 @@ import (
"fmt"
"testing"
+ "github.com/dtm-labs/dtm/dtmcli"
+ "github.com/dtm-labs/dtm/dtmcli/dtmimp"
+ "github.com/dtm-labs/dtm/examples"
"github.com/go-resty/resty/v2"
"github.com/stretchr/testify/assert"
- "github.com/yedf/dtm/dtmcli"
- "github.com/yedf/dtm/dtmcli/dtmimp"
- "github.com/yedf/dtm/examples"
)
func getXc() *dtmcli.XaClient {