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

fix(buffer): add correct envs

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2025-02-04 12:07:21 +01:00
parent de3ea6c8be
commit 272ea7fa7c
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/db/src/buffers/event-buffer-psql.ts
View File

@@ -14,8 +14,8 @@ export class EventBuffer extends BaseBuffer {
private daysToKeep = process.env.EVENT_BUFFER_DAYS_TO_KEEP private daysToKeep = process.env.EVENT_BUFFER_DAYS_TO_KEEP
? Number.parseInt(process.env.EVENT_BUFFER_DAYS_TO_KEEP, 10) ? Number.parseInt(process.env.EVENT_BUFFER_DAYS_TO_KEEP, 10)
: 3; : 3;
private batchSize = process.env.EVENT_BUFFER_CHUNK_SIZE private batchSize = process.env.EVENT_BUFFER_BATCH_SIZE
? Number.parseInt(process.env.EVENT_BUFFER_CHUNK_SIZE, 10) ? Number.parseInt(process.env.EVENT_BUFFER_BATCH_SIZE, 10)
: 2000; : 2000;
private chunkSize = process.env.EVENT_BUFFER_CHUNK_SIZE private chunkSize = process.env.EVENT_BUFFER_CHUNK_SIZE
? Number.parseInt(process.env.EVENT_BUFFER_CHUNK_SIZE, 10) ? Number.parseInt(process.env.EVENT_BUFFER_CHUNK_SIZE, 10)

4
packages/db/src/buffers/profile-buffer-psql.ts
View File

@@ -11,8 +11,8 @@ export class ProfileBuffer extends BaseBuffer {
private daysToKeep = process.env.PROFILE_BUFFER_DAYS_TO_KEEP private daysToKeep = process.env.PROFILE_BUFFER_DAYS_TO_KEEP
? Number.parseInt(process.env.PROFILE_BUFFER_DAYS_TO_KEEP, 10) ? Number.parseInt(process.env.PROFILE_BUFFER_DAYS_TO_KEEP, 10)
: 7; : 7;
private batchSize = process.env.PROFILE_BUFFER_CHUNK_SIZE private batchSize = process.env.PROFILE_BUFFER_BATCH_SIZE
? Number.parseInt(process.env.PROFILE_BUFFER_CHUNK_SIZE, 10) ? Number.parseInt(process.env.PROFILE_BUFFER_BATCH_SIZE, 10)
: 2000; : 2000;
private chunkSize = process.env.PROFILE_BUFFER_CHUNK_SIZE private chunkSize = process.env.PROFILE_BUFFER_CHUNK_SIZE
? Number.parseInt(process.env.PROFILE_BUFFER_CHUNK_SIZE, 10) ? Number.parseInt(process.env.PROFILE_BUFFER_CHUNK_SIZE, 10)