Struct DecoderContext 

pub struct DecoderContext { /* private fields */ }

Decoder context.

Implementations

impl DecoderContext

pub fn new( topology_context: &TopologyContext, component_context: &ComponentContext, component_registry: ComponentRegistry, health_handle: Health, dispatcher: EventsDispatcher, consumer: PayloadsConsumer, supervisor_handle: SupervisorHandle, ) -> Self

Creates a new DecoderContext.

pub fn take_health_handle(&mut self) -> Health

Consumes the health handle of this decoder 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(&mut self) -> &ComponentRegistry

Gets a reference to the component registry.

pub fn dispatcher(&self) -> &EventsDispatcher

Gets a reference to the events dispatcher.

pub fn payloads(&mut self) -> &mut PayloadsConsumer

Gets a mutable reference to the payloads consumer.

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.