Struct Context 

pub struct Context { /* private fields */ }

Root and child dependency containers for Cordis plugins.

Cloning a context is cheap. Child contexts share all runtime services while carrying immutable scope/intercept/metadata overlays and the current fiber.

Implementations

impl Context

pub fn new() -> Self

Create a root context and install the core reflection, registry, event, and logger services.

pub fn same_root(&self, other: &Context) -> bool

Return whether two contexts belong to the same root application.

pub fn root(&self) -> Context

Return the root context.

pub fn fiber(&self) -> Result<Fiber>

Return this context’s owning plugin fiber.

pub fn base_url(&self) -> Option<&str>

Return the base URL inherited by this context, when set.

pub fn with_base_url(&self, base_url: impl Into<Arc<str>>) -> Context

Derive a child context with a new base URL.

pub fn extend<T>(&self, name: impl Into<String>, value: T) -> Context

where T: Send + Sync + 'static,

Derive a child context carrying arbitrary metadata.

pub fn extend_value(&self, name: impl Into<String>, value: Value) -> Context

Derive a child context carrying type-erased metadata.

pub fn metadata<T>(&self, name: &str) -> Result<Option<Arc<T>>>

where T: Send + Sync + 'static,

Read typed context metadata.

pub fn new_isolation(&self) -> Isolation

Allocate a globally unique isolation label.

pub fn isolate(&self, name: impl Into<String>) -> Context

Create a child context with a fresh independent service scope for name.

pub fn isolate_with(&self, name: impl Into<String>, label: Isolation) -> Context

Create a child context using a supplied scope label. Reusing the label joins otherwise separate context branches to the same service scope.

A scope holds one implementation per slot, and every name isolated with the same label maps to that one slot: only one of those names can be provided there, and providing a second fails with DuplicateService.

pub fn isolate_many( &self, names: impl IntoIterator<Item = impl Into<String>>, label: Option<Isolation>, ) -> Context

Create a child context with several service names isolated together.

All names share one scope label and therefore one implementation slot, matching the upstream single-slot scope model: provide exactly one of them in this branch — providing a second name fails with DuplicateService — and inject only that name from sibling plugins. Use separate labels (or isolate) when several of the names need independent implementations.

pub fn intercept<T>(&self, name: impl Into<String>, config: T) -> Context

where T: Send + Sync + 'static,

Add service-specific intercept configuration below this context.

pub fn intercept_value(&self, name: impl Into<String>, config: Value) -> Context

Add type-erased intercept configuration.

pub fn intercepts<T>(&self, name: &str) -> Result<Vec<Arc<T>>>

where T: Send + Sync + 'static,

Return typed intercept configs in ancestor-to-descendant order.

pub fn with_filter<F>(&self, filter: F) -> Context

where F: Fn(&Context) -> bool + Send + Sync + 'static,

Attach an event listener filter to a derived context.

pub fn events(&self) -> EventsService

Return the events service bound to this context.

pub fn reflect(&self) -> ReflectService

Return the reflection/service store bound to this context.

pub fn registry(&self) -> RegistryService

Return the plugin registry bound to this context.

pub fn logger(&self) -> Logger

Return a logger named from the current fiber and intercepts.

pub fn named_logger(&self, name: impl Into<String>) -> Logger

Return an explicitly named logger.

pub fn logger_service(&self) -> LoggerService

Return the logger service bound to this context.

pub fn effect<F>( &self, label: impl Into<String>, dispose: F, ) -> Result<EffectHandle>

where F: FnOnce() -> Result<()> + Send + 'static,

Register a synchronous cleanup operation on the current fiber.

pub fn effect_infallible<F>( &self, label: impl Into<String>, dispose: F, ) -> Result<EffectHandle>

where F: FnOnce() + Send + 'static,

Register an infallible synchronous cleanup operation.

pub fn effect_async<F, Fut>( &self, label: impl Into<String>, dispose: F, ) -> Result<EffectHandle>

where F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Register an asynchronous cleanup operation.

pub fn provide<T>( &self, name: impl Into<String>, value: T, ) -> Result<EffectHandle>

where T: Send + Sync + 'static,

Provide a concrete service in this context’s isolation scope.

pub fn provide_arc<T>( &self, name: impl Into<String>, value: Arc<T>, ) -> Result<EffectHandle>

where T: Send + Sync + 'static,

Provide an existing Arc without wrapping it in a second Arc.

pub fn get<T>(&self, name: &str) -> Result<Option<Arc<T>>>

