Struct HttpSource 

pub struct HttpSource { /* private fields */ }

HTTP source with configurable adaptive batching.

This source exposes HTTP endpoints for receiving data change events. It supports both single-event and batch submission modes, with adaptive batching for optimized throughput.

Fields

• base: Common source functionality (dispatchers, status, lifecycle)
• config: HTTP-specific configuration (host, port, timeout)
• adaptive_config: Adaptive batching settings for throughput optimization

Implementations

impl HttpSource

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

Create a new HTTP source.

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 - HTTP source configuration

Returns

A new HttpSource instance, or an error if construction fails.

Errors

Returns an error if the base source cannot be initialized.

Example

use drasi_source_http::{HttpSource, HttpSourceBuilder};

let config = HttpSourceBuilder::new()
    .with_host("0.0.0.0")
    .with_port(8080)
    .build();

let source = HttpSource::new("my-http-source", config)?;

pub fn with_dispatch( id: impl Into<String>, config: HttpSourceConfig, dispatch_mode: Option<DispatchMode>, dispatch_buffer_capacity: Option<usize>, ) -> Result<Self>

Create a new HTTP source with custom dispatch settings.

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 - HTTP source configuration
• dispatch_mode - Optional dispatch mode (Channel, Direct, etc.)
• dispatch_buffer_capacity - Optional buffer capacity for channel dispatch

Returns

A new HttpSource instance with custom dispatch settings.

Errors

Returns an error if the base source cannot be initialized.

impl HttpSource

pub fn builder(id: impl Into<String>) -> HttpSourceBuilder

Create a builder for HttpSource with the given ID.

This is the recommended way to construct an HttpSource.

Arguments

• id - Unique identifier for the source instance

Example

let source = HttpSource::builder("my-source")
    .with_host("0.0.0.0")
    .with_port(8080)
    .with_bootstrap_provider(my_provider)
    .build()?;

Trait Implementations

impl Source for HttpSource

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 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 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<(), Error>> + Send + 'async_trait>>

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

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