base

class litestar.channels.backends.base.ChannelsBackend

基类：ABC

abstractmethod async on_startup() → None

由插件在应用程序启动时调用

abstractmethod async on_shutdown() → None

由插件在应用程序关闭时调用

abstractmethod async publish(data: bytes, channels: Iterable[str]) → None

将消息 data 发布到所有 channels

abstractmethod async subscribe(channels: Iterable[str]) → None

开始在 channels 上监听事件

abstractmethod async unsubscribe(channels: Iterable[str]) → None

停止在 channels 上监听事件

abstractmethod stream_events() → AsyncGenerator[tuple[str, bytes], None]

返回一个生成器，迭代订阅通道的可用事件。

abstractmethod async get_history(channel: str, limit: int | None = None) → list[bytes]

返回 channel 的事件历史，最多包含 limit 条记录