tijl/shortify
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 11 Wiki Activity

up

Browse Source
This commit is contained in:
Tijl 2025-08-09 19:10:16 +02:00
parent 5fc1b55d52
commit c9cf939e8c
Signed by: tijl
GPG Key ID: DAE24BFCD722F053
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/client/client.go
View File

@ -43,7 +43,7 @@ func NewClient(serverURL string, folder string) (*Client, error) {
serverURL: baseURL,
httpClient: httpClient,
db: db,
retryQueue: make(chan shortenJob, 1000),
retryQueue: make(chan shortenJob, 100000),
stopRetry: make(chan struct{}),
}

1
pkg/client/store.go
View File

@ -65,6 +65,7 @@ func (c *Client) retryWorker() {
case job := <-c.retryQueue:
err := c.sendShortenJob(job)
if err != nil {
log.Panicln("got error sending shorten job to server", err)
// Re-enqueue with delay
go func(j shortenJob) {
time.Sleep(2 * time.Second)