Struct SourceRuntime 

pub struct SourceRuntime {
    pub id: String,
    pub source_type: String,
    pub status: ComponentStatus,
    pub error_message: Option<String>,
    pub properties: HashMap<String, Value>,
}

Runtime representation of a source with execution status

SourceRuntime combines configuration with runtime state information like current execution status and error messages. It’s used for monitoring and managing source lifecycle.

Status Values

• ComponentStatus::Stopped: Source is configured but not running
• ComponentStatus::Starting: Source is initializing
• ComponentStatus::Running: Source is actively ingesting data
• ComponentStatus::Error: Source encountered an error (see error_message)

Thread Safety

This struct is Clone and Serialize for sharing across threads and APIs.

Examples

use drasi_lib::{DrasiLib, ComponentStatus};

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

// Get runtime information for a source
let source_info = core.get_source_info("orders_db").await?;
println!("Source {} is {:?}", source_info.id, source_info.status);

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

Fields

id: String

Unique identifier for the source

source_type: String

Type of source (e.g., “postgres”, “http”, “mock”, “platform”)

status: ComponentStatus

Current status of the source

error_message: Option<String>

Error message if status is Error

properties: HashMap<String, Value>

Source-specific configuration properties

Trait Implementations

impl Clone for SourceRuntime

fn clone(&self) -> SourceRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceRuntime

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SourceRuntime

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SourceRuntime

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

where __S: Serializer,

Serialize this value into the given Serde serializer.