Struct Query 

pub struct Query<C: Client> {
    pub http_client: Arc<C>,
    pub user_agent: String,
    pub endpoint: String,
    pub canonical_endpoint: String,
    pub auth: Auth,
    /* private fields */
}

Fields

http_client: Arc<C>

user_agent: String

endpoint: String

canonical_endpoint: String

auth: Auth

Implementations

impl<C: Client> Query<C>

pub fn new_request( &self, method: Method, path: impl Into<String>, content_type: impl Into<String>, on_behalf_of: Option<OnBehalfOfInfo>, body: Option<Bytes>, ) -> Request

pub async fn execute( &self, method: Method, path: impl Into<String>, content_type: impl Into<String>, on_behalf_of: Option<OnBehalfOfInfo>, body: Option<Bytes>, ) -> Result<Response>

pub async fn query(&self, opts: &QueryOptions) -> Result<QueryRespReader>

pub async fn get_all_indexes( &self, opts: &GetAllIndexesOptions<'_>, ) -> Result<Vec<Index>>

pub async fn create_primary_index( &self, opts: &CreatePrimaryIndexOptions<'_>, ) -> Result<()>

pub async fn create_index(&self, opts: &CreateIndexOptions<'_>) -> Result<()>

pub async fn drop_primary_index( &self, opts: &DropPrimaryIndexOptions<'_>, ) -> Result<()>

pub async fn drop_index(&self, opts: &DropIndexOptions<'_>) -> Result<()>

pub async fn build_deferred_indexes( &self, opts: &BuildDeferredIndexesOptions<'_>, ) -> Result<()>

pub async fn watch_indexes(&self, opts: &WatchIndexesOptions<'_>) -> Result<()>

pub async fn ping(&self, opts: &PingOptions<'_>) -> Result<()>

Trait Implementations

impl<C: Debug + Client> Debug for Query<C>

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

Formats the value using the given formatter.