rogee/atomctl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: import pkg issues

Browse Source
This commit is contained in:
Rogee
2024-12-29 10:17:59 +08:00
parent 18bcae9f96
commit 070feb3ca8
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
templates/project/pkg/service/queue/river.go.tpl
View File

@@ -3,11 +3,11 @@ package queue
import ( import (
"context" "context"
"demo01/app/jobs" "{{.ModuleName}}/app/jobs"
"demo01/pkg/service" "{{.ModuleName}}/pkg/service"
"demo01/providers/app" "{{.ModuleName}}/providers/app"
"demo01/providers/job" "{{.ModuleName}}/providers/job"
"demo01/providers/postgres" "{{.ModuleName}}/providers/postgres"
"git.ipao.vip/rogeecn/atom" "git.ipao.vip/rogeecn/atom"
"git.ipao.vip/rogeecn/atom/container" "git.ipao.vip/rogeecn/atom/container"

8
templates/project/providers/job/provider.go.tpl
View File

@@ -4,7 +4,7 @@ import (
"context" "context"
"sync" "sync"
"demo01/providers/postgres" "{{.ModuleName}}/providers/postgres"
"git.ipao.vip/rogeecn/atom/container" "git.ipao.vip/rogeecn/atom/container"
"git.ipao.vip/rogeecn/atom/utils/opt" "git.ipao.vip/rogeecn/atom/utils/opt"
@@ -71,9 +71,9 @@ func (q *Job) Client() (*river.Client[pgx.Tx], error) {
q.client, err = river.NewClient(q.Driver, &river.Config{ q.client, err = river.NewClient(q.Driver, &river.Config{
Workers: q.Workers, Workers: q.Workers,
Queues: map[string]river.QueueConfig{ Queues: map[string]river.QueueConfig{
PriorityHigh: {MaxWorkers: 10}, QueueHigh: {MaxWorkers: 10},
PriorityDefault: {MaxWorkers: 10}, QueueDefault: {MaxWorkers: 10},
PriorityLow: {MaxWorkers: 10}, QueueLow: {MaxWorkers: 10},
}, },
}) })
if err != nil { if err != nil {