Struct AsyncCollection 

pub struct AsyncCollection { /* private fields */ }

Available on crate feature tokio only.

Tokio-friendly handle to a Collection. Cheap to clone.

Implementations

impl AsyncCollection

pub async fn create_and_open( path: impl Into<String>, schema: CollectionSchema, options: Option<CollectionOptions>, ) -> Result<Self>

Create + open a new collection at path. Takes ownership of schema and options to satisfy 'static bounds on the blocking task.

pub async fn open( path: impl Into<String>, options: Option<CollectionOptions>, ) -> Result<Self>

Open an existing collection at path.

pub fn from_arc(inner: Arc<Collection>) -> Self

Wrap an existing Arc<Collection>. Useful when you already have a shared Collection you want to use from async contexts.

pub fn inner(&self) -> &Arc<Collection>

Access the underlying Arc<Collection>. Escape hatch for callers that need APIs this wrapper doesn’t cover yet.

pub async fn flush(&self) -> Result<()>

pub async fn optimize(&self) -> Result<()>

pub async fn schema(&self) -> Result<CollectionSchema>

pub async fn options(&self) -> Result<CollectionOptions>

pub async fn stats(&self) -> Result<CollectionStats>

pub async fn create_index( &self, field_name: impl Into<String>, params: IndexParams, ) -> Result<()>

pub async fn drop_index(&self, field_name: impl Into<String>) -> Result<()>

pub async fn add_column( &self, field: FieldSchema, expression: Option<String>, ) -> Result<()>

pub async fn drop_column(&self, column_name: impl Into<String>) -> Result<()>

pub async fn alter_column( &self, column_name: impl Into<String>, new_name: Option<String>, new_schema: Option<FieldSchema>, ) -> Result<()>

pub async fn insert(&self, docs: Vec<Doc>) -> Result<WriteSummary>

pub async fn insert_with_results( &self, docs: Vec<Doc>, ) -> Result<Vec<WriteResult>>

pub async fn update(&self, docs: Vec<Doc>) -> Result<WriteSummary>

pub async fn update_with_results( &self, docs: Vec<Doc>, ) -> Result<Vec<WriteResult>>

pub async fn upsert(&self, docs: Vec<Doc>) -> Result<WriteSummary>

pub async fn upsert_with_results( &self, docs: Vec<Doc>, ) -> Result<Vec<WriteResult>>

pub async fn delete(&self, pks: Vec<String>) -> Result<WriteSummary>

pub async fn delete_by_filter(&self, filter: impl Into<String>) -> Result<()>

pub async fn insert_iter<I>( &self, docs: I, batch_size: usize, ) -> Result<WriteSummary>

where I: IntoIterator<Item = Doc> + Send + 'static,

Streamed batched insert. The input iterator must be Send + 'static; callers producing docs lazily from a channel or stream can .collect::<Vec<_>>().await upstream.

pub async fn upsert_iter<I>( &self, docs: I, batch_size: usize, ) -> Result<WriteSummary>

where I: IntoIterator<Item = Doc> + Send + 'static,

pub async fn update_iter<I>( &self, docs: I, batch_size: usize, ) -> Result<WriteSummary>

where I: IntoIterator<Item = Doc> + Send + 'static,

pub async fn query(&self, query: VectorQuery) -> Result<DocSet>

pub async fn fetch(&self, pks: Vec<String>) -> Result<DocSet>

Trait Implementations

impl Clone for AsyncCollection

fn clone(&self) -> AsyncCollection

Returns a duplicate of the value.

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

Performs copy-assignment from source.