Struct PlatformSourceBuilder 

pub struct PlatformSourceBuilder { /* private fields */ }

Builder for creating PlatformSource instances.

Provides a fluent API for constructing platform sources with sensible defaults.

Example

use drasi_source_platform::PlatformSource;

let source = PlatformSource::builder("my-platform-source")
    .with_redis_url("redis://localhost:6379")
    .with_stream_key("my-app-changes")
    .with_consumer_group("my-consumers")
    .with_batch_size(50)
    .build()?;

Implementations

impl PlatformSourceBuilder

pub fn new(id: impl Into<String>) -> Self

Create a new builder with the given ID and default values.

pub fn with_redis_url(self, url: impl Into<String>) -> Self

Set the Redis connection URL.

Arguments

• url - Redis connection URL (e.g., redis://localhost:6379)

pub fn with_stream_key(self, key: impl Into<String>) -> Self

Set the Redis stream key to consume from.

Arguments

• key - Name of the Redis stream

pub fn with_consumer_group(self, group: impl Into<String>) -> Self

Set the consumer group name.

Arguments

• group - Consumer group name (default: "drasi-core")

pub fn with_consumer_name(self, name: impl Into<String>) -> Self

Set a unique consumer name within the group.

Arguments

• name - Unique consumer name (auto-generated if not specified)

pub fn with_batch_size(self, size: usize) -> Self

Set the batch size for reading events.

Arguments

• size - Number of events to read per XREADGROUP call (default: 100)

pub fn with_block_ms(self, ms: u64) -> Self

Set the block timeout for waiting on events.

Arguments

• ms - Milliseconds to block waiting for events (default: 5000)

pub fn with_dispatch_mode(self, mode: DispatchMode) -> Self

Set the dispatch mode for this source

pub fn with_dispatch_buffer_capacity(self, capacity: usize) -> Self

Set the dispatch buffer capacity for this source

pub fn with_bootstrap_provider( self, provider: impl BootstrapProvider + 'static, ) -> Self

Set the bootstrap provider for this source

pub fn with_auto_start(self, auto_start: bool) -> Self

Set whether this source should auto-start when DrasiLib starts.

Default is true. Set to false if this source should only be started manually via start_source().

pub fn with_config(self, config: PlatformSourceConfig) -> Self

Set the full configuration at once

pub fn build(self) -> Result<PlatformSource>

Build the platform source.

Errors

Returns an error if the source cannot be constructed.