Struct ExtensionManager 

pub struct ExtensionManager { /* private fields */ }

Implementations

impl ExtensionManager

pub fn new(vec: Vec<ConstructedExtension>) -> Self

pub fn set_disabled(&self, disabled: Vec<CompactString>)

Sets the extensions whose entrypoints are skipped, this has to happen before init and before extension migrations are collected.

pub fn disabled(&self) -> Vec<CompactString>

pub fn is_disabled(&self, package_name: &str) -> bool

pub fn failed(&self) -> BTreeMap<CompactString, String>

Extensions whose entrypoints were skipped at boot because one of them panicked or their routes or CLI commands conflict, mapped to the reason.

pub fn is_failed(&self, package_name: &str) -> bool

pub fn inactive(&self) -> Vec<CompactString>

Extensions that are not running, either disabled or failed to start.

pub async fn init( &self, state: State, router: OpenApiRouter<State>, mount: impl Fn(ExtensionRouteBuilder) -> OpenApiRouter<State>, ) -> (OpenApiRouter<State>, BackgroundTaskBuilder, ShutdownHandlerBuilder)

Runs the entrypoints of every enabled extension and merges their routes into router, which already holds the core routes. mount turns a single extension’s route builder into a router that can be merged into router.

An extension whose entrypoint panics, or whose routes conflict with the core or an earlier extension, is marked as failed and everything it registered is rolled back, instead of panicking the panel.

pub async fn init_cli( &self, env: Option<&Arc<Env>>, builder: CliCommandGroupBuilder, ) -> CliCommandGroupBuilder

Registers the CLI commands of every extension. An extension whose initialize_cli panics or registers an already taken command is marked as failed, which also skips its other entrypoints in init.

pub async fn extensions(&self) -> RwLockReadGuard<'_, Vec<ConstructedExtension>>

pub fn blocking_extensions( &self, ) -> RwLockReadGuard<'_, Vec<ConstructedExtension>>

pub async fn call( &self, name: impl AsRef<str>, args: &[ExtensionCallValue], ) -> Option<ExtensionCallValue>