Struct VectorIndexServer 

pub struct VectorIndexServer { /* private fields */ }

Vector Index gRPC Server

Implementations

impl VectorIndexServer

pub fn new() -> Self

Create a new server instance

pub fn into_service(self) -> VectorIndexServiceServer<Self>

Create the gRPC service

Trait Implementations

impl Default for VectorIndexServer

fn default() -> Self

Returns the “default value” for a type.

impl VectorIndexService for VectorIndexServer

fn create_index<'life0, 'async_trait>( &'life0 self, request: Request<CreateIndexRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateIndexResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a new vector index

fn drop_index<'life0, 'async_trait>( &'life0 self, request: Request<DropIndexRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DropIndexResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Drop an existing index

fn insert_batch<'life0, 'async_trait>( &'life0 self, request: Request<InsertBatchRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<InsertBatchResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Insert a batch of vectors

fn insert_stream<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<InsertStreamRequest>>, ) -> Pin<Box<dyn Future<Output = Result<Response<InsertStreamResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Insert vectors via streaming (for large batches)

fn search<'life0, 'async_trait>( &'life0 self, request: Request<SearchRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SearchResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Search for k-nearest neighbors

fn search_batch<'life0, 'async_trait>( &'life0 self, request: Request<SearchBatchRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SearchBatchResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Batch search multiple queries

fn get_stats<'life0, 'async_trait>( &'life0 self, request: Request<GetStatsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetStatsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get index statistics

fn health_check<'life0, 'async_trait>( &'life0 self, _request: Request<HealthCheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<HealthCheckResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Health check for load balancers