diff --git a/README.md b/README.md index 6d48cb5..c595a32 100644 --- a/README.md +++ b/README.md @@ -23,7 +23,7 @@ Make sure you have Go installed [download](https://go.dev/dl/) Initialize your project by creating a folder and then running `go mod init github.com/your/repo` inside the folder. Then install the library with the [`go get`](https://pkg.go.dev/cmd/go/#hdr-Add_dependencies_to_current_module_and_install_them) command: ```bash -go get -u github.com/francescopepe/formigo +go get -u github.com/Pod-Point/go-queue-worker ``` ## Examples @@ -37,8 +37,9 @@ import ( "context" "fmt" "log" - - "github.com/francescopepe/formigo" + + "github.com/Pod-Point/go-queue-worker" + workerSqs "github.com/Pod-Point/go-queue-worker/clients/sqs" "github.com/aws/aws-sdk-go-v2/aws" "github.com/aws/aws-sdk-go-v2/config" @@ -107,7 +108,8 @@ import ( "fmt" "log" - "github.com/francescopepe/formigo" + "github.com/Pod-Point/go-queue-worker" + workerSqs "github.com/Pod-Point/go-queue-worker/clients/sqs" "github.com/aws/aws-sdk-go-v2/aws" "github.com/aws/aws-sdk-go-v2/config" diff --git a/config.go b/config.go index d8bc8da..3b14f7f 100644 --- a/config.go +++ b/config.go @@ -4,7 +4,7 @@ import ( "log" "time" - "github.com/francescopepe/formigo/internal/client" + "github.com/Pod-Point/go-queue-worker/internal/client" ) const ( diff --git a/consumers.go b/consumers.go index 83834e4..a3eafa5 100644 --- a/consumers.go +++ b/consumers.go @@ -7,7 +7,7 @@ import ( "sync" "time" - "github.com/francescopepe/formigo/internal/messages" + "github.com/Pod-Point/go-queue-worker/internal/messages" ) type singleMessageHandler = func(ctx context.Context, msg interface{}) error diff --git a/deleter.go b/deleter.go index 289037b..3a180d7 100644 --- a/deleter.go +++ b/deleter.go @@ -4,8 +4,8 @@ import ( "fmt" "sync" - "github.com/francescopepe/formigo/internal/client" - "github.com/francescopepe/formigo/internal/messages" + "github.com/Pod-Point/go-queue-worker/internal/client" + "github.com/Pod-Point/go-queue-worker/internal/messages" ) // deleter will delete messages from SQS until the delete channel gets closed. diff --git a/go.mod b/go.mod index 93d117b..8d3fdf5 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/francescopepe/formigo +module github.com/Pod-Point/go-queue-worker go 1.20 diff --git a/internal/client/client.go b/internal/client/client.go index 9e24aeb..f3305ff 100644 --- a/internal/client/client.go +++ b/internal/client/client.go @@ -1,6 +1,6 @@ package client -import "github.com/francescopepe/formigo/internal/messages" +import "github.com/Pod-Point/go-queue-worker/internal/messages" type MessageReceiver interface { ReceiveMessages() ([]messages.Message, error) diff --git a/retriever.go b/retriever.go index 1ae23e1..737475a 100644 --- a/retriever.go +++ b/retriever.go @@ -5,8 +5,8 @@ import ( "errors" "fmt" - "github.com/francescopepe/formigo/internal/client" - "github.com/francescopepe/formigo/internal/messages" + "github.com/Pod-Point/go-queue-worker/internal/client" + "github.com/Pod-Point/go-queue-worker/internal/messages" ) // retriever will get messages from SQS until the given context gets canceled. diff --git a/sqs.go b/sqs.go index 01bbb2c..84582ef 100644 --- a/sqs.go +++ b/sqs.go @@ -9,8 +9,8 @@ import ( awsSqs "github.com/aws/aws-sdk-go-v2/service/sqs" "github.com/aws/aws-sdk-go-v2/service/sqs/types" - "github.com/francescopepe/formigo/internal/client" - "github.com/francescopepe/formigo/internal/messages" + "github.com/Pod-Point/go-queue-worker/internal/client" + "github.com/Pod-Point/go-queue-worker/internal/messages" ) type SqsClientConfiguration struct { diff --git a/worker.go b/worker.go index 9621dbf..ea18a48 100644 --- a/worker.go +++ b/worker.go @@ -5,8 +5,8 @@ import ( "errors" "sync" - "github.com/francescopepe/formigo/internal/client" - "github.com/francescopepe/formigo/internal/messages" + "github.com/Pod-Point/go-queue-worker/internal/client" + "github.com/Pod-Point/go-queue-worker/internal/messages" ) type worker struct {