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

The handle shares the WAL reference with the source, so handles obtained before or after start() will automatically use WAL when durability is enabled.

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>

Return all configuration properties for this source, including secrets.

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 supports_replay(&self) -> bool

Whether this source supports positional replay via resume_from.

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

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

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

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 describe_schema(&self) -> Option<SourceSchema>

Describe the graph schema this source provides, if known.

fn remove_position_handle<'life0, 'life1, 'async_trait>( &'life0 self, _query_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Release the position handle that a query was holding on this source.

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

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

Signal that the initial batch of query subscriptions is complete.

fn set_identity_provider<'life0, 'async_trait>( &'life0 self, _provider: Arc<dyn IdentityProvider>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Set the identity provider for this source.