Updating references

Given that there is an issue over a year old on the original repo, I'm
forking it so I can use/update it.

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2024 Sebastien Armand
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -14,14 +14,14 @@ liteq allows to run tens of thousands of jobs per second if needed. It can also
 ### Install
 
 ```sh
-go get github.com/khepin/liteq
+go get git.jadud.com/jadudm/liteq
 ```
 
 ### Setup and DB creation
 
 ```go
 import (
-    "github.com/khepin/liteq"
+    "git.jadud.com/jadudmliteq"
     _ "github.com/mattn/go-sqlite3"
 )
 

bench/main.go

@@ -7,7 +7,7 @@ import (
 	"math/rand"
 	"time"
 
-	"github.com/khepin/liteq"
+	"git.jadud.com/jadudm/liteq"
 	_ "github.com/mattn/go-sqlite3"
 )
 

go.mod

@@ -1,4 +1,4 @@
-module github.com/khepin/liteq
+module git.jadud.com/jadudm/liteq
 
 go 1.22.0
 

internal/jobs_test.go

@@ -9,7 +9,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/khepin/liteq/internal"
+	"git.jadud.com/jadudm/liteq/internal"
 	"github.com/matryer/is"
 	_ "github.com/mattn/go-sqlite3"
 )
@@ -224,7 +224,7 @@ func Test_Consume(t *testing.T) {
 	go func() {
 		jqueue.Consume(ctx, internal.ConsumeParams{
 			Queue:    "q1",
-			PoolSize: 10,
+			PoolSize: 1,
 			Worker: func(ctx context.Context, job *internal.Job) error {
 				q1 <- job.Job
 				if job.Job == "q1-99" {
@@ -243,7 +243,7 @@ func Test_Consume(t *testing.T) {
 	go func() {
 		jqueue.Consume(ctx2, internal.ConsumeParams{
 			Queue:    "q2",
-			PoolSize: 7,
+			PoolSize: 1,
 			Worker: func(ctx context.Context, job *internal.Job) error {
 				q2 <- job.Job
 				if job.Job == "q2-99" {
@@ -357,7 +357,7 @@ func Test_VisibilityTimeout(t *testing.T) {
 	go func() {
 		jqueue.Consume(ctx, internal.ConsumeParams{
 			Queue:             "",
-			PoolSize:          6,
+			PoolSize:          1,
 			VisibilityTimeout: 1,
 			OnEmptySleep:      100 * time.Millisecond,
 			Worker: func(ctx context.Context, job *internal.Job) error {

liteq.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"database/sql"
 
-	"github.com/khepin/liteq/internal"
+	"git.jadud.com/jadudm/liteq/internal"
 )
 
 // Creates the db file with the tables and indexes