pub struct PluginHostManager {
pub processes: Arc<DashMap<String, Arc<PluginProcess>>>,
pub plugins: Arc<DashMap<String, PluginRegistration>>,
pub data_dir_root: PathBuf,
pub log_dir_root: PathBuf,
/* private fields */
}Expand description
第三方插件子进程的顶层管理器。
Fields§
§processes: Arc<DashMap<String, Arc<PluginProcess>>>已加载插件的子进程映射。
plugins: Arc<DashMap<String, PluginRegistration>>已加载插件的组件注册包(含 DataSource / Executor / Plugin 适配器)。
data_dir_root: PathBuf插件数据的根目录。
log_dir_root: PathBuf插件 stderr 日志的根目录。
Implementations§
Source§impl PluginHostManager
impl PluginHostManager
Sourcepub fn scan_dirs(&self) -> Vec<PathBuf>
pub fn scan_dirs(&self) -> Vec<PathBuf>
枚举包含 manifest.toml 的插件目录(不解析清单)。 返回:目录列表;安装根目录不存在时为空。
仅用于启动期加载(load_all_third_party);列表/详情一律读内存快照。
Sourcepub fn installed_snapshot(&self) -> Vec<Arc<InstalledPlugin>>
pub fn installed_snapshot(&self) -> Vec<Arc<InstalledPlugin>>
已安装插件的内存快照(Arc 克隆,无磁盘 IO)。
Sourcepub fn refresh_installed(&self)
pub fn refresh_installed(&self)
立即重扫安装目录并替换快照。
安装/卸载/重载链路在动作完成后调用,保证紧随其后的 IPC 读到新事实; 监听线程同样只调用本方法,刷新逻辑唯一。
Sourcepub fn installed(&self, plugin_id: &str) -> Option<Arc<InstalledPlugin>>
pub fn installed(&self, plugin_id: &str) -> Option<Arc<InstalledPlugin>>
按清单 id 定位安装记录:已加载取注册包快照,否则读内存安装快照。 参数:plugin_id - 插件 id。 返回:安装记录;未安装(或快照尚未刷新到)返回 None。
Sourcepub fn start_installed_watcher(&self) -> Result<()>
pub fn start_installed_watcher(&self) -> Result<()>
启动插件目录监听:目录变更后异步重扫安装快照。
幂等:已启动直接返回 Ok。最终一致(事件合并窗口约 300ms),覆盖用户手动 拷贝/删除插件目录的场景;监听失败只降级为「只在动作后刷新」,不阻断启动。 返回:启动成功 Ok(()),创建目录或监听失败返回错误。
Sourcepub fn to_info(
&self,
installed: &InstalledPlugin,
is_component_enabled: impl Fn(&str) -> bool,
) -> PluginInfo
pub fn to_info( &self, installed: &InstalledPlugin, is_component_enabled: impl Fn(&str) -> bool, ) -> PluginInfo
安装记录 → 展示条目:已加载取运行时注册,未加载呈现 error 态。 参数:installed - 安装记录;is_component_enabled - 组件启用态谓词(由调用方提供)。 返回:IPC 展示条目(未加载时组件为空、enabled 为 false)。
Source§impl PluginHostManager
impl PluginHostManager
pub fn new( plugins_dir: PathBuf, data_dir_root: PathBuf, log_dir_root: PathBuf, ) -> Arc<Self> ⓘ
Sourcepub fn set_builtin_component_ids(&self, ids: HashSet<String>)
pub fn set_builtin_component_ids(&self, ids: HashSet<String>)
注入内置组件 id 集合(冲突预检数据源)。
由 src-tauri 在内置组件注册完毕后调用一次;此后内置组件集合 启动期稳定,不再更新。预检据此识别「与内置组件撞 id」。
Sourcepub async fn load(
&self,
plugin_dir: &Path,
host_call_handler: Arc<dyn HostCallHandler>,
on_restart: RestartCallback,
on_crash: CrashCallback,
restart_count: u32,
locale: &str,
) -> Result<PluginRegistration, PluginLoadError>
pub async fn load( &self, plugin_dir: &Path, host_call_handler: Arc<dyn HostCallHandler>, on_restart: RestartCallback, on_crash: CrashCallback, restart_count: u32, locale: &str, ) -> Result<PluginRegistration, PluginLoadError>
从包含 manifest.toml 的目录加载一个插件。
on_restart 存入重启上下文,崩溃重启成功后被调用,
供调用方(src-tauri)重新注册新适配器。
on_crash 在崩溃检测到的那一刻(任何重启尝试之前)以旧注册包调用,
供调用方解注册 CM/SR 中的过期组件。
restart_count 为已发生的重启次数(初次加载传 0),用于延续崩溃恢复计数。
locale 为宿主当前界面语言,随 initialize 握手下发插件进程。
Sourcepub fn plugins_dir(&self) -> &Path
pub fn plugins_dir(&self) -> &Path
返回插件安装目录(显式存储,非派生)。
Sourcepub async fn unload(&self, plugin_id: &str) -> Result<(), PluginLoadError>
pub async fn unload(&self, plugin_id: &str) -> Result<(), PluginLoadError>
卸载插件:关闭子进程、移除全部登记并删除诊断日志(含轮转 .log.1)。 与 teardown(加载失败清理)的区别:teardown 保留日志供故障溯源。
Sourcepub async fn shutdown_all(&self)
pub async fn shutdown_all(&self)
关闭全部已加载插件的子进程(应用退出路径)。
调用约定:进入本方法前,调用方必须已对每个插件执行 Plugin::on_shutdown
(应用退出路径由 src-tauri 遍历插件注册表统一完成)。本方法只负责关闭进程,
不再重复发送退出钩子。
与 unload 的区别:不删除诊断日志,只关闭进程并清空登记。
与 load/teardown 共用 load_lock,避免与并发的加载/卸载交错;
各进程并发关闭,整体耗时上限为单插件的退出等待预算。
Sourcepub fn update_locale(&self, plugin_id: &str, locale: &str)
pub fn update_locale(&self, plugin_id: &str, locale: &str)
更新插件重启上下文中的语言快照。
宿主在崩溃回调中调用(崩溃时刻取最新语言),保证崩溃重启的 initialize 握手携带最新 locale,而非首次加载时的快照。 插件不存在(正常卸载等)时静默。
Sourcepub fn get_plugin_info(
&self,
plugin_id: &str,
is_component_enabled: impl Fn(&str) -> bool,
) -> Option<PluginInfo>
pub fn get_plugin_info( &self, plugin_id: &str, is_component_enabled: impl Fn(&str) -> bool, ) -> Option<PluginInfo>
单个插件的运行时条目(按 id 直查,不遍历全量列表)。
返回 None 表示该插件当前未加载;调用方据此区分运行态与「已安装未加载」。 启用态 = 插件自身 Plugin 组件的启用态(路由只认插件 id)。
Auto Trait Implementations§
impl !Freeze for PluginHostManager
impl !RefUnwindSafe for PluginHostManager
impl !UnwindSafe for PluginHostManager
impl Forget for PluginHostManager
impl Move for PluginHostManager
impl Send for PluginHostManager
impl Sync for PluginHostManager
impl Unpin for PluginHostManager
impl UnsafeUnpin for PluginHostManager
Blanket Implementations§
Source§impl<S, D, Swp, Dwp, T> AdaptInto<D, Swp, Dwp, T> for Swhere
T: Real + Zero + Arithmetics + Clone,
Swp: WhitePoint<T>,
Dwp: WhitePoint<T>,
D: AdaptFrom<S, Swp, Dwp, T>,
impl<S, D, Swp, Dwp, T> AdaptInto<D, Swp, Dwp, T> for Swhere
T: Real + Zero + Arithmetics + Clone,
Swp: WhitePoint<T>,
Dwp: WhitePoint<T>,
D: AdaptFrom<S, Swp, Dwp, T>,
Source§fn adapt_into_using<M>(self, method: M) -> Dwhere
M: TransformMatrix<T>,
fn adapt_into_using<M>(self, method: M) -> Dwhere
M: TransformMatrix<T>,
replaced by palette::chromatic_adaptation::AdaptIntoUnclamped
Source§fn adapt_into(self) -> D
fn adapt_into(self) -> D
replaced by palette::chromatic_adaptation::AdaptIntoUnclamped
Source§impl<T, C> AdaptIntoUnclamped<T> for Cwhere
T: AdaptFromUnclamped<C>,
impl<T, C> AdaptIntoUnclamped<T> for Cwhere
T: AdaptFromUnclamped<C>,
Source§type Scalar = <T as AdaptFromUnclamped<C>>::Scalar
type Scalar = <T as AdaptFromUnclamped<C>>::Scalar
Source§fn adapt_into_unclamped_with<M>(self) -> Twhere
M: LmsToXyz<<C as AdaptIntoUnclamped<T>>::Scalar> + XyzToLms<<C as AdaptIntoUnclamped<T>>::Scalar>,
fn adapt_into_unclamped_with<M>(self) -> Twhere
M: LmsToXyz<<C as AdaptIntoUnclamped<T>>::Scalar> + XyzToLms<<C as AdaptIntoUnclamped<T>>::Scalar>,
Source§impl<T, C> ArraysFrom<C> for Twhere
C: IntoArrays<T>,
impl<T, C> ArraysFrom<C> for Twhere
C: IntoArrays<T>,
Source§fn arrays_from(colors: C) -> T
fn arrays_from(colors: C) -> T
Source§impl<T, C> ArraysInto<C> for Twhere
C: FromArrays<T>,
impl<T, C> ArraysInto<C> for Twhere
C: FromArrays<T>,
Source§fn arrays_into(self) -> C
fn arrays_into(self) -> C
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<WpParam, T, U> Cam16IntoUnclamped<WpParam, T> for Uwhere
T: FromCam16Unclamped<WpParam, U>,
impl<WpParam, T, U> Cam16IntoUnclamped<WpParam, T> for Uwhere
T: FromCam16Unclamped<WpParam, U>,
Source§type Scalar = <T as FromCam16Unclamped<WpParam, U>>::Scalar
type Scalar = <T as FromCam16Unclamped<WpParam, U>>::Scalar
parameters when converting.Source§fn cam16_into_unclamped(
self,
parameters: BakedParameters<WpParam, <U as Cam16IntoUnclamped<WpParam, T>>::Scalar>,
) -> T
fn cam16_into_unclamped( self, parameters: BakedParameters<WpParam, <U as Cam16IntoUnclamped<WpParam, T>>::Scalar>, ) -> T
self into C, using the provided parameters.impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T, C> ComponentsFrom<C> for Twhere
C: IntoComponents<T>,
impl<T, C> ComponentsFrom<C> for Twhere
C: IntoComponents<T>,
Source§fn components_from(colors: C) -> T
fn components_from(colors: C) -> T
Source§impl<T, C> ComponentsInto<C> for T
impl<T, C> ComponentsInto<C> for T
Source§fn components_into(self) -> C
fn components_into(self) -> C
Source§impl<T> FromAngle<T> for T
impl<T> FromAngle<T> for T
Source§fn from_angle(angle: T) -> T
fn from_angle(angle: T) -> T
angle.Source§impl<T, U> FromStimulus<U> for Twhere
U: IntoStimulus<T>,
impl<T, U> FromStimulus<U> for Twhere
U: IntoStimulus<T>,
Source§fn from_stimulus(other: U) -> T
fn from_stimulus(other: U) -> T
other into Self, while performing the appropriate scaling,
rounding and clamping.Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T, U> IntoAngle<U> for Twhere
U: FromAngle<T>,
impl<T, U> IntoAngle<U> for Twhere
U: FromAngle<T>,
Source§fn into_angle(self) -> U
fn into_angle(self) -> U
T.Source§impl<WpParam, T, U> IntoCam16Unclamped<WpParam, T> for Uwhere
T: Cam16FromUnclamped<WpParam, U>,
impl<WpParam, T, U> IntoCam16Unclamped<WpParam, T> for Uwhere
T: Cam16FromUnclamped<WpParam, U>,
Source§type Scalar = <T as Cam16FromUnclamped<WpParam, U>>::Scalar
type Scalar = <T as Cam16FromUnclamped<WpParam, U>>::Scalar
parameters when converting.Source§fn into_cam16_unclamped(
self,
parameters: BakedParameters<WpParam, <U as IntoCam16Unclamped<WpParam, T>>::Scalar>,
) -> T
fn into_cam16_unclamped( self, parameters: BakedParameters<WpParam, <U as IntoCam16Unclamped<WpParam, T>>::Scalar>, ) -> T
self into C, using the provided parameters.Source§impl<T, U> IntoColor<U> for Twhere
U: FromColor<T>,
impl<T, U> IntoColor<U> for Twhere
U: FromColor<T>,
Source§fn into_color(self) -> U
fn into_color(self) -> U
Source§impl<T, U> IntoColorUnclamped<U> for Twhere
U: FromColorUnclamped<T>,
impl<T, U> IntoColorUnclamped<U> for Twhere
U: FromColorUnclamped<T>,
Source§fn into_color_unclamped(self) -> U
fn into_color_unclamped(self) -> U
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoStimulus<T> for T
impl<T> IntoStimulus<T> for T
Source§fn into_stimulus(self) -> T
fn into_stimulus(self) -> T
self into T, while performing the appropriate scaling,
rounding and clamping.Source§impl<T> Pointable for T
impl<T> Pointable for T
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
Source§impl<T, C> TryComponentsInto<C> for Twhere
C: TryFromComponents<T>,
impl<T, C> TryComponentsInto<C> for Twhere
C: TryFromComponents<T>,
Source§type Error = <C as TryFromComponents<T>>::Error
type Error = <C as TryFromComponents<T>>::Error
try_into_colors fails to cast.Source§fn try_components_into(self) -> Result<C, <T as TryComponentsInto<C>>::Error>
fn try_components_into(self) -> Result<C, <T as TryComponentsInto<C>>::Error>
Source§impl<T, U> TryIntoColor<U> for Twhere
U: TryFromColor<T>,
impl<T, U> TryIntoColor<U> for Twhere
U: TryFromColor<T>,
Source§fn try_into_color(self) -> Result<U, OutOfBounds<U>>
fn try_into_color(self) -> Result<U, OutOfBounds<U>>
OutOfBounds error is returned which contains
the unclamped color. Read more