tiramisu/seyfert
5
0
Fork 0
mirror of https://github.com/tiramisulabs/seyfert.git synced 2025-07-01 20:46:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Reduce memory allocation in LimitedMemoryAdapter (#272)

Browse Source 
* refactor(LimitedMemoryAdapter): optimize scan function

Reduced the memory allocation by not creating a different array to iterate. Precalculated wildcard

* refactor(LimitedMemoryAdapter): optimize ulkGet function

Optimize the ulkGet function by not creating a different array once. Used Set for faster lookups.

* refactor(LimitedMemoryAdapter): rename keys to key in the get() function
This commit is contained in:
Mohtasim Alam Sohom 2024-10-06 19:30:59 +06:00 committed by GitHub
parent 5926b4df15
commit 4fb4861386
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 22 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/cache/adapters/limited.ts vendored
View File

@ -63,31 +63,36 @@ export class LimitedMemoryAdapter<T> implements Adapter {
scan(query: string, keys?: false): any[]; scan(query: string, keys?: false): any[];
scan(query: string, keys: true): string[]; scan(query: string, keys: true): string[];
scan(query: string, keys = false) { scan(query: string, keys = false) {
const values: (string | unknown)[] = [];
const sq = query.split('.'); const sq = query.split('.');
for (const iterator of [...this.storage.values()].flatMap(x => x.entries())) const isWildcard = sq.map(segment => segment === '*');
for (const [key, value] of iterator) {
if (key.split('.').every((value, i) => (sq[i] === '*' ? !!value : sq[i] === value))) {
values.push(keys ? key : this.options.decode(value.value));
}
}
return values; return [...this.storage.values()].flatMap(storageEntry =>
Array.from(storageEntry.entries())
.filter(([key]) => key.split('.').every((value, i) => isWildcard[i] || sq[i] === value))
.map(([key, value]) => (keys ? key : this.options.decode(value.value))),
);
} }
bulkGet(keys: string[]) { bulkGet(keys: string[]) {
const iterator = [...this.storage.values()]; const storageArray = Array.from(this.storage.values());
return keys const keySet = new Set(keys);
.map(key => {
const data = iterator.find(x => x.has(key))?.get(key); return storageArray
return data ? this.options.decode(data) : null; .flatMap(storageEntry => {
const entries = Array.from(storageEntry.entries());
return entries.filter(([key]) => keySet.has(key)).map(([, value]) => this.options.decode(value as T));
}) })
.filter(x => x); .filter(Boolean);
} }
get(keys: string) { get(key: string) {
const data = [...this.storage.values()].find(x => x.has(keys))?.get(keys); for (const storageEntry of this.storage.values()) {
return data ? this.options.decode(data) : null; if (storageEntry.has(key)) {
const data = storageEntry.get(key);
return data ? this.options.decode(data) : null;
}
}
return null;
} }
private __set(key: string, data: any) { private __set(key: string, data: any) {