Struct SourceContext 

pub struct SourceContext { /* private fields */ }

Source context.

Implementations

impl SourceContext

pub fn new( topology_context: &TopologyContext, component_context: &ComponentContext, component_registry: ComponentRegistry, health_handle: Health, dispatcher: EventsDispatcher, spawner: ComponentSpawner, ) -> Self

Creates a new SourceContext.

pub fn take_shutdown_handle(&mut self) -> ShutdownHandle

Consumes the shutdown handle of this source context.

Panics

Panics if the shutdown handle has already been taken.

pub fn take_health_handle(&mut self) -> Health

Consumes the health handle of this source context.

Panics

Panics if the health handle has already been taken.

pub fn topology_context(&self) -> &TopologyContext

Returns a reference to the topology context.

pub fn component_context(&self) -> &ComponentContext

Returns a reference to the component context.

pub fn component_registry(&self) -> &ComponentRegistry

Returns a reference to the component registry.

pub fn dispatcher(&self) -> &EventsDispatcher

Returns a reference to the events dispatcher.

pub fn spawner(&self) -> &ComponentSpawner

Returns a spawner for supervised child tasks belonging to this component.

All child tasks spawned through this mechanism are tied to the lifecycle of the component itself, such that they’re automatically shutdown/stopped when the component is stopped during topology shutdown, etc.

Trait Implementations

impl Clone for SourceContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.