gabsurd/queue

Queue management for the Absurd durable workflow system. Provides high-level functions for creating, dropping, and listing queues.

Values

</>

pub fn create(
  db: client.Db,
  queue_name: String,
) -> Result(Nil, client.GabsurdError)

Create a new queue with default (unpartitioned) storage mode.

</>

pub fn create_with_mode(
  db: client.Db,
  queue_name: String,
  storage_mode: String,
) -> Result(Nil, client.GabsurdError)

Create a new queue with a specific storage mode.

</>

pub fn drop(
  db: client.Db,
  queue_name: String,
) -> Result(Nil, client.GabsurdError)

Drop a queue and all its associated tables.

</>

pub fn list(
  db: client.Db,
) -> Result(List(String), client.GabsurdError)

List all queue names.