Fix(backend): inboxJobPerSecのデフォルト値を16から32に (#12631)
This commit is contained in:
parent
aad573a1d7
commit
06ca63f9c2
5 changed files with 35 additions and 35 deletions
|
@ -56,17 +56,17 @@ dbReplications: false
|
||||||
# You can configure any number of replicas here
|
# You can configure any number of replicas here
|
||||||
#dbSlaves:
|
#dbSlaves:
|
||||||
# -
|
# -
|
||||||
# host:
|
# host:
|
||||||
# port:
|
# port:
|
||||||
# db:
|
# db:
|
||||||
# user:
|
# user:
|
||||||
# pass:
|
# pass:
|
||||||
# -
|
# -
|
||||||
# host:
|
# host:
|
||||||
# port:
|
# port:
|
||||||
# db:
|
# db:
|
||||||
# user:
|
# user:
|
||||||
# pass:
|
# pass:
|
||||||
|
|
||||||
# ┌─────────────────────┐
|
# ┌─────────────────────┐
|
||||||
#───┘ Redis configuration └─────────────────────────────────────
|
#───┘ Redis configuration └─────────────────────────────────────
|
||||||
|
@ -151,7 +151,7 @@ id: 'aidx'
|
||||||
|
|
||||||
# Job rate limiter
|
# Job rate limiter
|
||||||
# deliverJobPerSec: 128
|
# deliverJobPerSec: 128
|
||||||
# inboxJobPerSec: 16
|
# inboxJobPerSec: 32
|
||||||
|
|
||||||
# Job attempts
|
# Job attempts
|
||||||
# deliverJobMaxAttempts: 12
|
# deliverJobMaxAttempts: 12
|
||||||
|
|
|
@ -166,7 +166,7 @@ id: 'aidx'
|
||||||
|
|
||||||
# Job rate limiter
|
# Job rate limiter
|
||||||
#deliverJobPerSec: 128
|
#deliverJobPerSec: 128
|
||||||
#inboxJobPerSec: 16
|
#inboxJobPerSec: 32
|
||||||
#relashionshipJobPerSec: 64
|
#relashionshipJobPerSec: 64
|
||||||
|
|
||||||
# Job attempts
|
# Job attempts
|
||||||
|
|
|
@ -56,17 +56,17 @@ dbReplications: false
|
||||||
# You can configure any number of replicas here
|
# You can configure any number of replicas here
|
||||||
#dbSlaves:
|
#dbSlaves:
|
||||||
# -
|
# -
|
||||||
# host:
|
# host:
|
||||||
# port:
|
# port:
|
||||||
# db:
|
# db:
|
||||||
# user:
|
# user:
|
||||||
# pass:
|
# pass:
|
||||||
# -
|
# -
|
||||||
# host:
|
# host:
|
||||||
# port:
|
# port:
|
||||||
# db:
|
# db:
|
||||||
# user:
|
# user:
|
||||||
# pass:
|
# pass:
|
||||||
|
|
||||||
# ┌─────────────────────┐
|
# ┌─────────────────────┐
|
||||||
#───┘ Redis configuration └─────────────────────────────────────
|
#───┘ Redis configuration └─────────────────────────────────────
|
||||||
|
@ -147,7 +147,7 @@ id: 'aidx'
|
||||||
|
|
||||||
# Job rate limiter
|
# Job rate limiter
|
||||||
# deliverJobPerSec: 128
|
# deliverJobPerSec: 128
|
||||||
# inboxJobPerSec: 16
|
# inboxJobPerSec: 32
|
||||||
|
|
||||||
# Job attempts
|
# Job attempts
|
||||||
# deliverJobMaxAttempts: 12
|
# deliverJobMaxAttempts: 12
|
||||||
|
|
|
@ -77,17 +77,17 @@ dbReplications: false
|
||||||
# You can configure any number of replicas here
|
# You can configure any number of replicas here
|
||||||
#dbSlaves:
|
#dbSlaves:
|
||||||
# -
|
# -
|
||||||
# host:
|
# host:
|
||||||
# port:
|
# port:
|
||||||
# db:
|
# db:
|
||||||
# user:
|
# user:
|
||||||
# pass:
|
# pass:
|
||||||
# -
|
# -
|
||||||
# host:
|
# host:
|
||||||
# port:
|
# port:
|
||||||
# db:
|
# db:
|
||||||
# user:
|
# user:
|
||||||
# pass:
|
# pass:
|
||||||
|
|
||||||
# ┌─────────────────────┐
|
# ┌─────────────────────┐
|
||||||
#───┘ Redis configuration └─────────────────────────────────────
|
#───┘ Redis configuration └─────────────────────────────────────
|
||||||
|
@ -167,7 +167,7 @@ id: "aidx"
|
||||||
|
|
||||||
# Job rate limiter
|
# Job rate limiter
|
||||||
# deliverJobPerSec: 128
|
# deliverJobPerSec: 128
|
||||||
# inboxJobPerSec: 16
|
# inboxJobPerSec: 32
|
||||||
|
|
||||||
# Job attempts
|
# Job attempts
|
||||||
# deliverJobMaxAttempts: 12
|
# deliverJobMaxAttempts: 12
|
||||||
|
|
|
@ -226,7 +226,7 @@ export class QueueProcessorService implements OnApplicationShutdown {
|
||||||
autorun: false,
|
autorun: false,
|
||||||
concurrency: this.config.inboxJobConcurrency ?? 16,
|
concurrency: this.config.inboxJobConcurrency ?? 16,
|
||||||
limiter: {
|
limiter: {
|
||||||
max: this.config.inboxJobPerSec ?? 16,
|
max: this.config.inboxJobPerSec ?? 32,
|
||||||
duration: 1000,
|
duration: 1000,
|
||||||
},
|
},
|
||||||
settings: {
|
settings: {
|
||||||
|
|
Loading…
Reference in a new issue