where T: Send + Sync + 'static,

Read a service without enforcing an inject declaration.

pub fn get_unchecked<T>(&self, name: &str) -> Result<Option<Arc<T>>>

where T: Send + Sync + 'static,

Read a service even while its provider is loading or unloading.

pub fn require<T>(&self, name: &str) -> Result<Arc<T>>

where T: Send + Sync + 'static,

Require a currently active service.

pub fn set<T>(&self, name: &str, value: T) -> Result<()>

where T: Send + Sync + 'static,

Replace a service value. Only its providing fiber may do this.

pub fn notify<I, S>(&self, names: I) -> Vec<Fiber>

where I: IntoIterator<Item = S>, S: AsRef<str>,

Re-evaluate dependency availability for the named services.

pub fn accessor( &self, name: impl Into<String>, accessor: Accessor, ) -> Result<EffectHandle>

Register a dynamic computed property.

pub fn on<F>( &self, name: impl Into<String>, listener: F, ) -> Result<EffectHandle>

where F: Fn(Event) -> EventResult + Send + Sync + 'static,

Register an event listener owned by this context’s fiber.

pub fn on_with<F>( &self, name: impl Into<String>, listener: F, options: EventOptions, ) -> Result<EffectHandle>

where F: Fn(Event) -> EventResult + Send + Sync + 'static,

Register a listener with placement and filtering options.

pub fn on_async<F, Fut>( &self, name: impl Into<String>, listener: F, ) -> Result<EffectHandle>

where F: Fn(Event) -> Fut + Send + Sync + 'static, Fut: Future<Output = EventResult> + Send + 'static,

Register an asynchronous event listener.

pub fn once<F>( &self, name: impl Into<String>, listener: F, ) -> Result<EffectHandle>

where F: Fn(Event) -> EventResult + Send + Sync + 'static,

Register a one-shot event listener.

pub fn emit( &self, name: impl Into<String>, args: impl IntoIterator<Item = EventValue>, ) -> Result<()>

Emit an event synchronously.

pub async fn parallel( &self, name: impl Into<String>, args: impl IntoIterator<Item = EventValue>, ) -> Result<()>

Run all matching listeners concurrently.

pub async fn serial( &self, name: impl Into<String>, args: impl IntoIterator<Item = EventValue>, ) -> EventResult

Await listeners in order until one returns a bail value.

pub fn bail( &self, name: impl Into<String>, args: impl IntoIterator<Item = EventValue>, ) -> EventResult

Run listeners synchronously until one returns a bail value.

pub fn waterfall<F>( &self, name: impl Into<String>, args: impl IntoIterator<Item = EventValue>, inner: F, ) -> EventResult

where F: Fn() -> EventResult + Send + Sync + 'static,

Compose listeners around an innermost synchronous callback.

pub fn plugin<P, C>(&self, plugin: P, config: C) -> Fiber

where P: IntoPlugin, C: Send + Sync + 'static,

Start a plugin and return its lifecycle fiber.

pub fn plugin_default<P>(&self, plugin: P) -> Fiber

where P: IntoPlugin,

Start a plugin with unit configuration.

pub fn plugin_object<P, C>(&self, plugin: P, config: C) -> Fiber

where P: Plugin, C: Send + Sync + 'static,

Wrap and start a concrete Plugin implementation.

pub fn plugin_object_default<P>(&self, plugin: P) -> Fiber

where P: Plugin,

Start a concrete plugin implementation with unit configuration.

pub fn inject<F>(&self, inject: Inject, callback: F) -> Fiber

where F: Fn(Context) -> Result<PluginOutput> + Send + Sync + 'static,

Start an inline callback after all listed services become available.

pub fn log_error(&self, error: impl ToString)

Log an error through the current context logger.

impl Context

pub fn provide_service<S>(&self, service: S) -> Result<EffectHandle>

where S: Service,

Provide a typed service under Service::NAME.

pub fn provide_service_arc<S>(&self, service: Arc<S>) -> Result<EffectHandle>

where S: Service,

Provide an existing shared typed service.

pub fn resolve_service_config<T, F>( &self, name: &str, base: T, merge: F, ) -> Result<T>

where T: Send + Sync + 'static, F: FnMut(T, &T) -> T,

Resolve service intercepts from root to leaf with a caller-supplied merge operation.

Trait Implementations

impl Clone for Context

fn clone(&self) -> Context

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Context

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Context

fn default() -> Self

Returns the “default value” for a type.