clickhouse-ts
Advanced tools
Comparing version 1.3.15 to 1.3.16
@@ -33,2 +33,9 @@ "use strict"; | ||
this.checkInstance(); | ||
Debug_1.debug.log('tableChunks_profiling', { tableChunks: __classPrivateFieldGet(this, _RedisCacheManager_tableChunks, "f") }); | ||
for await (const [table, chunkIds] of Object.entries(__classPrivateFieldGet(this, _RedisCacheManager_tableChunks, "f"))) { | ||
for await (const chunkId of chunkIds) { | ||
const chunkLen = await __classPrivateFieldGet(this, _RedisCacheManager_instance, "f").llen(chunkId); | ||
Debug_1.debug.log(`chunk.${table}.${chunkId}`, { chunkLen }); | ||
} | ||
} | ||
const now = dayjs_1.default(); | ||
@@ -35,0 +42,0 @@ for await (const [table, chunkNamespaces] of Object.entries(__classPrivateFieldGet(this, _RedisCacheManager_tableChunks, "f"))) { |
@@ -12,3 +12,3 @@ { | ||
], | ||
"version": "1.3.15", | ||
"version": "1.3.16", | ||
"license": "ISC", | ||
@@ -47,3 +47,2 @@ "description": "Clickhouse client on TypeScript using redis caching queries", | ||
"@types/sqlstring": "^2.3.0", | ||
"@types/uuid": "^8.3.0", | ||
"ts-node": "^10.0.0", | ||
@@ -50,0 +49,0 @@ "typescript": "^4.3.4" |
@@ -27,3 +27,3 @@ import dayjs from "dayjs"; | ||
}) { | ||
super() | ||
super() | ||
this.#tableChunks = {} | ||
@@ -36,2 +36,11 @@ this.#options = options | ||
debug.log('tableChunks_profiling', { tableChunks: this.#tableChunks }) | ||
for await (const [table, chunkIds] of Object.entries(this.#tableChunks)) { | ||
for await (const chunkId of chunkIds) { | ||
const chunkLen = await this.#instance!.llen(chunkId) | ||
debug.log(`chunk.${table}.${chunkId}`, { chunkLen }) | ||
} | ||
} | ||
const now = dayjs() | ||
@@ -38,0 +47,0 @@ for await (const [table, chunkNamespaces] of Object.entries(this.#tableChunks)) { |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
68607
3
1293