change mod name, fmt code

etcd/etcd.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"time"
 
-	"kettle/utl"
+	"git.wenlab.co/joe/kettle/utl"
 
 	"github.com/coreos/etcd/clientv3"
 )

go.mod

@@ -1,4 +1,4 @@
-module kettle
+module git.wenlab.co/joe/kettle
 
 go 1.17
 

htp/client.go

@@ -6,7 +6,7 @@ import (
 	"net/http"
 	"time"
 
-	"kettle/utl"
+	"git.wenlab.co/joe/kettle/utl"
 )
 
 type ClientOption func(*Client)

log/logger_test.go

@@ -16,4 +16,4 @@ func TestSLogger_Error(t *testing.T) {
 	Info("info")
 	Error("good")
 	Warn("hhhh")
-}
+}

mac/machine_test.go

@@ -14,4 +14,4 @@ func TestGetMacInfoImmutablePart(t *testing.T) {
 func TestGetMachInfoMutablePart(t *testing.T) {
 	GetMachInfoMutablePart(&mm)
 	t.Logf("%v", mm)
-}
+}

oss/ioss.go

@@ -10,5 +10,5 @@ type IOss interface {
 	UploadFile(absPath string, key string, conf *UploadConf) (string, error)
 	Upload(reader io.Reader, len int64, key string, conf *UploadConf) (string, error)
 	Delete(key string) error
-	Exists(key string) (bool)
+	Exists(key string) bool
 }

oss/osssvr/disable.go

@@ -2,7 +2,8 @@ package osssvr
 
 import (
 	"io"
-	"kettle/oss"
+
+	"git.wenlab.co/joe/kettle/oss"
 )
 
 type disableOss struct{}

oss/osssvr/qiniu.go

@@ -4,7 +4,8 @@ import (
 	"context"
 	"fmt"
 	"io"
-	"kettle/oss"
+
+	"git.wenlab.co/joe/kettle/oss"
 
 	"github.com/qiniu/go-sdk/v7/auth/qbox"
 	"github.com/qiniu/go-sdk/v7/storage"

oss/osssvr/qiniu_test.go

@@ -1,10 +1,11 @@
 package osssvr
 
 import (
-	"kettle/oss"
 	"path/filepath"
 	"testing"
 
+	"git.wenlab.co/joe/kettle/oss"
+
 	"github.com/qiniu/go-sdk/v7/storage"
 )
 

rds/client_test.go

@@ -1,8 +1,9 @@
 package rds
 
 import (
-	"kettle/utl"
 	"testing"
+
+	"git.wenlab.co/joe/kettle/utl"
 )
 
 const (

rds/script.go

@@ -2,11 +2,12 @@ package rds
 
 import (
 	"io/ioutil"
-	"kettle/utl"
 	"os"
 	"path/filepath"
 	"strings"
 
+	"git.wenlab.co/joe/kettle/utl"
+
 	"github.com/go-redis/redis"
 )
 

rds/script_test.go

@@ -1,8 +1,9 @@
 package rds
 
 import (
-	"kettle/utl"
 	"testing"
+
+	"git.wenlab.co/joe/kettle/utl"
 )
 
 func TestNewLuaScripts(t *testing.T) {

sms/smsplat/aliyun.go

@@ -1,11 +1,12 @@
 package smsplat
 
 import (
-	"kettle/sms"
-	"kettle/utl"
 	"net/http"
 	"time"
 
+	"git.wenlab.co/joe/kettle/sms"
+	"git.wenlab.co/joe/kettle/utl"
+
 	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
 	"github.com/aliyun/alibaba-cloud-sdk-go/services/dysmsapi"
 )

sms/smsplat/aliyun_test.go

@@ -2,8 +2,9 @@ package smsplat
 
 import (
 	"encoding/json"
-	"kettle/utl"
 	"testing"
+
+	"git.wenlab.co/joe/kettle/utl"
 )
 
 const (

sms/smsplat/disable_sms.go

@@ -1,7 +1,7 @@
 package smsplat
 
 import (
-	"kettle/sms"
+	"git.wenlab.co/joe/kettle/sms"
 )
 
 type disableSms struct{}

sms/smsplat/smsbao.go

@@ -2,12 +2,13 @@ package smsplat
 
 import (
 	"fmt"
-	"kettle/htp"
-	"kettle/sms"
-	"kettle/utl"
 	"net/url"
 	"strconv"
 	"strings"
+
+	"git.wenlab.co/joe/kettle/htp"
+	"git.wenlab.co/joe/kettle/sms"
+	"git.wenlab.co/joe/kettle/utl"
 )
 
 const (

wkrp/dispatcher.go

@@ -1,8 +1,9 @@
 package wkrp
 
 import (
-	"kettle/utl"
 	"sync"
+
+	"git.wenlab.co/joe/kettle/utl"
 )
 
 const (

wkrp/dispatcher_test.go

@@ -2,9 +2,10 @@ package wkrp
 
 import (
 	"fmt"
-	"kettle/utl"
 	"testing"
 	"time"
+
+	"git.wenlab.co/joe/kettle/utl"
 )
 
 func TestNewDispacher(t *testing.T) {

wkrp/doc.go

@@ -10,4 +10,4 @@ package wkrp
     })
 	...
 	wp.Stop()
- */
+*/

wkrp/worker.go

@@ -1,6 +1,6 @@
 package wkrp
 
-import "kettle/utl"
+import "git.wenlab.co/joe/kettle/utl"
 
 /**
 worker managed by dispatcher