| 303 | }; |
| 304 | |
| 305 | const createMemoryStore = () => { |
| 306 | const memoryStore = new InMemoryRuntimeStore(); |
| 307 | return { |
| 308 | backend: "memory", |
| 309 | envPrefix: resolvedEnvPrefix, |
| 310 | clear: () => { |
| 311 | memoryStore.values.clear(); |
| 312 | memoryStore.sortedSets.clear(); |
| 313 | memoryStore.hashes.clear(); |
| 314 | }, |
| 315 | get: (...args) => memoryStore.get(...args), |
| 316 | set: (...args) => memoryStore.set(...args), |
| 317 | del: (...args) => memoryStore.del(...args), |
| 318 | hset: (...args) => memoryStore.hset(...args), |
| 319 | hget: (...args) => memoryStore.hget(...args), |
| 320 | hgetall: (...args) => memoryStore.hgetall(...args), |
| 321 | hdel: (...args) => memoryStore.hdel(...args), |
| 322 | zscore: (...args) => memoryStore.zscore(...args), |
| 323 | zincrby: (...args) => memoryStore.zincrby(...args), |
| 324 | zrevrange: (...args) => memoryStore.zrevrange(...args), |
| 325 | zrem: (...args) => memoryStore.zrem(...args), |
| 326 | zcard: (...args) => memoryStore.zcard(...args), |
| 327 | zremrangebyrank: (...args) => memoryStore.zremrangebyrank(...args), |
| 328 | }; |
| 329 | }; |
| 330 | |
| 331 | if (clusterConfig?.cluster?.nodes?.length > 0) { |
| 332 | redisClient = new Redis.Cluster(clusterConfig.cluster.nodes, clusterConfig.cluster.options); |