in azure-kusto-ingest/src/resource_manager/ingest_client_resources.rs [90:107]
fn try_from(
(table, client_options): (&TableV1, &QueuedIngestClientOptions),
) -> std::result::Result<Self, Self::Error> {
let secured_ready_for_aggregation_queues =
get_resource_by_name(table, "SecuredReadyForAggregationQueue".to_string())?;
let temp_storage = get_resource_by_name(table, "TempStorage".to_string())?;
Ok(Self {
ingestion_queues: create_clients_vec(
&secured_ready_for_aggregation_queues,
&client_options.queue_service_options,
),
temp_storage_containers: create_clients_vec(
&temp_storage,
&client_options.blob_service_options,
),
})
}