Struct CosmosDBClient 

pub struct CosmosDBClient { /* private fields */ }

Low-level CosmosDB REST API client. Wraps reqwest and handles auth headers, serialization, and error mapping.

Implementations

impl CosmosDBClient

pub fn new( endpoint: &str, key: &str, database: &str, container: &str, ) -> Result<Self, String>

pub fn endpoint(&self) -> &str

pub fn database(&self) -> &str

pub fn container(&self) -> &str

pub async fn ensure_database(&self) -> Result<(), ProviderError>

Create database if it doesn’t exist.

pub async fn ensure_container( &self, indexing_policy: Option<Value>, ) -> Result<(), ProviderError>

Create container if it doesn’t exist.

pub async fn delete_container(&self) -> Result<(), ProviderError>

Delete container.

pub async fn create_document( &self, partition_key: &str, document: &Value, ) -> Result<CosmosDBResponse, ProviderError>

Create a document. Returns the response with the created document.

pub async fn upsert_document( &self, partition_key: &str, document: &Value, ) -> Result<CosmosDBResponse, ProviderError>

Upsert a document (create or replace).

pub async fn read_document( &self, doc_id: &str, partition_key: &str, ) -> Result<CosmosDBResponse, ProviderError>

Read a document by ID.

pub async fn replace_document( &self, doc_id: &str, partition_key: &str, document: &Value, if_match: Option<&str>, ) -> Result<CosmosDBResponse, ProviderError>

Replace a document by ID with optional ETag condition.

pub async fn delete_document( &self, doc_id: &str, partition_key: &str, ) -> Result<CosmosDBResponse, ProviderError>

Delete a document by ID.

pub async fn query( &self, sql: &str, parameters: Vec<QueryParameter>, partition_key: Option<&str>, ) -> Result<Vec<Value>, ProviderError>

Execute a SQL query. If partition_key is None, this is a cross-partition query.

pub async fn transactional_batch( &self, partition_key: &str, operations: Vec<BatchOperation>, ) -> Result<Vec<BatchOperationResult>, ProviderError>

Execute a transactional batch of operations within a single partition.

Trait Implementations

impl Clone for CosmosDBClient

fn clone(&self) -> CosmosDBClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.