Struct GrpcSource 

pub struct GrpcSource { /* private fields */ }

gRPC source that exposes a gRPC endpoint to receive SourceChangeEvents.

This source implements a gRPC service for receiving data change events from external systems. It supports both unary and streaming RPC methods for event submission.

Fields

• base: Common source functionality (dispatchers, status, lifecycle)
• config: gRPC-specific configuration (host, port, timeout)

Implementations

impl GrpcSource

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

Create a builder for GrpcSource

Example

use drasi_source_grpc::GrpcSource;

let source = GrpcSource::builder("my-grpc-source")
    .with_host("0.0.0.0")
    .with_port(50051)
    .with_bootstrap_provider(my_provider)
    .build()?;

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

Create a new gRPC 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 - gRPC source configuration

Returns

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

Errors

Returns an error if the base source cannot be initialized.

Example

use drasi_source_grpc::{GrpcSource, GrpcSourceConfig};

let config = GrpcSourceConfig {
    host: "0.0.0.0".to_string(),
    port: 50051,
    endpoint: None,
    timeout_ms: 5000,
};

let source = GrpcSource::new("my-grpc-source", config)?;

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

Create a new gRPC source with custom dispatch settings

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

Trait Implementations

impl Source for GrpcSource

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 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.