//! 实时事件网关：RocketMQ 消费、订阅索引、投递编排与内部 RPC 业务入口。
//!
//! 业务边界：本模块只做事件路由/订阅/投递与身份校验编排，
//! 权限判定统一走平台内部 RPC（`internal.v1.*AuthorizationService`）。

pub mod action;
pub mod event_service;
pub mod listener;
pub mod pipe;
pub mod plan;
pub mod platform;
pub mod result;
pub mod socket_backend;
pub mod socket_runtime;
pub mod subscriptions;

pub use pipe::{EventsPipe, QUEUE_CAPACITY};
pub use result::ConsumeResult;
pub use socket::EmitPacket;
pub use subscriptions::{Subscription, SubscriptionRequest, Subscriptions, is_personal};