tooling(resource): remove sysinfo check

CHANGELOG.md

@@ -1,44 +1,39 @@
-## [3.2.9](https://github.com/vmihailenco/taskq/compare/v3.2.8...v3.2.9) (2022-08-24)
-
+## [3.2.9](https://github.com/mscienski/taskq/compare/v3.2.8...v3.2.9) (2022-08-24)
 
 ### Bug Fixes
 
-* swapped dst and src arguments in zstd decode call ([e61a842](https://github.com/vmihailenco/taskq/commit/e61a84219a8fe65444da5ca9b19571d2245633f2))
-* Use localStorage for memqueue tests instead of Redis for [#162](https://github.com/vmihailenco/taskq/issues/162) ([b2ec9f5](https://github.com/vmihailenco/taskq/commit/b2ec9f53b0a3182b49c1c1510172e3ab6ac34b85))
-
+- swapped dst and src arguments in zstd decode call
+  ([e61a842](https://github.com/mscienski/taskq/commit/e61a84219a8fe65444da5ca9b19571d2245633f2))
+- Use localStorage for memqueue tests instead of Redis for
+  [#162](https://github.com/mscienski/taskq/issues/162)
+  ([b2ec9f5](https://github.com/mscienski/taskq/commit/b2ec9f53b0a3182b49c1c1510172e3ab6ac34b85))
 
 ### Features
 
-* allow set backoff duration for redis scheduler ([f6818a8](https://github.com/vmihailenco/taskq/commit/f6818a888f92e6a78e022aae2083d202bfdd3726))
-
-
-
-## [3.2.8](https://github.com/vmihailenco/taskq/compare/v3.2.7...v3.2.8) (2021-11-18)
+- allow set backoff duration for redis scheduler
+  ([f6818a8](https://github.com/mscienski/taskq/commit/f6818a888f92e6a78e022aae2083d202bfdd3726))
 
+## [3.2.8](https://github.com/mscienski/taskq/compare/v3.2.7...v3.2.8) (2021-11-18)
 
 ### Bug Fixes
 
-* ack msg before we delete it ([bac023a](https://github.com/vmihailenco/taskq/commit/bac023a71ba191e60f43ce3ca01a25d08d0a70c2))
-* adding ctx to msg ([819b42b](https://github.com/vmihailenco/taskq/commit/819b42b66bf482187843670a4a2fc288e9173e29))
-
-
-
-## [3.2.7](https://github.com/vmihailenco/taskq/compare/v3.2.6...v3.2.7) (2021-10-28)
+- ack msg before we delete it
+  ([bac023a](https://github.com/mscienski/taskq/commit/bac023a71ba191e60f43ce3ca01a25d08d0a70c2))
+- adding ctx to msg
+  ([819b42b](https://github.com/mscienski/taskq/commit/819b42b66bf482187843670a4a2fc288e9173e29))
 
+## [3.2.7](https://github.com/mscienski/taskq/compare/v3.2.6...v3.2.7) (2021-10-28)
 
 ### Bug Fixes
 
-* **redisq:** rework tests to use redis client ([670be0f](https://github.com/vmihailenco/taskq/commit/670be0f0ba7ee729df4c6e89c0c571340914f936))
-* **redsiq:** call xack inside delete in redsiq ([2f6bd74](https://github.com/vmihailenco/taskq/commit/2f6bd74c006132be6cbec74f9c4808888da34aff))
-
-
-
-## [3.2.6](https://github.com/vmihailenco/taskq/compare/v3.2.5...v3.2.6) (2021-10-11)
+- **redisq:** rework tests to use redis client
+  ([670be0f](https://github.com/mscienski/taskq/commit/670be0f0ba7ee729df4c6e89c0c571340914f936))
+- **redsiq:** call xack inside delete in redsiq
+  ([2f6bd74](https://github.com/mscienski/taskq/commit/2f6bd74c006132be6cbec74f9c4808888da34aff))
 
+## [3.2.6](https://github.com/mscienski/taskq/compare/v3.2.5...v3.2.6) (2021-10-11)
 
 ### Bug Fixes
 
-* introduce interfaces to allow mocking in tests ([6bc8f3b](https://github.com/vmihailenco/taskq/commit/6bc8f3b0462812996c39605c10428b43460696ff))
-
-
-
+- introduce interfaces to allow mocking in tests
+  ([6bc8f3b](https://github.com/mscienski/taskq/commit/6bc8f3b0462812996c39605c10428b43460696ff))

Makefile

@@ -16,4 +16,4 @@ go_mod_tidy:
 
 fmt:
 	gofmt -w -s ./
-	goimports -w  -local github.com/vmihailenco/taskq ./
+	goimports -w  -local github.com/mscienski/taskq ./

README.md

@@ -1,7 +1,7 @@
 # Golang asynchronous task/job queue with Redis, SQS, IronMQ, and in-memory backends
 
-![build workflow](https://github.com/vmihailenco/taskq/actions/workflows/build.yml/badge.svg)
-[![PkgGoDev](https://pkg.go.dev/badge/github.com/vmihailenco/taskq/v3)](https://pkg.go.dev/github.com/vmihailenco/taskq/v3)
+![build workflow](https://github.com/mscienski/taskq/actions/workflows/build.yml/badge.svg)
+[![PkgGoDev](https://pkg.go.dev/badge/github.com/mscienski/taskq/v3)](https://pkg.go.dev/github.com/mscienski/taskq/v3)
 [![Documentation](https://img.shields.io/badge/bun-documentation-informational)](https://taskq.uptrace.dev/)
 [![Chat](https://discordapp.com/api/guilds/752070105847955518/widget.png)](https://discord.gg/rWtp5Aj)
 
@@ -26,10 +26,10 @@
 Resources:
 
 - [**Get started**](https://taskq.uptrace.dev/guide/golang-task-queue.html)
-- [Examples](https://github.com/vmihailenco/taskq/tree/v3/example)
+- [Examples](https://github.com/mscienski/taskq/tree/v3/example)
 - [Discussions](https://github.com/uptrace/bun/discussions)
 - [Chat](https://discord.gg/rWtp5Aj)
-- [Reference](https://pkg.go.dev/github.com/vmihailenco/taskq/v3)
+- [Reference](https://pkg.go.dev/github.com/mscienski/taskq/v3)
 
 ## Getting started
 
@@ -39,8 +39,8 @@ To get started, see [Golang Task Queue](https://taskq.uptrace.dev/) documentatio
 
 ```go
 import (
-    "github.com/vmihailenco/taskq/v3"
-    "github.com/vmihailenco/taskq/v3/redisq"
+    "github.com/mscienski/taskq/v3"
+    "github.com/mscienski/taskq/v3/redisq"
 )
 
 // Create a queue factory.
@@ -94,6 +94,6 @@ if err := MainQueue.Start(context.Background()); err != nil {
 
 Thanks to all the people who already contributed!
 
-<a href="https://github.com/vmihailenco/taskq/graphs/contributors">
-  <img src="https://contributors-img.web.app/image?repo=vmihailenco/taskq" />
+<a href="https://github.com/mscienski/taskq/graphs/contributors">
+  <img src="https://contributors-img.web.app/image?repo=mscienski/taskq" />
 </a>

azsqs/factory.go

@@ -5,8 +5,8 @@ import (
 
 	"github.com/aws/aws-sdk-go/service/sqs"
 
-	"github.com/vmihailenco/taskq/v3"
-	"github.com/vmihailenco/taskq/v3/internal/base"
+	"github.com/mscienski/taskq/v3"
+	"github.com/mscienski/taskq/v3/internal/base"
 )
 
 type factory struct {

azsqs/queue.go

@@ -13,11 +13,11 @@ import (
 	"github.com/aws/aws-sdk-go/aws/awserr"
 	"github.com/aws/aws-sdk-go/service/sqs"
 
-	"github.com/vmihailenco/taskq/v3"
-	"github.com/vmihailenco/taskq/v3/internal"
-	"github.com/vmihailenco/taskq/v3/internal/base"
-	"github.com/vmihailenco/taskq/v3/internal/msgutil"
-	"github.com/vmihailenco/taskq/v3/memqueue"
+	"github.com/mscienski/taskq/v3"
+	"github.com/mscienski/taskq/v3/internal"
+	"github.com/mscienski/taskq/v3/internal/base"
+	"github.com/mscienski/taskq/v3/internal/msgutil"
+	"github.com/mscienski/taskq/v3/memqueue"
 )
 
 const msgSizeLimit = 262144

azsqs_test.go

@@ -7,8 +7,8 @@ import (
 	"github.com/aws/aws-sdk-go/aws/session"
 	"github.com/aws/aws-sdk-go/service/sqs"
 
-	"github.com/vmihailenco/taskq/v3"
-	"github.com/vmihailenco/taskq/v3/azsqs"
+	"github.com/mscienski/taskq/v3"
+	"github.com/mscienski/taskq/v3/azsqs"
 )
 
 var accountID string

bench_test.go

@@ -5,9 +5,9 @@ import (
 	"sync"
 	"testing"
 
-	"github.com/vmihailenco/taskq/v3"
-	"github.com/vmihailenco/taskq/v3/memqueue"
-	"github.com/vmihailenco/taskq/v3/redisq"
+	"github.com/mscienski/taskq/v3"
+	"github.com/mscienski/taskq/v3/memqueue"
+	"github.com/mscienski/taskq/v3/redisq"
 )
 
 func BenchmarkConsumerMemq(b *testing.B) {

consumer.go

@@ -12,7 +12,7 @@ import (
 
 	"github.com/bsm/redislock"
 
-	"github.com/vmihailenco/taskq/v3/internal"
+	"github.com/mscienski/taskq/v3/internal"
 )
 
 const stopTimeout = 30 * time.Second

consumer_config.go

@@ -5,7 +5,7 @@ import (
 	"math/rand"
 	"time"
 
-	"github.com/vmihailenco/taskq/v3/internal"
+	"github.com/mscienski/taskq/v3/internal"
 )
 
 const numSelectedThreshold = 20
@@ -245,11 +245,6 @@ func (r *configRoulette) genConfigs(bestCfg *consumerConfig, queueEmpty bool) {
 	r.oldBestCfg = bestCfg.Clone()
 	r.addConfig(r.oldBestCfg)
 
-	if !hasFreeSystemResources() {
-		internal.Logger.Println("taskq: system does not have enough free resources")
-		return
-	}
-
 	if queueEmpty {
 		r.addConfig(r.withMoreWorkers(bestCfg, 2))
 		return

consumer_test.go

@@ -17,8 +17,8 @@ import (
 	"github.com/go-redis/redis/v8"
 	"github.com/go-redis/redis_rate/v9"
 
-	"github.com/vmihailenco/taskq/v3"
-	"github.com/vmihailenco/taskq/v3/redisq"
+	"github.com/mscienski/taskq/v3"
+	"github.com/mscienski/taskq/v3/redisq"
 )
 
 const waitTimeout = time.Second

example/redisexample/consumer/main.go

@@ -5,7 +5,7 @@ import (
 	"flag"
 	"log"
 
-	"github.com/vmihailenco/taskq/example/redisexample"
+	"github.com/mscienski/taskq/example/redisexample"
 )
 
 func main() {

example/redisexample/go.mod

@@ -1,10 +1,10 @@
-module github.com/vmihailenco/taskq/example/redisexample
+module github.com/mscienski/taskq/example/redisexample
 
 go 1.17
 
 require (
 	github.com/go-redis/redis/v8 v8.11.5
-	github.com/vmihailenco/taskq/v3 v3.2.9
+	github.com/mscienski/taskq/v3 v3.2.9
 )
 
 require (
@@ -21,4 +21,4 @@ require (
 	github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
 )
 
-replace github.com/vmihailenco/taskq/v3 => ../..
+replace github.com/mscienski/taskq/v3 => ../..

example/redisexample/producer/main.go

@@ -5,7 +5,7 @@ import (
 	"flag"
 	"log"
 
-	"github.com/vmihailenco/taskq/example/redisexample"
+	"github.com/mscienski/taskq/example/redisexample"
 )
 
 func main() {

example/redisexample/tasks.go

@@ -10,8 +10,8 @@ import (
 
 	"github.com/go-redis/redis/v8"
 
-	"github.com/vmihailenco/taskq/v3"
-	"github.com/vmihailenco/taskq/v3/redisq"
+	"github.com/mscienski/taskq/v3"
+	"github.com/mscienski/taskq/v3/redisq"
 )
 
 var Redis = redis.NewClient(&redis.Options{

example/sqsexample/consumer/main.go

@@ -5,7 +5,7 @@ import (
 	"flag"
 	"log"
 
-	"github.com/vmihailenco/taskq/example/sqsexample"
+	"github.com/mscienski/taskq/example/sqsexample"
 )
 
 func main() {

example/sqsexample/go.mod

@@ -1,11 +1,11 @@
-module github.com/vmihailenco/taskq/example/sqsexample
+module github.com/mscienski/taskq/example/sqsexample
 
 go 1.17
 
 require (
 	github.com/aws/aws-sdk-go v1.43.45
 	github.com/go-redis/redis/v8 v8.11.5
-	github.com/vmihailenco/taskq/v3 v3.2.9
+	github.com/mscienski/taskq/v3 v3.2.9
 )
 
 require (
@@ -22,4 +22,4 @@ require (
 	github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
 )
 
-replace github.com/vmihailenco/taskq/v3 => ../..
+replace github.com/mscienski/taskq/v3 => ../..

example/sqsexample/producer/main.go

@@ -5,7 +5,7 @@ import (
 	"flag"
 	"log"
 
-	"github.com/vmihailenco/taskq/example/sqsexample"
+	"github.com/mscienski/taskq/example/sqsexample"
 )
 
 func main() {

example/sqsexample/tasks.go

@@ -12,8 +12,8 @@ import (
 	"github.com/aws/aws-sdk-go/service/sqs"
 	"github.com/go-redis/redis/v8"
 
-	"github.com/vmihailenco/taskq/v3"
-	"github.com/vmihailenco/taskq/v3/azsqs"
+	"github.com/mscienski/taskq/v3"
+	"github.com/mscienski/taskq/v3/azsqs"
 )
 
 var Redis = redis.NewClient(&redis.Options{

example_ratelimit_test.go

@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/vmihailenco/taskq/v3"
-	"github.com/vmihailenco/taskq/v3/memqueue"
+	"github.com/mscienski/taskq/v3"
+	"github.com/mscienski/taskq/v3/memqueue"
 )
 
 type RateLimitError string

example_test.go

@@ -9,8 +9,8 @@ import (
 
 	"github.com/go-redis/redis_rate/v9"
 
-	"github.com/vmihailenco/taskq/v3"
-	"github.com/vmihailenco/taskq/v3/memqueue"
+	"github.com/mscienski/taskq/v3"
+	"github.com/mscienski/taskq/v3/memqueue"
 )
 
 func timeSince(start time.Time) time.Duration {

extra/taskqotel/go.mod

@@ -1,11 +1,11 @@
-module github.com/vmihailenco/taskq/extra/taskqotel/v3
+module github.com/mscienski/taskq/extra/taskqotel/v3
 
 go 1.17
 
-replace github.com/vmihailenco/taskq/v3 => ../..
+replace github.com/mscienski/taskq/v3 => ../..
 
 require (
-	github.com/vmihailenco/taskq/v3 v3.2.9
+	github.com/mscienski/taskq/v3 v3.2.9
 	go.opentelemetry.io/otel v1.6.3
 	go.opentelemetry.io/otel/trace v1.6.3
 

extra/taskqotel/otel.go

@@ -5,10 +5,10 @@ import (
 	"go.opentelemetry.io/otel/codes"
 	"go.opentelemetry.io/otel/trace"
 
-	"github.com/vmihailenco/taskq/v3"
+	"github.com/mscienski/taskq/v3"
 )
 
-var tracer = otel.Tracer("github.com/vmihailenco/taskq")
+var tracer = otel.Tracer("github.com/mscienski/taskq")
 
 type OpenTelemetryHook struct{}
 

go.mod

@@ -1,11 +1,10 @@
-module github.com/vmihailenco/taskq/v3
+module github.com/mscienski/taskq/v3
 
 go 1.17
 
 require (
 	github.com/aws/aws-sdk-go v1.43.45
 	github.com/bsm/redislock v0.7.2
-	github.com/capnm/sysinfo v0.0.0-20130621111458-5909a53897f3
 	github.com/dgryski/go-farm v0.0.0-20200201041132-a6ae2369ad13
 	github.com/go-redis/redis/v8 v8.11.5
 	github.com/go-redis/redis_rate/v9 v9.1.2

go.sum

@@ -2,8 +2,6 @@ github.com/aws/aws-sdk-go v1.43.45 h1:2708Bj4uV+ym62MOtBnErm/CDX61C4mFe9V2gXy1ca
 github.com/aws/aws-sdk-go v1.43.45/go.mod h1:y4AeaBuwd2Lk+GepC1E9v0qOiTws0MIWAX4oIKwKHZo=
 github.com/bsm/redislock v0.7.2 h1:jggqOio8JyX9FJBKIfjF3fTxAu/v7zC5mAID9LveqG4=
 github.com/bsm/redislock v0.7.2/go.mod h1:kS2g0Yvlymc9Dz8V3iVYAtLAaSVruYbAFdYBDrmC5WU=
-github.com/capnm/sysinfo v0.0.0-20130621111458-5909a53897f3 h1:IHZ1Le1ejzkmS7Si7dIzJvYDWe+BIoNmqMnfWHBZSVw=
-github.com/capnm/sysinfo v0.0.0-20130621111458-5909a53897f3/go.mod h1:M5XHQLu90v2JNm/bW2tdsYar+5vhV0gEcBcmDBNAN1Y=
 github.com/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE=
 github.com/cespare/xxhash/v2 v2.1.2/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI=

internal/base/batcher.go

@@ -4,7 +4,7 @@ import (
 	"sync"
 	"time"
 
-	"github.com/vmihailenco/taskq/v3"
+	"github.com/mscienski/taskq/v3"
 )
 
 type BatcherOptions struct {

internal/base/factory.go

@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"sync"
 
-	"github.com/vmihailenco/taskq/v3"
+	"github.com/mscienski/taskq/v3"
 )
 
 type Factory struct {