zias/stats
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

bump groupmq

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2025-10-07 12:59:13 +02:00
parent e4bc21fc2e
commit 6bc4f6fbd2
5 changed files with 27 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
apps/api/package.json
View File

@@ -38,7 +38,7 @@
"fastify": "^5.2.1", "fastify": "^5.2.1",
"fastify-metrics": "^12.1.0", "fastify-metrics": "^12.1.0",
"fastify-raw-body": "^5.0.0", "fastify-raw-body": "^5.0.0",
"groupmq": "1.0.0-next.15", "groupmq": "1.0.0-next.16",
"ico-to-png": "^0.2.2", "ico-to-png": "^0.2.2",
"jsonwebtoken": "^9.0.2", "jsonwebtoken": "^9.0.2",
"ramda": "^0.29.1", "ramda": "^0.29.1",

2
apps/worker/package.json
View File

@@ -23,7 +23,7 @@
"@openpanel/redis": "workspace:*", "@openpanel/redis": "workspace:*",
"bullmq": "^5.8.7", "bullmq": "^5.8.7",
"express": "^4.18.2", "express": "^4.18.2",
"groupmq": "1.0.0-next.15", "groupmq": "1.0.0-next.16",
"prom-client": "^15.1.3", "prom-client": "^15.1.3",
"ramda": "^0.29.1", "ramda": "^0.29.1",
"source-map-support": "^0.5.21", "source-map-support": "^0.5.21",

2
packages/queue/package.json
View File

@@ -10,7 +10,7 @@
"@openpanel/logger": "workspace:*", "@openpanel/logger": "workspace:*",
"@openpanel/redis": "workspace:*", "@openpanel/redis": "workspace:*",
"bullmq": "^5.8.7", "bullmq": "^5.8.7",
"groupmq": "1.0.0-next.15" "groupmq": "1.0.0-next.16"
}, },
"devDependencies": { "devDependencies": {
"@openpanel/sdk": "workspace:*", "@openpanel/sdk": "workspace:*",

16
packages/queue/src/queues.ts
View File

@@ -107,6 +107,18 @@ export const eventsQueue = new Queue<EventsQueuePayload>('events', {
}, },
}); });
const orderingWindowMs = Number.parseInt(
process.env.ORDERING_WINDOW_MS || '50',
10,
);
const orderingGracePeriodDecay = Number.parseFloat(
process.env.ORDERING_GRACE_PERIOD_DECAY || '0.9',
);
const orderingMaxWaitMultiplier = Number.parseInt(
process.env.ORDERING_MAX_WAIT_MULTIPLIER || '8',
10,
);
export const eventsGroupQueue = new GroupQueue< export const eventsGroupQueue = new GroupQueue<
EventsQueuePayloadIncomingEvent['payload'] EventsQueuePayloadIncomingEvent['payload']
>({ >({
@@ -114,7 +126,9 @@ export const eventsGroupQueue = new GroupQueue<
namespace: 'group_events', namespace: 'group_events',
redis: getRedisGroupQueue(), redis: getRedisGroupQueue(),
orderingMethod: 'in-memory', orderingMethod: 'in-memory',
orderingWindowMs: 50, orderingWindowMs,
orderingGracePeriodDecay,
orderingMaxWaitMultiplier,
keepCompleted: 10, keepCompleted: 10,
keepFailed: 10_000, keepFailed: 10_000,
}); });

18
pnpm-lock.yaml generated
View File

@@ -127,8 +127,8 @@ importers:
specifier: ^5.0.0 specifier: ^5.0.0
version: 5.0.0 version: 5.0.0
groupmq: groupmq:
specifier: 1.0.0-next.15 specifier: 1.0.0-next.16
version: 1.0.0-next.15(ioredis@5.4.1) version: 1.0.0-next.16(ioredis@5.4.1)
ico-to-png: ico-to-png:
specifier: ^0.2.2 specifier: ^0.2.2
version: 0.2.2 version: 0.2.2
@@ -760,8 +760,8 @@ importers:
specifier: ^4.18.2 specifier: ^4.18.2
version: 4.18.2 version: 4.18.2
groupmq: groupmq:
specifier: 1.0.0-next.15 specifier: 1.0.0-next.16
version: 1.0.0-next.15(ioredis@5.4.1) version: 1.0.0-next.16(ioredis@5.4.1)
prom-client: prom-client:
specifier: ^15.1.3 specifier: ^15.1.3
version: 15.1.3 version: 15.1.3
@@ -1224,8 +1224,8 @@ importers:
specifier: ^5.8.7 specifier: ^5.8.7
version: 5.8.7 version: 5.8.7
groupmq: groupmq:
specifier: 1.0.0-next.15 specifier: 1.0.0-next.16
version: 1.0.0-next.15(ioredis@5.4.1) version: 1.0.0-next.16(ioredis@5.4.1)
devDependencies: devDependencies:
'@openpanel/sdk': '@openpanel/sdk':
specifier: workspace:* specifier: workspace:*
@@ -8837,8 +8837,8 @@ packages:
resolution: {integrity: sha512-5v6yZd4JK3eMI3FqqCouswVqwugaA9r4dNZB1wwcmrD02QkV5H0y7XBQW8QwQqEaZY1pM9aqORSORhJRdNK44Q==} resolution: {integrity: sha512-5v6yZd4JK3eMI3FqqCouswVqwugaA9r4dNZB1wwcmrD02QkV5H0y7XBQW8QwQqEaZY1pM9aqORSORhJRdNK44Q==}
engines: {node: '>=6.0'} engines: {node: '>=6.0'}
groupmq@1.0.0-next.15: groupmq@1.0.0-next.16:
resolution: {integrity: sha512-iYOctW9kqhJroupw3tRtgfIsc0Jd4e36E7FsMHmOV35VygIDmrGi/3wZ1TCFIkxJjeaizQ6/GsNojqoBqEzFSg==} resolution: {integrity: sha512-gcaNO0tKnHfcxMUaMh0Wk2Ljn7+VFJT8Trjyp4lrYCHDnWJDMFLOGTvd44Ar7mlzdoXDrrbPHUKs80yZqJ6Zzw==}
engines: {node: '>=18'} engines: {node: '>=18'}
peerDependencies: peerDependencies:
ioredis: '>=5' ioredis: '>=5'
@@ -22060,7 +22060,7 @@ snapshots:
section-matter: 1.0.0 section-matter: 1.0.0
strip-bom-string: 1.0.0 strip-bom-string: 1.0.0
groupmq@1.0.0-next.15(ioredis@5.4.1): groupmq@1.0.0-next.16(ioredis@5.4.1):
dependencies: dependencies:
cron-parser: 4.9.0 cron-parser: 4.9.0
ioredis: 5.4.1 ioredis: 5.4.1