Struct ArmClient 

pub struct ArmClient { /* private fields */ }

Azure Resource Manager client for subscription/service discovery

Implementations

impl ArmClient

pub fn new() -> Result<Self, ClientError>

Create a new ARM client using Azure CLI credentials

pub async fn get_resource_identity( &self, resource_id: &str, api_version: &str, ) -> Result<Option<ResourceIdentity>, ClientError>

Read a resource’s managed identity block: GET {id}?api-version=....

pub async fn list_role_assignments( &self, scope: &str, principal_id: &str, ) -> Result<Vec<String>, ClientError>

Role definition IDs assigned to principal_id at (or inherited by) scope.

pub async fn create_role_assignment( &self, scope: &str, principal_id: &str, role_definition_guid: &str, ) -> Result<(), ClientError>

Create a role assignment for a principal at a scope.

pub async fn enable_system_identity( &self, resource_id: &str, api_version: &str, ) -> Result<(), ClientError>

Enable a system-assigned managed identity on a resource (PATCH).

pub async fn find_search_service_id( &self, name: &str, ) -> Result<String, ClientError>

Find the full ARM resource id of a search service by name.

pub fn token(&self) -> &str

The ARM bearer token this client authenticated with.

pub async fn list_subscriptions(&self) -> Result<Vec<Subscription>, ClientError>

List subscriptions the user has access to

pub async fn list_search_services( &self, subscription_id: &str, ) -> Result<Vec<SearchService>, ClientError>

List Azure AI Search services in a subscription

pub async fn find_resource_group( &self, subscription_id: &str, service_name: &str, ) -> Result<String, ClientError>

Find the resource group of a search service by scanning the subscription.

Returns the resource group name extracted from the service’s ARM resource ID.

pub async fn list_ai_services_accounts( &self, subscription_id: &str, ) -> Result<Vec<AiServicesAccount>, ClientError>

List Azure AI Services accounts in a subscription (filtered to kind=AIServices)

pub async fn find_cognitive_account_id( &self, name: &str, ) -> Result<String, ClientError>

Find the ARM resource id of ANY Microsoft.CognitiveServices account by name — regardless of kind (AIServices, CognitiveServices, OpenAI, …). Unlike Self::list_ai_services_accounts (which serves Foundry discovery and filters to kind AIServices), this covers e.g. the plain CognitiveServices accounts skillsets use for enrichment.

pub async fn list_foundry_projects( &self, account: &AiServicesAccount, subscription_id: &str, ) -> Result<Vec<FoundryProject>, ClientError>

List Microsoft Foundry projects under a specific AI Services account.

Projects are sub-resources at: Microsoft.CognitiveServices/accounts/{accountName}/projects

The account_id should be the full ARM resource ID of the account, from which we extract the resource group.

pub async fn list_storage_accounts( &self, subscription_id: &str, resource_group: &str, ) -> Result<Vec<StorageAccount>, ClientError>

List storage accounts in a resource group.

pub async fn list_storage_accounts_subscription( &self, subscription_id: &str, ) -> Result<Vec<StorageAccount>, ClientError>

List storage accounts across a whole subscription.

pub async fn storage_account_has_container( &self, account_id: &str, container: &str, ) -> Result<bool, ClientError>

Whether a storage account contains a blob container with this name (checked via ARM with the caller’s CLI token — no data-plane access or account keys involved).

pub async fn find_storage_accounts_with_container( &self, container: &str, ) -> Result<Vec<StorageAccount>, ClientError>

Find every storage account (across all visible subscriptions) that holds a blob container named container. Used to auto-construct identity-based ResourceId= data-source connections — the user is already logged in via Azure CLI, so rigg discovers instead of asking. Accounts that fail the container check (e.g. insufficient RBAC on an unrelated subscription) are skipped, not fatal.

pub async fn get_storage_account_key( &self, subscription_id: &str, resource_group: &str, account_name: &str, ) -> Result<String, ClientError>

Get the primary access key for a storage account.

pub async fn list_model_deployments( &self, account: &AiServicesAccount, subscription_id: &str, ) -> Result<Vec<ModelDeployment>, ClientError>

List model deployments for an AI Services account.

pub async fn create_model_deployment( &self, account: &AiServicesAccount, subscription_id: &str, deployment_name: &str, model_name: &str, model_version: &str, ) -> Result<(), ClientError>

Create a model deployment on an AI Services account.

pub async fn get_storage_connection_string( &self, subscription_id: &str, resource_group: &str, account_name: &str, ) -> Result<String, ClientError>

Build a full connection string for a storage account.