File tree Expand file tree Collapse file tree 9 files changed +18
-16
lines changed
Expand file tree Collapse file tree 9 files changed +18
-16
lines changed Original file line number Diff line number Diff line change @@ -23,7 +23,7 @@ Make sure you have Go installed [download](https://go.dev/dl/)
2323Initialize 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:
2424
2525``` bash
26- go get -u github.com/francescopepe/formigo
26+ go get -u github.com/Pod-Point/go-queue-worker
2727```
2828
2929## Examples
@@ -37,8 +37,9 @@ import (
3737 " context"
3838 " fmt"
3939 " log"
40-
41- " github.com/francescopepe/formigo"
40+
41+ " github.com/Pod-Point/go-queue-worker"
42+ workerSqs " github.com/Pod-Point/go-queue-worker/clients/sqs"
4243
4344 " github.com/aws/aws-sdk-go-v2/aws"
4445 " github.com/aws/aws-sdk-go-v2/config"
@@ -107,7 +108,8 @@ import (
107108 " fmt"
108109 " log"
109110
110- " github.com/francescopepe/formigo"
111+ " github.com/Pod-Point/go-queue-worker"
112+ workerSqs " github.com/Pod-Point/go-queue-worker/clients/sqs"
111113
112114 " github.com/aws/aws-sdk-go-v2/aws"
113115 " github.com/aws/aws-sdk-go-v2/config"
Original file line number Diff line number Diff line change 44 "log"
55 "time"
66
7- "github.com/francescopepe/formigo /internal/client"
7+ "github.com/Pod-Point/go-queue-worker /internal/client"
88)
99
1010const (
Original file line number Diff line number Diff line change 77 "sync"
88 "time"
99
10- "github.com/francescopepe/formigo /internal/messages"
10+ "github.com/Pod-Point/go-queue-worker /internal/messages"
1111)
1212
1313type BatchResponse struct {
Original file line number Diff line number Diff line change 44 "fmt"
55 "sync"
66
7- "github.com/francescopepe/formigo /internal/client"
8- "github.com/francescopepe/formigo /internal/messages"
7+ "github.com/Pod-Point/go-queue-worker /internal/client"
8+ "github.com/Pod-Point/go-queue-worker /internal/messages"
99)
1010
1111// deleter will delete messages from SQS until the delete channel gets closed.
Original file line number Diff line number Diff line change 1- module github.com/francescopepe/formigo
1+ module github.com/Pod-Point/go-queue-worker
22
33go 1.21
44
Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ package client
33import (
44 "context"
55
6- "github.com/francescopepe/formigo /internal/messages"
6+ "github.com/Pod-Point/go-queue-worker /internal/messages"
77)
88
99type MessageReceiver interface {
Original file line number Diff line number Diff line change 55 "errors"
66 "fmt"
77
8- "github.com/francescopepe/formigo /internal/client"
9- "github.com/francescopepe/formigo /internal/messages"
8+ "github.com/Pod-Point/go-queue-worker /internal/client"
9+ "github.com/Pod-Point/go-queue-worker /internal/messages"
1010)
1111
1212// retriever will get messages from SQS until the given context gets canceled.
Original file line number Diff line number Diff line change 99 awsSqs "github.com/aws/aws-sdk-go-v2/service/sqs"
1010 "github.com/aws/aws-sdk-go-v2/service/sqs/types"
1111
12- "github.com/francescopepe/formigo /internal/client"
13- "github.com/francescopepe/formigo /internal/messages"
12+ "github.com/Pod-Point/go-queue-worker /internal/client"
13+ "github.com/Pod-Point/go-queue-worker /internal/messages"
1414)
1515
1616type SqsClientConfiguration struct {
Original file line number Diff line number Diff line change 55 "errors"
66 "sync"
77
8- "github.com/francescopepe/formigo /internal/client"
9- "github.com/francescopepe/formigo /internal/messages"
8+ "github.com/Pod-Point/go-queue-worker /internal/client"
9+ "github.com/Pod-Point/go-queue-worker /internal/messages"
1010)
1111
1212type Worker struct {
You can’t perform that action at this time.
0 commit comments