Struct RuntimeContext 

pub struct RuntimeContext { /* private fields */ }

RuntimeContext - Runtime’s implementation of Context trait

设计特性

• 零虚函数：内部使用 OutGate enum dispatch（非 dyn）
• 智能路由：根据 Dest 自动选择 InprocOut 或 OutprocOut
• 完整实现：包含 call/tell 的完整逻辑（编码、发送、解码）
• 类型安全：泛型方法提供编译时类型检查

性能

• OutGate 是 enum，使用静态分发
• 编译器可完全内联整个调用链
• 零虚函数调用开销

Implementations

impl RuntimeContext

pub fn new( self_id: ActrId, caller_id: Option<ActrId>, request_id: String, inproc_gate: OutGate, outproc_gate: Option<OutGate>, data_stream_registry: Arc<DataStreamRegistry>, media_frame_registry: Arc<MediaFrameRegistry>, signaling_client: Arc<dyn SignalingClient>, credential: AIdCredential, actr_lock: Option<LockFile>, config_dir: Option<PathBuf>, ) -> Self

创建新的 RuntimeContext

参数

• self_id: 当前 Actor 的 ID
• caller_id: 调用方 Actor ID（可选）
• request_id: 当前请求唯一 ID
• inproc_gate: 进程内通信 gate（立即可用）
• outproc_gate: 跨进程通信 gate（可能为 None，等待 WebRTC 初始化）
• data_stream_registry: DataStream 回调注册表
• media_frame_registry: MediaTrack 回调注册表
• signaling_client: 用于路由发现的信令客户端
• credential: 该 Actor 的凭证（调用信令接口时使用）
• actr_lock: Actr.lock.toml 依赖配置（用于 fingerprint 查找）
• config_dir: 配置目录路径（用于 compat.lock.toml Fast Path 缓存）

pub async fn call_raw( &self, target: &Dest, route_key: String, payload_type: PayloadType, payload: Bytes, timeout_ms: i64, ) -> ActorResult<Bytes>

Execute a non-generic RPC request call (useful for language bindings).

pub async fn tell_raw( &self, target: &Dest, route_key: String, payload_type: PayloadType, payload: Bytes, ) -> ActorResult<()>

Execute a non-generic RPC message call (fire-and-forget, useful for language bindings).

pub async fn send_data_stream_with_type( &self, target: &Dest, payload_type: PayloadType, chunk: DataStream, ) -> ActorResult<()>

Send DataStream with an explicit payload type (lane selection).

This is intended for language bindings; the Context trait method send_data_stream() currently defaults to StreamReliable.

Trait Implementations

impl Clone for RuntimeContext

fn clone(&self) -> RuntimeContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Context for RuntimeContext

fn self_id(&self) -> &ActrId

Get the current Actor’s ID

fn caller_id(&self) -> Option<&ActrId>

Get the caller’s Actor ID

fn request_id(&self) -> &str

Get the unique request ID

fn call<'life0, 'life1, 'async_trait, R>( &'life0 self, target: &'life1 Dest, request: R, ) -> Pin<Box<dyn Future<Output = ActorResult<R::Response>> + Send + 'async_trait>>

where R: 'async_trait + RpcRequest, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a type-safe RPC request and wait for response

fn tell<'life0, 'life1, 'async_trait, R>( &'life0 self, target: &'life1 Dest, message: R, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where R: 'async_trait + RpcRequest, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a type-safe one-way message (no response expected)

fn register_stream<'life0, 'async_trait, F>( &'life0 self, stream_id: String, callback: F, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where F: Fn(DataStream, ActrId) -> BoxFuture<'static, ActorResult<()>> + Send + Sync + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Register a DataStream callback for a specific stream

fn unregister_stream<'life0, 'life1, 'async_trait>( &'life0 self, stream_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Unregister a DataStream callback

fn send_data_stream<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 Dest, chunk: DataStream, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a DataStream to a destination

fn discover_route_candidate<'life0, 'life1, 'async_trait>( &'life0 self, target_type: &'life1 ActrType, ) -> Pin<Box<dyn Future<Output = ActorResult<ActrId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Discover a remote Actor of the specified type via the signaling server.

fn call_raw<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, target: &'life1 ActrId, route_key: &'life2 str, payload: Bytes, ) -> Pin<Box<dyn Future<Output = ActorResult<Bytes>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Send a raw RPC request (untyped bytes) and wait for response

fn register_media_track<'life0, 'async_trait, F>( &'life0 self, track_id: String, callback: F, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where F: Fn(MediaSample, ActrId) -> BoxFuture<'static, ActorResult<()>> + Send + Sync + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Register a WebRTC native media track callback

fn unregister_media_track<'life0, 'life1, 'async_trait>( &'life0 self, track_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Unregister a media track callback

fn send_media_sample<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, target: &'life1 Dest, track_id: &'life2 str, sample: MediaSample, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Send media samples via WebRTC native track