Skip to main content

LockProvider factory

Initial configuration​

To begin using the ILockProviderFactory, You will need to register all required adapters during initialization.

import { LockProviderFactory } from "@daiso-tech/core/lock";
import {
    MemoryLockAdapter,
    RedisLockAdapter,
} from "@daiso-tech/core/lock/adapters";
import { Serde } from "@daiso-tech/core/serde";
import type { ISerde } from "@daiso-tech/core/serde/contracts";
import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/adapters";
import { Namespace } from "@daiso-tech/core/utilities";
import Redis from "ioredis";

const serde = new Serde(new SuperJsonSerdeAdapter());
const lockProvider = new LockProviderFactory({
    // The LockProviderFactory takes the same settings as LockProvider class
    namespace: new Namespace("lock"),
    adapters: {
        memory: new MemoryLockAdapter(),
        redis: new RedisLockAdapter(new Redis("YOUR_REDIS_CONNECTION")),
    },
    // You can set an optional default adapter
    defaultAdapter: "memory",
});

Usage examples​

1. Using the default adapter​

await lockProvider
    .use()
    .create("shared-resource")
    .run(async () => {
        // code to run
    });
danger

Note that if you dont set a default adapter, an error will be thrown.

2. Specifying an adapter explicitly​

await lockProvider
    .use("redis")
    .create("shared-resource")
    .run(async () => {
        // code to run
    });
danger

Note that if you specify a non-existent adapter, an error will be thrown.

3. Overriding default settings​

await lockProvider
    .setNamespace(new Namespace("@my-namespace"))
    .use("redis")
    .create("shared-resource")
    .run(async () => {
        // code to run
    });
info

Note that the LockProviderFactory is immutable, meaning any configuration override returns a new instance rather than modifying the existing one.