Aller au contenu
English

createSqliteTaskQueue

import { createSqliteTaskQueue } from "@elie-laloum/outpost";

Ouvre ou crée une base SQLite de file à path, avec son répertoire parent, et renvoie une DurableTaskQueue. Les jobs sont pris en charge dans l’ordre d’insertion sous des baux protégés par fence, et chaque écriture est synchronisée sur disque. Appelez close() une fois les workers et producteurs arrêtés.

Exemple complet et règles détaillées.

  • pathRequis
    string
    Chemin du fichier de base SQLite, résolu depuis le répertoire courant ; le fichier et son répertoire parent sont créés s’ils manquent.

Promise<DurableTaskQueue>

export declare function createSqliteTaskQueue(
  path: string,
): Promise<DurableTaskQueue>;