asyncpg¶ class litestar.channels.backends.asyncpg.AsyncPgChannelsBackend¶ Bases: ChannelsBackend __init__(dsn: str) → None¶ __init__(*, make_connection: Callable[[], Awaitable[asyncpg.Connection]]) → None async on_startup() → None¶ Called by the plugin on application startup async on_shutdown() → None¶ Called by the plugin on application shutdown async publish(data: bytes, channels: Iterable[str]) → None¶ Publish the message data to all channels async subscribe(channels: Iterable[str]) → None¶ Start listening for events on channels async unsubscribe(channels: Iterable[str]) → None¶ Stop listening for events on channels async stream_events() → AsyncGenerator[tuple[str, bytes], None]¶ Return a generator, iterating over events of subscribed channels as they become available async get_history(channel: str, limit: int | None = None) → list[bytes]¶ Return the event history of channel, at most limit entries