Struct SourceRuntimeContext 

pub struct SourceRuntimeContext {
    pub source_id: String,
    pub status_tx: ComponentEventSender,
    pub state_store: Option<Arc<dyn StateStoreProvider>>,
}

Context provided to Source plugins during initialization.

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

Available Services

• source_id: The unique identifier for this source instance
• status_tx: Channel for reporting component status/lifecycle events
• state_store: Optional persistent state storage (if configured)

Clone

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

Fields

source_id: String

Unique identifier for this source 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. Sources can use this to persist state across restarts.

Implementations

impl SourceRuntimeContext

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

Create a new source runtime context.

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

Arguments

• source_id - The unique identifier for this source
• status_tx - Channel for reporting component status/lifecycle events
• state_store - Optional persistent state storage

pub fn source_id(&self) -> &str

Get the source’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.

Trait Implementations

impl Clone for SourceRuntimeContext

fn clone(&self) -> SourceRuntimeContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceRuntimeContext

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

Formats the value using the given formatter.