Struct AsyncSolrCloudClient 

pub struct AsyncSolrCloudClient {
    pub context: SolrServerContext,
}

Async client for SolrCloud

Examples

use solrstice::{AsyncSolrCloudClient, SolrServerContextBuilder, SolrSingleServerHost};
let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);

Fields

context: SolrServerContext

The solr server context used to specify how to connect to Solr

Implementations

impl AsyncSolrCloudClient

pub fn new<C: Into<SolrServerContext>>(context: C) -> AsyncSolrCloudClient

Create a new instance of AsyncSolrCloudClient

Examples

use solrstice::{AsyncSolrCloudClient, SolrServerContextBuilder, SolrSingleServerHost};
let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);

pub async fn upload_config<N: AsRef<str>, P: AsRef<Path>>( &self, name: N, path: P, ) -> Result<(), Error>

Upload a config to SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
client.upload_config("config_name", Path::new("/path/to/config")).await?;

pub async fn get_configs(&self) -> Result<Vec<String>, Error>

Get the configs existing in SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
let configs: Vec<String> = client.get_configs().await?;

pub async fn config_exists<S: AsRef<str>>(&self, name: S) -> Result<bool, Error>

Check if a config exists in SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
let exists: bool = client.config_exists("config_name").await?;

pub async fn delete_config<N: AsRef<str>>(&self, name: N) -> Result<(), Error>

Delete a config from SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
client.delete_config("config_name").await?;

pub async fn create_collection<S: AsRef<str>>( &self, name: S, config: S, shards: usize, replication_factor: usize, ) -> Result<(), Error>

Create a collection in SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
client.create_collection("collection_name", "config_name", 1, 1).await?;

pub async fn get_collections(&self) -> Result<Vec<String>, Error>

Get collections from SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
let collections: Vec<String> = client.get_collections().await?;

pub async fn collection_exists<S: AsRef<str>>( &self, name: S, ) -> Result<bool, Error>

Check if a collection exists in SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
let exists: bool = client.collection_exists("collection_name").await?;

pub async fn delete_collection<N: AsRef<str>>( &self, name: N, ) -> Result<(), Error>

Delete a collection from SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
client.delete_collection("collection_name").await?;

pub async fn create_alias<S: AsRef<str>>( &self, alias: S, collections: &[S], ) -> Result<(), Error>

Create an alias in SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
client.create_alias("alias_name", &["collection1", "collection2"]).await?;

pub async fn get_aliases(&self) -> Result<HashMap<String, Vec<String>>, Error>

Get aliases from SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
let aliases: HashMap<String, Vec<String>> = client.get_aliases().await?;

pub async fn alias_exists<N: AsRef<str>>(&self, name: N) -> Result<bool, Error>

Check if an alias exists in SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
let exists: bool = client.alias_exists("alias_name").await?;

pub async fn delete_alias<S: AsRef<str>>(&self, name: S) -> Result<(), Error>

Delete an alias from SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
client.delete_alias("alias_name").await?;

pub async fn index<T: Serialize, B: AsRef<UpdateQuery>, C: AsRef<str>>( &self, builder: B, collection: C, data: &[T], ) -> Result<SolrResponse, Error>

Index some data into SolrCloud

Examples

#[derive(Serialize)]
struct Data {id: String}

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
let response = client.index(&UpdateQuery::new(), "collection_name", &[Data {id: "test".to_string()}]).await?;

pub async fn select<B: AsRef<SelectQuery>, D: Into<SelectDestination>>( &self, builder: B, destination: D, ) -> Result<SolrResponse, Error>

Select some data from SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
let response = client.select(&SelectQuery::new().fq(["age:[* TO *]"]), "collection_name").await?;

pub async fn select_raw<B: AsRef<SelectQuery>, D: Into<SelectDestination>>( &self, builder: B, destination: D, ) -> Result<HashMap<String, Value>, Error>

Select some data from SolrCloud. Return the response directly

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
let response: HashMap<String, serde_json::Value> = client.select_raw(&SelectQuery::new().fq(["age:[* TO *]"]), "collection_name").await?;

pub async fn delete<B: AsRef<DeleteQuery>, C: AsRef<str>>( &self, builder: B, collection: C, ) -> Result<SolrResponse, Error>

Delete some data from SolrCloud

Examples

let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983")).build();
let client = AsyncSolrCloudClient::new(context);
let response = client.delete(&DeleteQuery::new().ids(["document1"]).queries(["age:[* TO *]"]), "collection_name").await?;

Trait Implementations

impl Clone for AsyncSolrCloudClient

fn clone(&self) -> AsyncSolrCloudClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.