rally_runtime/system

System database: observability and background jobs.

Opens a separate SQLite database (system.db) for message logging and the job queue. The connection is stored globally so any WS handler process can log messages. Uses synchronous=OFF because losing a few recent log entries on crash is acceptable for the throughput gain.

Types

JobHandler

</>

pub type JobHandler =
  fn(String, BitArray) -> Result(Nil, String)

Values

enqueue

</>

pub fn enqueue(
  name name: String,
  payload payload: BitArray,
  run_at run_at: Int,
) -> Nil

Enqueue a job to run at a specific time.

enqueue_in

</>

pub fn enqueue_in(
  name name: String,
  payload payload: BitArray,
  delay_seconds delay_seconds: Int,
) -> Nil

Enqueue a job to run after a delay.

enqueue_now

</>

pub fn enqueue_now(
  name name: String,
  payload payload: BitArray,
) -> Nil

Enqueue a job to run immediately.

start

</>

pub fn start(path: String) -> Nil

Call during app startup. Opens the system DB and stores the connection globally so any process (WS handlers) can access it.

start_job_runner

</>

pub fn start_job_runner(
  path path: String,
  handler handler: fn(String, BitArray) -> Result(Nil, String),
) -> Result(actor.Started(Nil), actor.StartError)

Start the system DB and job runner, returning the actor handle.

start_with_jobs

</>

pub fn start_with_jobs(
  path path: String,
  handler handler: fn(String, BitArray) -> Result(Nil, String),
) -> Nil

Start the system DB with an unsupervised background job runner.

supervised_job_runner

</>

pub fn supervised_job_runner(
  path path: String,
  handler handler: fn(String, BitArray) -> Result(Nil, String),
) -> supervision.ChildSpecification(Nil)

Return a worker child specification for supervising the job runner.