Struct DataverseSourceConfig 

pub struct DataverseSourceConfig {
    pub environment_url: String,
    pub tenant_id: String,
    pub client_id: String,
    pub client_secret: String,
    pub use_azure_cli: bool,
    pub entities: Vec<String>,
    pub entity_set_overrides: HashMap<String, String>,
    pub entity_columns: HashMap<String, Vec<String>>,
    pub min_interval_ms: u64,
    pub max_interval_seconds: u64,
    pub api_version: String,
}

Configuration for the Dataverse replication source.

Mirrors the platform Dataverse source configuration which uses RetrieveEntityChangesRequest for change tracking. In the Rust/Web API implementation, this is achieved via OData change tracking with Prefer: odata.track-changes headers and delta links.

Required Configuration

• environment_url: The Dataverse environment URL (e.g., https://myorg.crm.dynamics.com)
• entities: List of entity logical names to monitor (e.g., ["account", "contact"])
• Authentication (one of):
  • Identity provider via [DataverseSource::builder] .with_identity_provider() (recommended)
  • tenant_id + client_id + client_secret for client credentials flow
  • use_azure_cli = true for Azure CLI authentication (local dev)

Optional Configuration

• entity_set_overrides: Override computed entity set names for specific entities
• min_interval_ms: Minimum adaptive polling interval (default: 500)
• max_interval_seconds: Maximum adaptive polling interval (default: 30)
• api_version: Dataverse Web API version (default: v9.2)

Fields

environment_url: String

Dataverse environment URL (e.g., https://myorg.crm.dynamics.com).

tenant_id: String

Azure AD / Microsoft Entra ID tenant ID for OAuth2 authentication. Required for client credentials flow, ignored when use_azure_cli is true.

client_id: String

Azure AD application (client) ID. Required for client credentials flow, ignored when use_azure_cli is true.

client_secret: String

Azure AD client secret for OAuth2 client credentials flow. Required for client credentials flow, ignored when use_azure_cli is true.

use_azure_cli: bool

Use Azure CLI (az account get-access-token) for authentication. When true, tenant_id, client_id, and client_secret are not required. Requires az login to have been run beforehand.

entities: Vec<String>

List of entity logical names to monitor (e.g., ["account", "contact"]). These are the singular logical names matching the platform’s RetrieveEntityChangesRequest.EntityName parameter.

entity_set_overrides: HashMap<String, String>

Override the entity set name (Web API plural form) for specific entities. By default, entity set names are derived by appending ‘s’ to the logical name. Use this for entities with non-standard pluralization.

Example: {"activityparty": "activityparties"}

entity_columns: HashMap<String, Vec<String>>

Per-entity column selection. If an entity is not in this map, all columns are retrieved (equivalent to ColumnSet(true) in the SDK).

min_interval_ms: u64

Minimum adaptive polling interval in milliseconds (default: 500). Matches the platform’s MinIntervalMs = 500.

max_interval_seconds: u64

Maximum adaptive polling interval per entity in seconds (default: 30). This is the single-entity base value, matching the platform’s SingleEntityMaxIntervalMs / 1000. At startup, the effective max is scaled by sqrt(entity_count) (e.g., 1 entity → 30s, 5 → 67s, 10 → 95s).

api_version: String

Dataverse Web API version (default: v9.2).

Implementations

impl DataverseSourceConfig

pub fn validate(&self) -> Result<(), String>

Validate the configuration, returning an error if required fields are missing.

pub fn validate_with_identity_provider(&self) -> Result<(), String>

Validate config when an external identity provider handles authentication.

Only checks that environment_url and entities are set — credential fields (tenant_id, client_id, client_secret) are not required because the identity provider supplies tokens directly.

pub fn entity_set_name(&self, entity: &str) -> String

Get the entity set name (plural form) for a given entity logical name.

First checks entity_set_overrides, then falls back to appending ‘s’. This mirrors how the platform’s RetrieveEntityChangesRequest uses entity logical names but the Web API requires entity set names.

pub fn select_columns(&self, entity: &str) -> Option<String>

Get the $select clause for a given entity, or None for all columns.

Ensures that the primary key column ({entity}id) is always included when a column list is configured, to keep change tracking and bootstrap logic functional.

Trait Implementations

impl Clone for DataverseSourceConfig

fn clone(&self) -> DataverseSourceConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DataverseSourceConfig

Manual Debug implementation that redacts client_secret so it cannot leak through tracing, panic messages, or any {:?} formatting.

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.