milvus-clj.api — io.github.hive-agi/milvus-clj 0.2.3

Legacy thin compat shim over milvus-clj.client.

Historical shape: a flat API of 21 functions holding a defonce singleton MilvusServiceClient. The protocol refactor (see milvus-clj.client) split the implementation into transport- specific records under milvus-clj.transport.*. This ns survives as a delegating layer so existing callers (hive-milvus is the sole consumer) need not migrate in one PR.

The singleton lives in *default-client*. connect! builds a GrpcClient via client/make and stores it. Every op reads @default-client, dispatches to the protocol method, and wraps the return in future to preserve the legacy @(milvus/...) call pattern hive-milvus depends on.

This ns will be deleted in PR-4 once all call sites migrate to milvus-clj.client/with-client.

Backward compatibility notes:

• connect! / disconnect! / connected? preserve the old singleton lifecycle.
• Every op still returns a future (deref with @).
• Config keys merged via connect! pass through to milvus-clj.client/make under {:transport :grpc} defaults.
• resolve-consistency + with-connection macro preserved (hive-milvus uses neither today, but external callers might).

add clj

(add collection-name records & {:keys [upsert? partition] :or {upsert? false}})

Insert or upsert records. Returns future. Options: :upsert? (default false), :partition.

collection-stats clj

(collection-stats collection-name)

Basic collection stats. Returns future<map>.

connect! clj

(connect!)

(connect! opts)

Connect to Milvus using the configured transport.

Preserved signatures: (connect!) (connect! {:host "milvus.prod" :port 19530}) (connect! {:transport :http :host "milvus.prod"})

Merges opts into milvus-clj.config (legacy flat shape), constructs the appropriate transport-specific client via milvus-clj.client/make, and stores it in the singleton default-client atom.

Returns the underlying transport-native client for backward compat:

• gRPC: the MilvusServiceClient instance (legacy callers may hold it)
• HTTP: the HttpClient defrecord (no legacy raw reference exists)

New code should use milvus-clj.client/with-client + protocol methods directly instead of this singleton path.

connected? clj

(connected?)

Real liveness check — verifies the singleton client can actually reach the server, not merely that the atom holds a reference.

Caches a positive result for ~5s so a burst of consumer calls amortises to one RPC. A negative result immediately invalidates the cache so the resilience layer's reconnect loop sees the truth on its next poll.

Returns false (does NOT throw) on IO/fatal — callers reasoning about liveness want a boolean, not an exception. The reactive retry path (with-auto-reconnect) catches throws on the actual RPC site.

consistency-levels clj

Map keyword → ConsistencyLevelEnum (gRPC-only concept).

create-collection clj

(create-collection collection-name opts)

Create a Milvus collection with schema + optional index. Returns future. See milvus-clj.client/-create-collection.

create-index clj

(create-index collection-name index-opts)

Create an index on a collection field. Returns future.

delete clj

(delete collection-name ids & {:keys [partition]})

Delete records by IDs. Returns future. Options: :partition.

disconnect! clj

(disconnect!)

Close the active client and clear the singleton. Idempotent.

drop-collection clj

(drop-collection collection-name)

Drop a collection. Returns future.

drop-index clj

(drop-index collection-name field-name)

Drop an index from a collection field. Returns future.

flush-collection clj

(flush-collection collection-name)

Flush collection to storage. Returns future.

get clj

(get collection-name
     ids
     &
     {:keys [include consistency-level] :or {consistency-level :strong}})

Get records by IDs. Returns future<vec>. Options: :include, :consistency-level.

get-collection clj

(get-collection collection-name)

Describe a collection's schema. Returns future<map>.

has-collection clj

(has-collection collection-name)

Check if a collection exists. Returns future<boolean>.

invalidate-probe-cache! clj

(invalidate-probe-cache!)

Force the next connected? call to re-probe. Hook for the resilience layer to call after a reactive failure so the cache stays honest.

list-collections clj

(list-collections)

List all collection names. Returns future<vector<string>>.

load-collection clj

(load-collection collection-name)

Load a collection into memory. Returns future.

query clj

(query collection-name q-map)

Vector similarity search. Returns future<vec>. See milvus-clj.client/-query for q-map shape.

query-scalar clj

(query-scalar collection-name q-map)

Scalar filter query. Returns future<vec>.

release-collection clj

(release-collection collection-name)

Release a collection from memory. Returns future.

resolve-consistency clj

(resolve-consistency kw)

Resolve keyword to a gRPC ConsistencyLevelEnum. Nil means default.

with-connection clj macro

(with-connection opts & body)

Execute body with a temporary Milvus connection that auto-disconnects. Preserved for backward compat — new code should use milvus-clj.client/with-client.