Add licence and update package name

soroosh-tanzadeh · Jun 12, 2024 · f3445a8 · f3445a8
1 parent 6858db5
commit f3445a8
Show file tree

Hide file tree

Showing 12 changed files with 690 additions and 28 deletions.
diff --git a/.gitlab-ci.yml b/.gitlab-ci.yml
diff --git a/LICENSE b/LICENSE
diff --git a/README.md b/README.md
@@ -21,8 +21,8 @@ import (
 	"sync"
 	"time"
 
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/redisstream"
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/runner"
+	"github.com/soroosh-tanzadeh/taskrunner/redisstream"
+	"github.com/soroosh-tanzadeh/taskrunner/runner"
 	"github.com/redis/go-redis/v9"
 )
 

diff --git a/go.mod b/go.mod
@@ -1,4 +1,4 @@
-module git.arvaninternal.ir/cdn-go-kit/taskrunner
+module github.com/soroosh-tanzadeh/taskrunner
 
 go 1.21
 

diff --git a/internal/locker/redis_lock.go b/internal/locker/redis_lock.go
@@ -3,11 +3,11 @@ package locker
 import (
 	"time"
 
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/contracts"
 	"github.com/go-redsync/redsync/v4"
 	redsyncredis "github.com/go-redsync/redsync/v4/redis"
 	"github.com/go-redsync/redsync/v4/redis/goredis/v9"
 	"github.com/redis/go-redis/v9"
+	"github.com/soroosh-tanzadeh/taskrunner/contracts"
 )
 
 const DefaultRetryDuration = time.Duration(100) * time.Millisecond

diff --git a/redisstream/redis_stream_message_queue.go b/redisstream/redis_stream_message_queue.go
@@ -7,12 +7,12 @@ import (
 	"sync"
 	"time"
 
+	"github.com/Masterminds/semver/v3"
 	"github.com/redis/go-redis/v9"
 
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/contracts"
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/internal/ring"
-	semver "github.com/Masterminds/semver/v3"
 	log "github.com/sirupsen/logrus"
+	"github.com/soroosh-tanzadeh/taskrunner/contracts"
+	"github.com/soroosh-tanzadeh/taskrunner/internal/ring"
 )
 
 const payloadKey = "payload"

diff --git a/redisstream/redis_stream_message_queue_test.go b/redisstream/redis_stream_message_queue_test.go
@@ -7,9 +7,9 @@ import (
 	"testing"
 	"time"
 
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/contracts"
 	"github.com/alicebob/miniredis/v2"
 	"github.com/redis/go-redis/v9"
+	"github.com/soroosh-tanzadeh/taskrunner/contracts"
 	"github.com/stretchr/testify/assert"
 )
 

diff --git a/runner/mock_queue_test.go b/runner/mock_queue_test.go
diff --git a/runner/task_runner.go b/runner/task_runner.go
@@ -8,10 +8,10 @@ import (
 	"sync/atomic"
 	"time"
 
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/contracts"
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/internal/locker"
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/internal/safemap"
 	"github.com/redis/go-redis/v9"
+	"github.com/soroosh-tanzadeh/taskrunner/contracts"
+	"github.com/soroosh-tanzadeh/taskrunner/internal/locker"
+	"github.com/soroosh-tanzadeh/taskrunner/internal/safemap"
 )
 
 const (

diff --git a/runner/task_runner_test.go b/runner/task_runner_test.go
@@ -10,11 +10,11 @@ import (
 	"testing"
 	"time"
 
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/contracts"
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/redisstream"
 	"github.com/alicebob/miniredis/v2"
 	"github.com/google/uuid"
 	"github.com/redis/go-redis/v9"
+	"github.com/soroosh-tanzadeh/taskrunner/contracts"
+	"github.com/soroosh-tanzadeh/taskrunner/redisstream"
 	"github.com/stretchr/testify/mock"
 	"github.com/stretchr/testify/suite"
 )

diff --git a/runner/unique.go b/runner/unique.go
@@ -4,8 +4,8 @@ import (
 	"errors"
 	"time"
 
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/contracts"
 	"github.com/go-redsync/redsync/v4"
+	"github.com/soroosh-tanzadeh/taskrunner/contracts"
 )
 
 const uniqueLockPrefix = "taskrunner:unique:"

diff --git a/runner/worker.go b/runner/worker.go
@@ -8,9 +8,9 @@ import (
 	"strconv"
 	"time"
 
-	"git.arvaninternal.ir/cdn-go-kit/taskrunner/contracts"
 	"github.com/google/uuid"
 	log "github.com/sirupsen/logrus"
+	"github.com/soroosh-tanzadeh/taskrunner/contracts"
 )
 
 func (t *TaskRunner) addWorker(ctx context.Context, workerID int) {