Struct DataverseSourceBuilder 

pub struct DataverseSourceBuilder { /* private fields */ }

Builder for DataverseSource instances.

Provides a fluent API for constructing Dataverse sources with sensible defaults. The builder takes the source ID at construction and returns a fully constructed DataverseSource from build().

Example

let source = DataverseSource::builder("dv-source")
    .with_environment_url("https://myorg.crm.dynamics.com")
    .with_tenant_id("tenant-id")
    .with_client_id("client-id")
    .with_client_secret("client-secret")
    .with_entities(vec!["account".to_string()])
    .build()?;

Implementations

impl DataverseSourceBuilder

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

Create a new builder with the given source ID.

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

Set the Dataverse environment URL.

pub fn with_tenant_id(self, tenant_id: impl Into<String>) -> Self

Set the Azure AD tenant ID.

pub fn with_client_id(self, client_id: impl Into<String>) -> Self

Set the Azure AD client ID.

pub fn with_client_secret(self, client_secret: impl Into<String>) -> Self

Set the Azure AD client secret.

pub fn with_identity_provider( self, provider: impl IdentityProvider + 'static, ) -> Self

Set an identity provider for token acquisition.

When an identity provider is set, it takes precedence over tenant_id/client_id/client_secret. The provider’s get_credentials() must return Credentials::Token.

This enables using any of the platform’s identity providers, including:

• AzureIdentityProvider::with_client_secret(...) for client credentials
• AzureIdentityProvider::with_default_credentials(...) for managed identity
• AzureIdentityProvider::with_developer_tools(...) for local dev (CLI, azd, PS)
• AzureIdentityProvider::with_workload_identity(...) for Kubernetes workloads

Example

use drasi_lib::identity::AzureIdentityProvider;
use drasi_source_dataverse::DataverseSource;

let provider = AzureIdentityProvider::with_client_secret(
    "tenant-id", "client-id", "client-secret", "dataverse",
)?
.with_scope("https://myorg.crm.dynamics.com/.default");

let source = DataverseSource::builder("dv-source")
    .with_environment_url("https://myorg.crm.dynamics.com")
    .with_entities(vec!["account".to_string()])
    .with_identity_provider(provider)
    .build()?;

pub fn with_entities(self, entities: Vec<String>) -> Self

Set the list of entity logical names to monitor.

pub fn with_entity(self, entity: impl Into<String>) -> Self

Add a single entity to monitor.

pub fn with_entity_set_override( self, entity_name: impl Into<String>, entity_set_name: impl Into<String>, ) -> Self

Override the entity set name for a specific entity.

pub fn with_entity_columns( self, entity: impl Into<String>, columns: Vec<String>, ) -> Self

Set column selection for a specific entity.

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

Set the minimum adaptive polling interval in milliseconds.

pub fn with_max_interval_seconds(self, seconds: u64) -> Self

Set the maximum adaptive polling interval in seconds.

pub fn with_api_version(self, version: impl Into<String>) -> Self

Set the Dataverse Web API version.

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

Set the dispatch mode.

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

Set the dispatch buffer capacity.

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

Set the bootstrap provider for initial data delivery.

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

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

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

Build the DataverseSource instance.