moonbitstack/mooncat/lifespan

moonbitstack/mooncat/lifespan does not have a README file

LifespanError

pub suberror LifespanError {
  LifespanError(String)
}

Raised when an application reports lifespan.startup.failed or lifespan.shutdown.failed, carrying the failure message the app supplied.

Lifespan

source

pub struct Lifespan {
  app : async (@moonbitstack/moonasgi/spec.Scope
Scope, async () -> @moonbitstack/moonasgi/spec.Event
Event, async (@moonbitstack/moonasgi/spec.Event
Event) -> Unit) -> Unit
  inbox : @moonbitlang/async/aqueue.Queue
Queue[@moonbitstack/moonasgi/spec.Event
Event]
  outbox : @moonbitlang/async/aqueue.Queue
Queue[@moonbitstack/moonasgi/spec.Event
Event]
  state : Map[String, Json]
}

Drives an ASGI application's lifespan protocol (← uvicorn LifespanOn).

A single long-lived invocation of the app runs under a Lifespan scope. The server and that invocation exchange messages through two async queues: the server pushes lifespan.startup / lifespan.shutdown onto inbox (which backs the app's Receive), and the app pushes its *.complete / *.failed replies onto outbox (which the app's Send writes to). state seeds the lifespan scope and is shared into request scopes by the caller.

Lifespan::new

source

fn Lifespan::new(app : async (@moonbitstack/moonasgi/spec.Scope
Scope, async () -> @moonbitstack/moonasgi/spec.Event
Event, async (@moonbitstack/moonasgi/spec.Event
Event) -> Unit) -> Unit) -> Lifespan

Create a lifespan driver for app, with empty unbounded message queues and empty lifespan state.

Lifespan::shutdown

source

async fn Lifespan::shutdown(self : Lifespan, task : @moonbitlang/async.Task
Task[Unit]) -> Unit

Run ASGI lifespan shutdown: push lifespan.shutdown and await the app's reply, or return immediately if the app invocation has already finished. Raises LifespanError if the app reports lifespan.shutdown.failed.

Lifespan::spawn

source

fn Lifespan::spawn(self : Lifespan, g : @moonbitlang/async.TaskGroup
TaskGroup[Unit]) -> @moonbitlang/async.Task
Task[Unit]

Spawn the application under a Lifespan scope as a task in g, returning its handle. The task blocks on receive() until startup() / shutdown() push signals; a lifespan-aware app therefore stays parked for the server's whole life, while an app that ignores the lifespan scope simply returns at once (detected via the returned task in startup / shutdown).

Lifespan::startup

source

async fn Lifespan::startup(self : Lifespan, task : @moonbitlang/async.Task
Task[Unit]) -> Unit

Run ASGI lifespan startup: push lifespan.startup and await the app's reply. Returns once the app sends lifespan.startup.complete, or once the app returns without lifespan support (its task finishing wins the race, and startup is treated as a no-op, matching uvicorn's lifespan="auto"). Raises LifespanError if the app reports lifespan.startup.failed.

Source Files

lifespan.mbt

Install

Download zip

mooncat — a native ASGI 3.0 server for MoonBit (← uvicorn), built on moonbitlang/async and the moonasgi SEAM. HTTP/1.1, HTTP/2, WebSocket, TLS and HTTP/3, a uvicorn-shaped command line, and a process model with graceful shutdown; the protocols themselves are moonhttp, moontls and moonquic.

asgiserveruvicornhttpwebsocketmoonbitnative