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, supervisor_handle: SupervisorHandle, ) -> 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

Gets a reference to the topology context.

pub fn component_context(&self) -> &ComponentContext

Gets a reference to the component context.

pub fn component_registry(&self) -> &ComponentRegistry

Gets a reference to the component registry.

pub fn dispatcher(&self) -> &EventsDispatcher

Gets a reference to the events dispatcher.

pub fn spawn_handle(&self) -> &SupervisorHandle

Returns a handle to the supervisor that this component is spawned on.

Dynamic child processes can be spawned via the supervisor handle and thus have their lifecycle coupled to the component itself: if the component restarts, or the component’s supervisor dies, the dynamic child processes will also be terminated automatically as well.

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.