import { SqliteLockAdapter } from "@daiso-tech/core/lock/adapters";
import { LockProvider } from "@daiso-tech/core/lock";
import { KeyPrefixer } from "@daiso-tech/core/utilities";
import { Serde } from "@daiso-tech/core/serde";
import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/adapters";
import Sqlite from "better-sqlite3";
const database = new Sqlite("local.db");
const lockAdapter = new SqliteLockAdapter({
database,
});
// You need initialize the adapter once before using it.
await lockAdapter.init();
const serde = new Serde(new SuperJsonSerdeAdapter())
const lockProvider = new LockProvider({
keyPrefixer: new KeyPrefixer("lock"),
serde,
adapter: lockAdapter,
});
You can listen to the following LockEvents of all ILock instances created by the ILockProvider.
To understand how this method works, refer to IEventListenable .
You can listen to the following LockEvents of all ILock instances created by the ILockProvider.
To understand how this method works, refer to IEventListenable .
import { LockProvider } from "@daiso-tech/core/lock";
import { MemoryLockAdapter } from "@daiso-tech/core/lock/adapters";
import { KeyPrefixer } from "@daiso-tech/core/utilities";
import { Serde } from "@daiso-tech/core/serde";
import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/adapters";
const lockProvider = new LockProvider({
adapter: new MemoryLockAdapter(),
keyPrefixer: new KeyPrefixer("lock"),
serde: new Serde(new SuperJsonSerdeAdapter())
});
const lock = lockProvider.create("a");
You can listen to the following LockEvents of all ILock instances created by the ILockProvider.
To understand how this method works, refer to IEventListenable .
You can listen to the following LockEvents of all ILock instances created by the ILockProvider.
To understand how this method works, refer to IEventListenable .
You can listen to the following LockEvents of all ILock instances created by the ILockProvider.
To understand how this method works, refer to IEventListenable .
You can listen to the following LockEvents of all ILock instances created by the ILockProvider.
To understand how this method works, refer to IEventListenable .
LockProviderclass can be derived from anyILockAdapterorIDatabaseLockAdapter.Note the
ILockinstances created by theLockProviderclass are serializable and deserializable, allowing them to be seamlessly transferred across different servers, processes, and databases. This can be done directly usingIFlexibleSerdeor indirectly through components that rely onIFlexibleSerdeinternally.IMPORT_PATH:
"@daiso-tech/core/lock"