Skip to content

Commit

Permalink
chore: update go-zero to v1.3.0
Browse files Browse the repository at this point in the history
  • Loading branch information
kevwan committed Feb 1, 2022
1 parent 9edfaea commit 8200942
Show file tree
Hide file tree
Showing 12 changed files with 70 additions and 71 deletions.
2 changes: 1 addition & 1 deletion dq/config.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package dq

import "github.com/tal-tech/go-zero/core/stores/redis"
import "github.com/zeromicro/go-zero/core/stores/redis"

type (
Beanstalk struct {
Expand Down
8 changes: 4 additions & 4 deletions dq/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,10 @@ import (
"strconv"
"time"

"github.com/tal-tech/go-zero/core/hash"
"github.com/tal-tech/go-zero/core/logx"
"github.com/tal-tech/go-zero/core/service"
"github.com/tal-tech/go-zero/core/stores/redis"
"github.com/zeromicro/go-zero/core/hash"
"github.com/zeromicro/go-zero/core/logx"
"github.com/zeromicro/go-zero/core/service"
"github.com/zeromicro/go-zero/core/stores/redis"
)

const (
Expand Down
4 changes: 2 additions & 2 deletions dq/consumernode.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,8 @@ import (
"time"

"github.com/beanstalkd/go-beanstalk"
"github.com/tal-tech/go-zero/core/logx"
"github.com/tal-tech/go-zero/core/syncx"
"github.com/zeromicro/go-zero/core/logx"
"github.com/zeromicro/go-zero/core/syncx"
)

type (
Expand Down
8 changes: 4 additions & 4 deletions dq/producer.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,10 @@ import (
"strings"
"time"

"github.com/tal-tech/go-zero/core/errorx"
"github.com/tal-tech/go-zero/core/fx"
"github.com/tal-tech/go-zero/core/lang"
"github.com/tal-tech/go-zero/core/logx"
"github.com/zeromicro/go-zero/core/errorx"
"github.com/zeromicro/go-zero/core/fx"
"github.com/zeromicro/go-zero/core/lang"
"github.com/zeromicro/go-zero/core/logx"
)

const (
Expand Down
2 changes: 1 addition & 1 deletion example/dq/consumer/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@ package main
import (
"fmt"

"github.com/tal-tech/go-zero/core/stores/redis"
"github.com/zeromicro/go-queue/dq"
"github.com/zeromicro/go-zero/core/stores/redis"
)

func main() {
Expand Down
2 changes: 1 addition & 1 deletion example/kq/consumer/queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@ package main
import (
"fmt"

"github.com/tal-tech/go-zero/core/conf"
"github.com/zeromicro/go-queue/kq"
"github.com/zeromicro/go-zero/core/conf"
)

func main() {
Expand Down
2 changes: 1 addition & 1 deletion example/kq/producer/produce.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,8 @@ import (
"strconv"
"time"

"github.com/tal-tech/go-zero/core/cmdline"
"github.com/zeromicro/go-queue/kq"
"github.com/zeromicro/go-zero/core/cmdline"
)

type message struct {
Expand Down
4 changes: 2 additions & 2 deletions go.mod
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
module github.com/zeromicro/go-queue

go 1.14
go 1.15

require (
github.com/beanstalkd/go-beanstalk v0.1.0
github.com/segmentio/kafka-go v0.4.25
github.com/tal-tech/go-zero v1.2.5
github.com/zeromicro/go-zero v1.3.0
)
91 changes: 45 additions & 46 deletions go.sum

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion kq/config.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package kq

import "github.com/tal-tech/go-zero/core/service"
import "github.com/zeromicro/go-zero/core/service"

const (
firstOffset = "first"
Expand Down
4 changes: 2 additions & 2 deletions kq/pusher.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,8 @@ import (

"github.com/segmentio/kafka-go"
"github.com/segmentio/kafka-go/snappy"
"github.com/tal-tech/go-zero/core/executors"
"github.com/tal-tech/go-zero/core/logx"
"github.com/zeromicro/go-zero/core/executors"
"github.com/zeromicro/go-zero/core/logx"
)

type (
Expand Down
12 changes: 6 additions & 6 deletions kq/queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,12 +10,12 @@ import (
_ "github.com/segmentio/kafka-go/gzip"
_ "github.com/segmentio/kafka-go/lz4"
_ "github.com/segmentio/kafka-go/snappy"
"github.com/tal-tech/go-zero/core/logx"
"github.com/tal-tech/go-zero/core/queue"
"github.com/tal-tech/go-zero/core/service"
"github.com/tal-tech/go-zero/core/stat"
"github.com/tal-tech/go-zero/core/threading"
"github.com/tal-tech/go-zero/core/timex"
"github.com/zeromicro/go-zero/core/logx"
"github.com/zeromicro/go-zero/core/queue"
"github.com/zeromicro/go-zero/core/service"
"github.com/zeromicro/go-zero/core/stat"
"github.com/zeromicro/go-zero/core/threading"
"github.com/zeromicro/go-zero/core/timex"
)

const (
Expand Down

0 comments on commit 8200942

Please sign in to comment.