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/)
23
23
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:
24
24
25
25
``` bash
26
- go get -u github.com/francescopepe/formigo
26
+ go get -u github.com/Pod-Point/go-queue-worker
27
27
```
28
28
29
29
## Examples
@@ -37,8 +37,9 @@ import (
37
37
" context"
38
38
" fmt"
39
39
" 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"
42
43
43
44
" github.com/aws/aws-sdk-go-v2/aws"
44
45
" github.com/aws/aws-sdk-go-v2/config"
@@ -107,7 +108,8 @@ import (
107
108
" fmt"
108
109
" log"
109
110
110
- " github.com/francescopepe/formigo"
111
+ " github.com/Pod-Point/go-queue-worker"
112
+ workerSqs " github.com/Pod-Point/go-queue-worker/clients/sqs"
111
113
112
114
" github.com/aws/aws-sdk-go-v2/aws"
113
115
" github.com/aws/aws-sdk-go-v2/config"
Original file line number Diff line number Diff line change 4
4
"log"
5
5
"time"
6
6
7
- "github.com/francescopepe/formigo /internal/client"
7
+ "github.com/Pod-Point/go-queue-worker /internal/client"
8
8
)
9
9
10
10
const (
Original file line number Diff line number Diff line change 7
7
"sync"
8
8
"time"
9
9
10
- "github.com/francescopepe/formigo /internal/messages"
10
+ "github.com/Pod-Point/go-queue-worker /internal/messages"
11
11
)
12
12
13
13
type singleMessageHandler = func (ctx context.Context , msg interface {}) error
Original file line number Diff line number Diff line change 4
4
"fmt"
5
5
"sync"
6
6
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"
9
9
)
10
10
11
11
// 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
2
2
3
3
go 1.20
4
4
Original file line number Diff line number Diff line change 1
1
package client
2
2
3
- import "github.com/francescopepe/formigo /internal/messages"
3
+ import "github.com/Pod-Point/go-queue-worker /internal/messages"
4
4
5
5
type MessageReceiver interface {
6
6
ReceiveMessages () ([]messages.Message , error )
Original file line number Diff line number Diff line change 5
5
"errors"
6
6
"fmt"
7
7
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"
10
10
)
11
11
12
12
// retriever will get messages from SQS until the given context gets canceled.
Original file line number Diff line number Diff line change 9
9
awsSqs "github.com/aws/aws-sdk-go-v2/service/sqs"
10
10
"github.com/aws/aws-sdk-go-v2/service/sqs/types"
11
11
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"
14
14
)
15
15
16
16
type SqsClientConfiguration struct {
Original file line number Diff line number Diff line change 5
5
"errors"
6
6
"sync"
7
7
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"
10
10
)
11
11
12
12
type worker struct {
You can’t perform that action at this time.
0 commit comments