import { LockFactoryResolver } from "@daiso-tech/core/lock";
import { MemoryLockAdapter } from "@daiso-tech/core/lock/memory-lock-adapter";
import { RedisLockAdapter } from "@daiso-tech/core/lock/redis-lock-adapter";
import { Serde } from "@daiso-tech/core/serde";
import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/super-json-serde-adapter";
import Redis from "ioredis"
const serde = new Serde(new SuperJsonSerdeAdapter());
const lockFactoryResolver = new LockFactoryResolver({
serde,
adapters: {
memory: new MemoryLockAdapter(),
redis: new RedisLockAdapter(new Redis("YOUR_REDIS_CONNECTION")),
},
defaultAdapter: "memory",
});
import { LockFactoryResolver } from "@daiso-tech/core/lock";
import { MemoryLockAdapter } from "@daiso-tech/core/lock/memory-lock-adapter";
import { RedisLockAdapter } from "@daiso-tech/core/lock/redis-lock-adapter";
import { Serde } from "@daiso-tech/core/serde";
import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/super-json-serde-adapter";
import { TimeSpan } from "@daiso-tech/core/time-span";
import Redis from "ioredis";
const serde = new Serde(new SuperJsonSerdeAdapter());
const lockFactoryResolver = new LockFactoryResolver({
serde,
adapters: {
memory: new MemoryLockAdapter(),
redis: new RedisLockAdapter(new Redis("YOUR_REDIS_CONNECTION")),
},
defaultAdapter: "memory",
});
// Will acquire key using the default adapter which is MemoryLockAdapter
await lockFactoryResolver
.use()
.create("a")
.acquire();
// Will acquire key using the redis adapter
await lockFactoryResolver
.use("redis")
.create("a")
.acquire();
The
LockFactoryResolverclass is immutable.IMPORT_PATH:
"@daiso-tech/core/lock"