Struct ReactionRuntime 

pub struct ReactionRuntime {
    pub id: String,
    pub reaction_type: String,
    pub status: ComponentStatus,
    pub error_message: Option<String>,
    pub queries: Vec<String>,
    pub properties: HashMap<String, Value>,
}

Runtime representation of a reaction with execution status

ReactionRuntime combines reaction configuration with runtime state information. Used for monitoring reaction execution, tracking which queries it subscribes to, and inspecting delivery status.

Status Values

• ComponentStatus::Stopped: Reaction is configured but not running
• ComponentStatus::Starting: Reaction is initializing connections
• ComponentStatus::Running: Reaction is actively delivering results
• ComponentStatus::Error: Reaction encountered an error (see error_message)

Examples

use drasi_lib::{DrasiLib, ComponentStatus};

let core = DrasiLib::builder().with_id("my-server").build().await?;
core.start().await?;

// Get runtime information for a reaction
let reaction_info = core.get_reaction_info("order_webhook").await?;
println!("Reaction {} ({}) is {:?}",
    reaction_info.id,
    reaction_info.reaction_type,
    reaction_info.status
);
println!("Subscribed to queries: {:?}", reaction_info.queries);

if let Some(error) = reaction_info.error_message {
    eprintln!("Reaction error: {}", error);
}

Fields

id: String

Unique identifier for the reaction

reaction_type: String

Type of reaction (e.g., “log”, “http”, “grpc”, “sse”, “platform”)

status: ComponentStatus

Current status of the reaction

error_message: Option<String>

Error message if status is Error

queries: Vec<String>

IDs of queries this reaction subscribes to

properties: HashMap<String, Value>

Reaction-specific configuration properties

Trait Implementations

impl Clone for ReactionRuntime

fn clone(&self) -> ReactionRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReactionRuntime

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ReactionRuntime

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ReactionRuntime

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.