etcd lock

lock.ts

import { Etcd3 } from "etcd3";
const client = new Etcd3();

async function withLock(
  key: string,
  action: () => Promise<void>,
  client: Etcd3
): Promise<void> {
  const lockKey = `locks/${key}`;
  const lock = client.lock(lockKey);
  const safeAction = async () => action().catch(console.error);
  while (true) {
    try {
      await lock.do(safeAction);
      return;
    } catch (e) {
      continue;
    }
  }
}