Method releaseLock

packages/db/src/buffers/base-buffer.ts:310–319

(lockId: string)

  }

  private async releaseLock(lockId: string): Promise<void> {
    const script = `
      if redis.call("get", KEYS[1]) == ARGV[1] then
        return redis.call("del", KEYS[1])
      else
        return 0
      end
    `;
    await getRedisCache().eval(script, 1, this.lockKey, lockId);
  }

  /**
   * Emit a flush observation to the configured observer and to the structured