hive-milvus.store — io.github.hive-agi/hive-milvus 0.4.4

Milvus implementation of IMemoryStore protocol.

Standalone addon project. Wraps milvus-clj.api into protocol methods.

Milvus requires explicit embeddings on insert and search; those are produced through the injected hive-milvus.embed.port boundary.

DDD: Repository pattern — MilvusMemoryStore is the Milvus aggregate adapter.

This namespace is the façade over four cohesive submodules: hive-milvus.store.schema — entry<->record, filter expressions hive-milvus.store.index — collection loading + scalar indexes hive-milvus.store.query — single-entry read / read-modify-write hive-milvus.resilience.retry — reactive retry pipeline + resilient hive-milvus.resilience.probe — cached liveness query hive-milvus.resilience.reconnect — background heal loop, probe-verified

The old hive-milvus.store.health was a 5-responsibility monolith (circuit, probe, reconnect-loop, retry, classify); split into the three resilience.* nses per SRP. store.health now exists as a deprecation shim that re-exports the new locations so external callers don't break.

The defrecord MilvusMemoryStore + create-store live here because the protocol methods can't be split across files.

build-filter-expr clj

create-store clj

(create-store)

(create-store opts)

Create a new Milvus-backed memory store.

Options (also configurable via connect!): :host - Milvus gRPC host (default: localhost) :port - Milvus gRPC port (default: 19530) :collection-name - Collection name (default: hive_mcp_memory)

Returns an IMemoryStore implementation. Registering it as the active store is a host concern (see the hive-milvus addon).

Example: (def store (create-store {:host "milvus.milvus.svc" :port 19530})) (proto/connect! store {:host "milvus.milvus.svc" :port 19530})

entry->record clj

helpfulness-map clj

record->entry clj

staleness-probability clj

str->tags clj

tags->str clj

with-auto-reconnect clj