Struct QueryRuntime 

pub struct QueryRuntime {
    pub id: String,
    pub query: String,
    pub status: ComponentStatus,
    pub error_message: Option<String>,
    pub source_subscriptions: Vec<SourceSubscriptionConfig>,
    pub joins: Option<Vec<QueryJoinConfig>>,
}

Runtime representation of a query with execution status

QueryRuntime combines query configuration with runtime state information. Used for monitoring query execution, tracking which sources it subscribes to, and inspecting any runtime errors.

Status Values

• ComponentStatus::Stopped: Query is configured but not processing
• ComponentStatus::Starting: Query is initializing (bootstrap phase)
• ComponentStatus::Running: Query is actively processing events
• ComponentStatus::Error: Query 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 query
let query_info = core.get_query_info("active_orders").await?;
println!("Query: {}", query_info.query);
println!("Status: {:?}", query_info.status);
println!("Source subscriptions: {:?}", query_info.source_subscriptions);

if let Some(joins) = query_info.joins {
    println!("Synthetic joins configured: {}", joins.len());
}

Fields

id: String

Unique identifier for the query

query: String

Cypher or GQL query string

status: ComponentStatus

Current status of the query

error_message: Option<String>

Error message if status is Error

source_subscriptions: Vec<SourceSubscriptionConfig>

Source subscriptions with middleware pipelines

joins: Option<Vec<QueryJoinConfig>>

Optional synthetic joins for the query

Trait Implementations

impl Clone for QueryRuntime

fn clone(&self) -> QueryRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueryRuntime

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for QueryRuntime

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<QueryConfig> for QueryRuntime

fn from(config: QueryConfig) -> Self

Converts to this type from the input type.

impl Serialize for QueryRuntime

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

where __S: Serializer,

Serialize this value into the given Serde serializer.