README
- ::addMilvusStore::add
- ::clearMilvusStore::clear
- ::createMilvusStore::create
- ::deleteMilvusStore::delete
- ::lenMilvusStore::len
- ::newMilvusStore::new
- ::searchMilvusStore::search

moonmilvus

A Milvus vector store for moonbitstack/moonrag, over its REST API.

moonrag

milvus

vector-store

vector-database

moonbit

Download zip

Author

moonbitstack

Version

0.0.1

License

Apache-2.0

Repository

github.com/moonbitstack/moonrag

Last updated

9 hours ago

Downloads

#moonmilvus

A Milvus vector store for moonrag, over its REST API. Native only: it opens sockets, so it is not built for js or wasm.

moon add moonbitstack/moonmilvus

let store = @moonmilvus.MilvusStore::new("http://127.0.0.1:19530", embedder, dimension=256)

It implements moonrag's VectorStore. Like the in-memory, SQLite and MySQL stores it recomputes the cosine in this process and ranks by the same Filter::matches, so its results agree with the other backends rather than trusting the server.

See this store's page, the guide and the API.

MilvusStore

source

pub struct MilvusStore {
  base : String
  collection : String
  embedder : &@moonbitstack/moonrag.Embedder
Embedder
  dimension : Int
  counter : Int
}

impl VectorStore for MilvusStore

async fn add(self : MilvusStore, documents : Array[@moonbitstack/moonrag.Document
Document]) -> Array[String]

source

Embed documents, upsert them, and return the ids they are stored under.

async fn delete(self : MilvusStore, ids : ArrayView[String]) -> Unit

source

Delete the rows stored under ids. An id not present is not an error.

async fn search(self : MilvusStore, vector : ArrayView[Double], limit~ : Int, filter? : @moonbitstack/moonrag.Filter
Filter) -> Array[@moonbitstack/moonrag.Scored
Scored]

source

The best limit documents for vector, best first. Every row is read back with its vector, then filtered, scored and ranked here.

MilvusStore::add

source

async fn MilvusStore::add(self : MilvusStore, documents : Array[@moonbitstack/moonrag.Document
Document]) -> Array[String]

MilvusStore::clear

source

async fn MilvusStore::clear(self : MilvusStore) -> Unit

Remove every stored row, leaving the collection.

MilvusStore::create

source

async fn MilvusStore::create(self : MilvusStore) -> Unit

Create the collection (tolerating one that already exists) and load it for querying.

MilvusStore::delete

source

async fn MilvusStore::delete(self : MilvusStore, ids : ArrayView[String]) -> Unit

MilvusStore::len

source

async fn MilvusStore::len(self : MilvusStore) -> Int64

The number of stored rows.

MilvusStore::new

source

fn MilvusStore::new(base : String, embedder : &@moonbitstack/moonrag.Embedder
Embedder, dimension~ : Int, collection? : String) -> MilvusStore raise

A store over the Milvus server at base (for example http://127.0.0.1:19530).

MilvusStore::search

source

async fn MilvusStore::search(self : MilvusStore, vector : ArrayView[Double], limit~ : Int, filter? : @moonbitstack/moonrag.Filter
Filter) -> Array[@moonbitstack/moonrag.Scored
Scored]