Function load

flow-rs/src/loader/mod.rs:49–78

(local_key: u64, cfg: &LoaderConfig)

static ONCE_LOAD_FROM_SCOPE: Once = Once::new();

pub(crate) fn load(local_key: u64, cfg: &LoaderConfig) -> Result<()> {
    let loader = <Box<dyn Loader>>::registry_global().get(&cfg.ty).unwrap();
    ONCE_LOAD_FROM_SCOPE.call_once(|| {
        for plugin in loader
            .load_from_scope(local_key)
            .expect("cannot load plugins from current scope")
        {
            plugin.submit();
        }
    });

    if let Some(plugin_path) = &cfg.plugin_path {
        for entry in fs::read_dir(&plugin_path)? {
            let entry = entry?;
            let pathbuf = entry.path();
            let path: &Path = pathbuf.as_ref();
            if let Some(path) = cfg.ty.check(path) {
                for plugin in loader.load_from_file(
                    local_key,
                    cfg.module_path.as_ref().map(|x| x.as_ref()),
                    path.as_path(),
                )? {
                    plugin.submit();
                }
            }
        }
    }

    Ok(())
}

impl PluginType {
    fn check(&self, path: &Path) -> Option<PathBuf> {