Struct RpcClient 

pub struct RpcClient { /* private fields */ }

One connection to a Vectorizer RPC server.

Implementations

impl RpcClient

pub async fn connect_url(url: &str) -> Result<Self>

Convenience: parse a vectorizer://host[:port] URL and dial.

Accepts every form documented at crate::rpc::endpoint::parse_endpoint:

• vectorizer://host:port → RPC on the given port.
• vectorizer://host → RPC on the default port 15503.
• host:port (no scheme) → RPC.
• http(s)://... → returns RpcClientError::Server with a clear message asking the caller to use the HTTP client instead. The SDK ships the http Cargo feature for that path; an http:// URL is not a transport an RPC client can speak.

pub async fn connect(addr: impl ToSocketAddrs) -> Result<Self>

Open a TCP connection to addr (which must be host:port) and start the background reader task. Does NOT send HELLO — callers MUST call Self::hello before any data-plane command, or the server will reject it.

pub async fn hello(&self, payload: HelloPayload) -> Result<HelloResponse>

Issue the HELLO handshake. Must be the first call on a fresh connection. Returns the server’s capability list and auth flags.

pub async fn ping(&self) -> Result<String>

Health check. The server treats PING as auth-exempt so this works even before HELLO; the typed wrapper still validates the response shape.

pub async fn call( &self, command: impl Into<String>, args: Vec<VectorizerValue>, ) -> Result<VectorizerValue>

Generic call dispatcher. Most callers should use a typed wrapper from crate::rpc::commands instead.

pub fn is_authenticated(&self) -> bool

Returns true once HELLO has succeeded on this connection.

pub fn close(self)

Close the connection. Aborts the reader task; in-flight calls receive ConnectionClosed.

impl RpcClient

pub async fn list_collections(&self) -> Result<Vec<String>>

collections.list — return every collection name visible to the authenticated principal.

pub async fn get_collection_info(&self, name: &str) -> Result<CollectionInfo>

collections.get_info — return metadata for one collection.

pub async fn get_vector( &self, collection: &str, vector_id: &str, ) -> Result<VectorizerValue>

vectors.get — fetch one vector by id. Returns the raw VectorizerValue::Map so callers can read whichever fields they care about (id, data, payload, document_id).

pub async fn search_basic( &self, collection: &str, query: &str, limit: usize, ) -> Result<Vec<SearchHit>>

search.basic — search collection for query and return up to limit hits sorted by descending similarity.

Trait Implementations

impl Drop for RpcClient

fn drop(&mut self)

Executes the destructor for this type.