Struct ReactionRuntimeContext 

pub struct ReactionRuntimeContext {
    pub reaction_id: String,
    pub status_tx: ComponentEventSender,
    pub state_store: Option<Arc<dyn StateStoreProvider>>,
    pub query_provider: Arc<dyn QueryProvider>,
}

Context provided to Reaction plugins during initialization.

Contains Arc<T> instances for all drasi-lib provided services. DrasiLib constructs this context when a reaction is added via add_reaction().

Available Services

• reaction_id: The unique identifier for this reaction instance
• status_tx: Channel for reporting component status/lifecycle events
• state_store: Optional persistent state storage (if configured)
• query_provider: Access to query instances for subscription

Clone

This struct implements Clone and all fields use Arc internally, making cloning cheap (just reference count increments).

Fields

reaction_id: String

Unique identifier for this reaction instance

status_tx: ComponentEventSender

Channel for reporting component status/lifecycle events.

Use this to send status updates (Starting, Running, Stopped, Error) back to DrasiLib for monitoring and lifecycle management.

state_store: Option<Arc<dyn StateStoreProvider>>

Optional persistent state storage.

This is Some if a state store provider was configured on DrasiLib, otherwise None. Reactions can use this to persist state across restarts.

query_provider: Arc<dyn QueryProvider>

Access to query instances for subscription.

Reactions use this to get query instances and subscribe to their results. This is always available (not optional) since reactions require queries.

Implementations

impl ReactionRuntimeContext

pub fn new( reaction_id: impl Into<String>, status_tx: ComponentEventSender, state_store: Option<Arc<dyn StateStoreProvider>>, query_provider: Arc<dyn QueryProvider>, ) -> Self

Create a new reaction runtime context.

This is typically called by ReactionManager when adding a reaction to DrasiLib. Plugin developers do not need to call this directly.

Arguments

• reaction_id - The unique identifier for this reaction
• status_tx - Channel for reporting component status/lifecycle events
• state_store - Optional persistent state storage
• query_provider - Access to query instances for subscription

pub fn reaction_id(&self) -> &str

Get the reaction’s unique identifier.

pub fn status_tx(&self) -> &ComponentEventSender

Get a reference to the status channel.

Use this to send component status updates (Starting, Running, Stopped, Error) back to DrasiLib.

pub fn state_store(&self) -> Option<&Arc<dyn StateStoreProvider>>

Get a reference to the state store if configured.

Returns Some(&Arc<dyn StateStoreProvider>) if a state store was configured, otherwise None.

pub fn query_provider(&self) -> &Arc<dyn QueryProvider>

Get a reference to the query provider.

Use this to get query instances and subscribe to their results.

Trait Implementations

impl Clone for ReactionRuntimeContext

fn clone(&self) -> ReactionRuntimeContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReactionRuntimeContext

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

Formats the value using the given formatter.