Struct ApplicationSource 

pub struct ApplicationSource { /* private fields */ }

A source that allows applications to programmatically inject events.

This source receives events from an ApplicationSourceHandle and forwards them to the Drasi query processing pipeline.

Fields

• base: Common source functionality (dispatchers, status, lifecycle, bootstrap)
• config: Application source configuration
• app_rx: Receiver for events from the handle
• app_tx: Sender for creating additional handles

Implementations

impl ApplicationSource

pub fn new( id: impl Into<String>, config: ApplicationSourceConfig, ) -> Result<(Self, ApplicationSourceHandle)>

Create a new application source and its handle.

The event channel is automatically injected when the source is added to DrasiLib via add_source().

Arguments

• id - Unique identifier for this source instance
• config - Application source configuration

Returns

A tuple of (ApplicationSource, ApplicationSourceHandle) where the handle can be used to send events to the source.

Errors

Returns an error if the base source cannot be initialized.

Example

use drasi_source_application::{ApplicationSource, ApplicationSourceConfig};

let config = ApplicationSourceConfig::default();
let (source, handle) = ApplicationSource::new("my-source", config)?;

pub fn get_handle(&self) -> ApplicationSourceHandle

Get a new handle for this source

Trait Implementations

impl Source for ApplicationSource

fn id(&self) -> &str

Get the source’s unique identifier

fn type_name(&self) -> &str

Get the source type name (e.g., “postgres”, “http”, “mock”)

fn properties(&self) -> HashMap<String, Value>

Get the source’s configuration properties for inspection

fn auto_start(&self) -> bool

Whether this source should auto-start when DrasiLib starts

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start the source

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop the source

fn status<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ComponentStatus> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the current status of the source

fn subscribe<'life0, 'async_trait>( &'life0 self, settings: SourceSubscriptionSettings, ) -> Pin<Box<dyn Future<Output = Result<SubscriptionResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Subscribe to this source for change events

fn as_any(&self) -> &dyn Any

Downcast helper for testing - allows access to concrete types

fn initialize<'life0, 'async_trait>( &'life0 self, context: SourceRuntimeContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initialize the source with runtime context.

fn set_bootstrap_provider<'life0, 'async_trait>( &'life0 self, provider: Box<dyn BootstrapProvider + 'static>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Set the bootstrap provider for this source

fn dispatch_mode(&self) -> DispatchMode

Get the dispatch mode for this source (Channel or Broadcast)

fn deprovision<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Permanently clean up internal state when the source is being removed.