Struct azure_cosmos_sdk::client::Client

pub struct Client { /* fields omitted */ }

Methods

impl<'a> Client

fn new(
    handle: &Handle,
    authorization_token: AuthorizationToken
) -> Result<Client, Error>

fn set_authorization_token(&mut self, at: AuthorizationToken)

fn list_databases(
    &self
) -> impl Future<Item = Vec<Database>, Error = AzureError>

Returns database list associated to the account specified in the azure_sdk_for_rust::azure::cosmos::authorization_token::AuthorizationToken.

fn list_collections(
    &self,
    database_name: &str
) -> impl Future<Item = Vec<Collection>, Error = AzureError>

fn create_database(
    &self,
    database_name: &str
) -> impl Future<Item = Database, Error = AzureError>

fn get_database(
    &self,
    database_name: &str
) -> impl Future<Item = Database, Error = AzureError>

fn delete_database(
    &self,
    database_name: &str
) -> impl Future<Item = (), Error = AzureError>

fn get_collection(
    &self,
    database_name: &str,
    collection_name: &str
) -> impl Future<Item = Collection, Error = AzureError>

fn create_collection(
    &self,
    database_name: &str,
    required_throughput: u64,
    collection: &Collection
) -> impl Future<Item = Collection, Error = AzureError>

fn delete_collection(
    &self,
    database_name: &str,
    collection_name: &str
) -> impl Future<Item = (), Error = AzureError>

fn replace_collection(
    &self,
    database_name: &str,
    collection: &str
) -> impl Future<Item = Collection, Error = AzureError>

fn create_document_as_str<T, S1, S2, S3>(
    &self,
    database: S1,
    collection: S2,
    is_upsert: bool,
    indexing_directive: Option<IndexingDirective>,
    partition_key: &PartitionKey,
    document_str: S3
) -> impl Future<Item = DocumentAttributes, Error = AzureError> where
    T: Serialize,
    S1: AsRef<str>,
    S2: AsRef<str>,
    S3: AsRef<str>, 

fn create_document_as_entity<T, S1, S2>(
    &self,
    database: S1,
    collection: S2,
    is_upsert: bool,
    indexing_directive: Option<IndexingDirective>,
    partition_key: &PartitionKey,
    document: &T
) -> impl Future<Item = DocumentAttributes, Error = AzureError> where
    T: Serialize,
    S1: AsRef<str>,
    S2: AsRef<str>, 

fn list_documents<S1, S2, T>(
    &self,
    database: S1,
    collection: S2,
    ldo: &ListDocumentsOptions
) -> impl Future<Item = ListDocumentsResponse<T>, Error = AzureError> where
    S1: AsRef<str>,
    S2: AsRef<str>,
    T: DeserializeOwned, 

fn get_document<S1, S2, S3, T>(
    &self,
    database: S1,
    collection: S2,
    document_id: S3,
    gdo: &GetDocumentOptions
) -> impl Future<Item = GetDocumentResponse<T>, Error = AzureError> where
    S1: AsRef<str>,
    S2: AsRef<str>,
    S3: AsRef<str>,
    T: DeserializeOwned, 

fn query_document<'b, S1, S2, T>(
    &self,
    database: S1,
    collection: S2,
    query: &Query<'b>,
    options: &QueryDocumentOptions
) -> impl Future<Item = QueryDocumentResponse<T>, Error = AzureError> + 'b where
    T: DeserializeOwned + 'b,
    S1: AsRef<str> + 'b,
    S2: AsRef<str> + 'b, 

fn query_document_json<'b, S1, S2>(
    &self,
    database: S1,
    collection: S2,
    query: &Query<'b>,
    options: &QueryDocumentOptions
) -> impl Future<Item = QueryDocumentResponse<String>, Error = AzureError> where
    S1: AsRef<str>,
    S2: AsRef<str>,