Skip to content

Commit ae260e1

Browse files
vmihailencovmihailenco
committed
go mod v2
1 parent 5befc46 commit ae260e1

33 files changed

+86
-63
lines changed

‎README.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
## Installation
77

88
```bash
9-
go get -u github.com/vmihailenco/taskq
9+
go get github.com/vmihailenco/taskq/v2
1010
```
1111

1212
## Features

‎azsqs/factory.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,8 @@ package azsqs
33
import (
44
"github.com/aws/aws-sdk-go/service/sqs"
55

6-
"github.com/vmihailenco/taskq"
7-
"github.com/vmihailenco/taskq/internal/base"
6+
"github.com/vmihailenco/taskq/v2"
7+
"github.com/vmihailenco/taskq/v2/internal/base"
88
)
99

1010
type factory struct {

‎azsqs/queue.go

+5-5
Original file line numberDiff line numberDiff line change
@@ -12,11 +12,11 @@ import (
1212
"github.com/aws/aws-sdk-go/aws/awserr"
1313
"github.com/aws/aws-sdk-go/service/sqs"
1414

15-
"github.com/vmihailenco/taskq"
16-
"github.com/vmihailenco/taskq/internal"
17-
"github.com/vmihailenco/taskq/internal/base"
18-
"github.com/vmihailenco/taskq/internal/msgutil"
19-
"github.com/vmihailenco/taskq/memqueue"
15+
"github.com/vmihailenco/taskq/v2"
16+
"github.com/vmihailenco/taskq/v2/internal"
17+
"github.com/vmihailenco/taskq/v2/internal/base"
18+
"github.com/vmihailenco/taskq/v2/internal/msgutil"
19+
"github.com/vmihailenco/taskq/v2/memqueue"
2020
)
2121

2222
const msgSizeLimit = 262144

‎azsqs_test.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -4,11 +4,11 @@ import (
44
"os"
55
"testing"
66

7-
"github.com/vmihailenco/taskq"
8-
"github.com/vmihailenco/taskq/azsqs"
9-
107
"github.com/aws/aws-sdk-go/aws/session"
118
"github.com/aws/aws-sdk-go/service/sqs"
9+
10+
"github.com/vmihailenco/taskq/v2"
11+
"github.com/vmihailenco/taskq/v2/azsqs"
1212
)
1313

1414
var accountID string

‎bench_test.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,9 @@ import (
44
"sync"
55
"testing"
66

7-
"github.com/vmihailenco/taskq"
8-
"github.com/vmihailenco/taskq/memqueue"
9-
"github.com/vmihailenco/taskq/redisq"
7+
"github.com/vmihailenco/taskq/v2"
8+
"github.com/vmihailenco/taskq/v2/memqueue"
9+
"github.com/vmihailenco/taskq/v2/redisq"
1010
)
1111

1212
func BenchmarkConsumerMemq(b *testing.B) {

‎consumer.go

+3-2
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,10 @@ import (
88
"sync/atomic"
99
"time"
1010

11-
"github.com/vmihailenco/taskq/internal"
12-
"github.com/vmihailenco/taskq/internal/redislock"
1311
"golang.org/x/time/rate"
12+
13+
"github.com/vmihailenco/taskq/v2/internal"
14+
"github.com/vmihailenco/taskq/v2/internal/redislock"
1415
)
1516

1617
const timePrecision = time.Microsecond

‎consumer_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ import (
1414
"github.com/go-redis/redis"
1515
"golang.org/x/time/rate"
1616

17-
"github.com/vmihailenco/taskq"
17+
"github.com/vmihailenco/taskq/v2"
1818
)
1919

2020
const waitTimeout = time.Second

‎example_ratelimit_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@ import (
44
"fmt"
55
"time"
66

7-
"github.com/vmihailenco/taskq"
8-
"github.com/vmihailenco/taskq/memqueue"
7+
"github.com/vmihailenco/taskq/v2"
8+
"github.com/vmihailenco/taskq/v2/memqueue"
99
)
1010

1111
type RateLimitError string

‎example_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,8 @@ import (
88

99
"golang.org/x/time/rate"
1010

11-
"github.com/vmihailenco/taskq"
12-
"github.com/vmihailenco/taskq/memqueue"
11+
"github.com/vmihailenco/taskq/v2"
12+
"github.com/vmihailenco/taskq/v2/memqueue"
1313
)
1414

1515
func timeSince(start time.Time) time.Duration {

‎examples/api_worker/api/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package main
33
import (
44
"log"
55

6-
"github.com/vmihailenco/taskq/examples/api_worker"
6+
"github.com/vmihailenco/taskq/v2/examples/api_worker"
77
)
88

99
func main() {

‎examples/api_worker/tasks.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,8 @@ import (
1010

1111
"github.com/go-redis/redis"
1212

13-
"github.com/vmihailenco/taskq"
14-
"github.com/vmihailenco/taskq/redisq"
13+
"github.com/vmihailenco/taskq/v2"
14+
"github.com/vmihailenco/taskq/v2/redisq"
1515
)
1616

1717
var Redis = redis.NewClient(&redis.Options{

‎examples/api_worker/worker/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package main
33
import (
44
"log"
55

6-
"github.com/vmihailenco/taskq/examples/api_worker"
6+
"github.com/vmihailenco/taskq/v2/examples/api_worker"
77
)
88

99
func main() {

‎examples/sqs_api_worker/api/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package main
33
import (
44
"log"
55

6-
"github.com/vmihailenco/taskq/examples/sqs_api_worker"
6+
"github.com/vmihailenco/taskq/v2/examples/sqs_api_worker"
77
)
88

99
func main() {

‎examples/sqs_api_worker/tasks.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,8 @@ import (
1212
"github.com/aws/aws-sdk-go/service/sqs"
1313
"github.com/go-redis/redis"
1414

15-
"github.com/vmihailenco/taskq"
16-
"github.com/vmihailenco/taskq/azsqs"
15+
"github.com/vmihailenco/taskq/v2"
16+
"github.com/vmihailenco/taskq/v2/azsqs"
1717
)
1818

1919
var Redis = redis.NewClient(&redis.Options{

‎examples/sqs_api_worker/worker/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package main
33
import (
44
"log"
55

6-
"github.com/vmihailenco/taskq/examples/sqs_api_worker"
6+
"github.com/vmihailenco/taskq/v2/examples/sqs_api_worker"
77
)
88

99
func main() {

‎go.mod

+7-1
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,15 @@
1-
module github.com/vmihailenco/taskq
1+
module github.com/vmihailenco/taskq/v2
22

33
go 1.13
44

55
require (
66
github.com/aws/aws-sdk-go v1.19.21
7+
github.com/bsm/redis-lock v8.0.0+incompatible // indirect
78
github.com/davecgh/go-spew v1.1.1 // indirect
9+
github.com/go-msgqueue/msgqueue v1.8.2 // indirect
810
github.com/go-redis/redis v0.0.0-20190629095326-73d3c18522e8
911
github.com/go-redis/redis_rate v6.5.0+incompatible
12+
github.com/golang/snappy v0.0.1 // indirect
1013
github.com/hashicorp/golang-lru v0.5.1
1114
github.com/iron-io/iron_go3 v0.0.0-20171208104426-f14ff828153c
1215
github.com/jeffh/go.bdd v0.0.0-20120717032931-88f798ee0c74 // indirect
@@ -16,7 +19,10 @@ require (
1619
github.com/stretchr/testify v1.3.0 // indirect
1720
github.com/valyala/gozstd v1.5.0
1821
github.com/vmihailenco/msgpack v4.0.4+incompatible
22+
golang.org/x/net v0.0.0-20181129055619-fae4c4e3ad76 // indirect
23+
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f // indirect
1924
golang.org/x/sys v0.0.0-20190422165155-953cdadca894 // indirect
2025
golang.org/x/time v0.0.0-20190308202827-9d24e82272b4
2126
google.golang.org/appengine v1.6.0 // indirect
27+
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 // indirect
2228
)

‎go.sum

+16
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,26 @@
11
github.com/aws/aws-sdk-go v1.19.21 h1:xLaPxl8gy0ZSXbc13jsCKIaHD6NiX+2tAQodPSEL5r8=
22
github.com/aws/aws-sdk-go v1.19.21/go.mod h1:KmX6BPdI08NWTb3/sm4ZGu5ShLoqVDhKgpiN924inxo=
3+
github.com/bsm/redis-lock v8.0.0+incompatible/go.mod h1:8dGkQ5GimBCahwF2R67tqGCJbyDZSp0gzO7wq3pDrik=
4+
github.com/bsm/redis-lock v8.0.1+incompatible h1:fMAjpnGDLlRmim9rrduK9BBiEBBZ5umwqORSItcYUbc=
5+
github.com/bsm/redis-lock v8.0.1+incompatible/go.mod h1:6x/+0cRhn40yiTNKNevREywXLnwH8TnsA3T/axEkf5g=
36
github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
47
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
58
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
69
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
710
github.com/fsnotify/fsnotify v1.4.7 h1:IXs+QLmnXW2CcXuY+8Mzv/fWEsPGWxqefPtCP5CnV9I=
811
github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
12+
github.com/go-msgqueue/msgqueue v1.8.2 h1:bIx41YS9F54oYjz1IaFzQkUAFi6XF7/3DRUhr3Ya0Pc=
13+
github.com/go-msgqueue/msgqueue v1.8.2/go.mod h1:jGIzECcSp3BGJ5/WCIDD8QGbZLQV+XI3ChmnZWQeGEc=
914
github.com/go-redis/redis v0.0.0-20190629095326-73d3c18522e8 h1:2e6XxyC6Qxi+9NdbtdKglnoqsH2LZN0bxGenZCuWvj0=
1015
github.com/go-redis/redis v0.0.0-20190629095326-73d3c18522e8/go.mod h1:nuQKdm6S7SnV28NJEN2ZNbKpddAM1O76Z2LMJcIxJVM=
16+
github.com/go-redis/redis v6.14.2+incompatible h1:UE9pLhzmWf+xHNmZsoccjXosPicuiNaInPgym8nzfg0=
17+
github.com/go-redis/redis v6.14.2+incompatible/go.mod h1:NAIEuMOZ/fxfXJIrKDQDz8wamY7mA7PouImQ2Jvg6kA=
1118
github.com/go-redis/redis_rate v6.5.0+incompatible h1:K/G+KaoJgO3kbkLLbfdg0kzJsHhhk0gVGTMgstKgbsM=
1219
github.com/go-redis/redis_rate v6.5.0+incompatible/go.mod h1:Jxe7BhQuVncH6fUQ2rwoAkc8SesjCGIWkm6fNRQo4Qg=
1320
github.com/golang/protobuf v1.2.0 h1:P3YflyNX/ehuJFLhxviNdFxQPkGK5cDcApsge1SqnvM=
1421
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
22+
github.com/golang/snappy v0.0.1 h1:Qgr9rKW7uDUkrbSmQeiDsGa8SjGyCOGtuasMWwvp2P4=
23+
github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
1524
github.com/hashicorp/golang-lru v0.5.1 h1:0hERBMJE1eitiLkihrMvRVBYAkpHzc/J3QdDN+dAcgU=
1625
github.com/hashicorp/golang-lru v0.5.1/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
1726
github.com/hpcloud/tail v1.0.0 h1:nfCOvKYfkgYP8hkirhJocXT2+zOD8yUNjXaWfTlyFKI=
@@ -23,8 +32,10 @@ github.com/jeffh/go.bdd v0.0.0-20120717032931-88f798ee0c74/go.mod h1:qNa9FlAfO0U
2332
github.com/jmespath/go-jmespath v0.0.0-20180206201540-c2b33e8439af h1:pmfjZENx5imkbgOkpRUYLnmbU7UEFbjtDA2hxJ1ichM=
2433
github.com/jmespath/go-jmespath v0.0.0-20180206201540-c2b33e8439af/go.mod h1:Nht3zPeWKUH0NzdCt2Blrr5ys8VGpn0CEB0cQHVjt7k=
2534
github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
35+
github.com/onsi/ginkgo v1.7.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
2636
github.com/onsi/ginkgo v1.8.0 h1:VkHVNpR4iVnU8XQR6DBm8BqYjN7CRzw+xKUbVVbbW9w=
2737
github.com/onsi/ginkgo v1.8.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
38+
github.com/onsi/gomega v1.4.3/go.mod h1:ex+gbHU/CVuBBDIJjb2X0qEXbFg53c61hWP/1CpauHY=
2839
github.com/onsi/gomega v1.5.0 h1:izbySO9zDPmjJ8rDjLvkA2zJHIo+HkYXHnf7eN7SSyo=
2940
github.com/onsi/gomega v1.5.0/go.mod h1:ex+gbHU/CVuBBDIJjb2X0qEXbFg53c61hWP/1CpauHY=
3041
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
@@ -41,10 +52,14 @@ github.com/vmihailenco/msgpack v4.0.4+incompatible/go.mod h1:fy3FlTQTDXWkZ7Bh6Ac
4152
golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
4253
golang.org/x/net v0.0.0-20180906233101-161cd47e91fd h1:nTDtHvHSdCn1m6ITfMRqtOd/9+7a3s8RBNOZ3eYZzJA=
4354
golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
55+
golang.org/x/net v0.0.0-20181129055619-fae4c4e3ad76 h1:xx5MUFyRQRbPk6VjWjIE1epE/K5AoDD8QUN116NCy8k=
56+
golang.org/x/net v0.0.0-20181129055619-fae4c4e3ad76/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
4457
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f h1:wMNYb4v58l5UBM7MYRLPG6ZhfOqbKu7X5eyFl8ZhKvA=
4558
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
59+
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
4660
golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e h1:o3PsSEY8E4eXWkXrIP9YJALUkVZqzHJT5DOasTyn8Vs=
4761
golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
62+
golang.org/x/sys v0.0.0-20181128092732-4ed8d59d0b35/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
4863
golang.org/x/sys v0.0.0-20190422165155-953cdadca894 h1:Cz4ceDQGXuKRnVBDTS23GTn/pU5OE2C0WrNTOYK1Uuc=
4964
golang.org/x/sys v0.0.0-20190422165155-953cdadca894/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
5065
golang.org/x/text v0.3.0 h1:g61tztE5qeGQ89tm6NTjjM9VPIm088od1l6aSorWRWg=
@@ -55,6 +70,7 @@ google.golang.org/appengine v1.6.0 h1:Tfd7cKwKbFRsI8RMAD3oqqw7JPFRrvFlOsfbgVkjOO
5570
google.golang.org/appengine v1.6.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
5671
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
5772
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
73+
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
5874
gopkg.in/fsnotify.v1 v1.4.7 h1:xOHLXZwVvI9hhs+cLKq5+I5onOuwQLhQwiu63xxlHs4=
5975
gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys=
6076
gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ=

‎internal/base/batcher.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import (
44
"sync"
55
"time"
66

7-
"github.com/vmihailenco/taskq"
7+
"github.com/vmihailenco/taskq/v2"
88
)
99

1010
type BatcherOptions struct {

‎internal/base/factory.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package base
33
import (
44
"sync"
55

6-
"github.com/vmihailenco/taskq"
6+
"github.com/vmihailenco/taskq/v2"
77
)
88

99
type Factory struct {

‎internal/base/queue.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package base
33
import (
44
"fmt"
55

6-
"github.com/vmihailenco/taskq"
6+
"github.com/vmihailenco/taskq/v2"
77
)
88

99
type Queue struct {

‎internal/msgutil/msgutil.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package msgutil
33
import (
44
"fmt"
55

6-
"github.com/vmihailenco/taskq"
6+
"github.com/vmihailenco/taskq/v2"
77
)
88

99
func WrapMessage(msg *taskq.Message) *taskq.Message {

‎ironmq/factory.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@ import (
44
iron_config "github.com/iron-io/iron_go3/config"
55
"github.com/iron-io/iron_go3/mq"
66

7-
"github.com/vmihailenco/taskq"
8-
"github.com/vmihailenco/taskq/internal/base"
7+
"github.com/vmihailenco/taskq/v2"
8+
"github.com/vmihailenco/taskq/v2/internal/base"
99
)
1010

1111
type factory struct {

‎ironmq/queue.go

+5-5
Original file line numberDiff line numberDiff line change
@@ -9,11 +9,11 @@ import (
99
"github.com/iron-io/iron_go3/api"
1010
"github.com/iron-io/iron_go3/mq"
1111

12-
"github.com/vmihailenco/taskq"
13-
"github.com/vmihailenco/taskq/internal"
14-
"github.com/vmihailenco/taskq/internal/base"
15-
"github.com/vmihailenco/taskq/internal/msgutil"
16-
"github.com/vmihailenco/taskq/memqueue"
12+
"github.com/vmihailenco/taskq/v2"
13+
"github.com/vmihailenco/taskq/v2/internal"
14+
"github.com/vmihailenco/taskq/v2/internal/base"
15+
"github.com/vmihailenco/taskq/v2/internal/msgutil"
16+
"github.com/vmihailenco/taskq/v2/memqueue"
1717
)
1818

1919
type Queue struct {

‎ironmq_test.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -3,10 +3,10 @@ package taskq_test
33
import (
44
"testing"
55

6-
"github.com/vmihailenco/taskq"
7-
"github.com/vmihailenco/taskq/ironmq"
8-
96
iron_config "github.com/iron-io/iron_go3/config"
7+
8+
"github.com/vmihailenco/taskq/v2"
9+
"github.com/vmihailenco/taskq/v2/ironmq"
1010
)
1111

1212
func ironmqFactory() taskq.Factory {

‎memqueue/bench_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,8 @@ package memqueue_test
33
import (
44
"testing"
55

6-
"github.com/vmihailenco/taskq"
7-
"github.com/vmihailenco/taskq/memqueue"
6+
"github.com/vmihailenco/taskq/v2"
7+
"github.com/vmihailenco/taskq/v2/memqueue"
88
)
99

1010
func BenchmarkCallAsync(b *testing.B) {

‎memqueue/factory.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package memqueue
22

33
import (
4-
"github.com/vmihailenco/taskq"
5-
"github.com/vmihailenco/taskq/internal/base"
4+
"github.com/vmihailenco/taskq/v2"
5+
"github.com/vmihailenco/taskq/v2/internal/base"
66
)
77

88
type factory struct {

‎memqueue/memqueue_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@ import (
1616
. "github.com/onsi/gomega"
1717
uuid "github.com/satori/go.uuid"
1818

19-
"github.com/vmihailenco/taskq"
20-
"github.com/vmihailenco/taskq/memqueue"
19+
"github.com/vmihailenco/taskq/v2"
20+
"github.com/vmihailenco/taskq/v2/memqueue"
2121
)
2222

2323
func TestMemqueue(t *testing.T) {

‎memqueue/queue.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,9 @@ import (
77
"sync/atomic"
88
"time"
99

10-
"github.com/vmihailenco/taskq"
11-
"github.com/vmihailenco/taskq/internal"
12-
"github.com/vmihailenco/taskq/internal/base"
10+
"github.com/vmihailenco/taskq/v2"
11+
"github.com/vmihailenco/taskq/v2/internal"
12+
"github.com/vmihailenco/taskq/v2/internal/base"
1313
)
1414

1515
type Queue struct {

‎message.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ import (
99
"github.com/valyala/gozstd"
1010
"github.com/vmihailenco/msgpack"
1111

12-
"github.com/vmihailenco/taskq/internal"
12+
"github.com/vmihailenco/taskq/v2/internal"
1313
)
1414

1515
// ErrDuplicate is returned when adding duplicate message to the queue.

‎redisq/factory.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package redisq
22

33
import (
4-
"github.com/vmihailenco/taskq"
5-
"github.com/vmihailenco/taskq/internal/base"
4+
"github.com/vmihailenco/taskq/v2"
5+
"github.com/vmihailenco/taskq/v2/internal/base"
66
)
77

88
type factory struct {

0 commit comments

Comments
 (0)