PROMOTE: wrap the embedder BOUNDARY call + the pure schema record builder into a Result-tracked promoter. The single caller (the pipeline) gets one r/ok / r/err to thread through.
Why this is a promoter even though it touches the embedder:
embed-for-entry returns Result; from the pipeline's POV the
embedding is just data flowing through the bundle. The actual
I/O (HTTP call to Ollama) is encapsulated in the embedder ns;
here we only orchestrate.
PROMOTE: wrap the embedder BOUNDARY call + the pure schema record builder into a Result-tracked promoter. The single caller (the pipeline) gets one r/ok / r/err to thread through. Why this is a promoter even though it touches the embedder: `embed-for-entry` returns Result; from the pipeline's POV the embedding is just data flowing through the bundle. The actual I/O (HTTP call to Ollama) is encapsulated in the embedder ns; here we only orchestrate.
(build-target-record {:keys [entry target-coll] :as bundle})Re-embed the entry under the target collection's routing-aligned provider, then build the Milvus insert record.
Bundle in: {:entry e :target-coll s …} Bundle out: same plus {:embedding v :record m}
Returns r/err :embedder/* on embed failure (propagated from
hive-milvus.embedder/embed-for-entry).
Re-embed the entry under the target collection's routing-aligned
provider, then build the Milvus insert record.
Bundle in: {:entry e :target-coll s …}
Bundle out: same plus {:embedding v :record m}
Returns r/err :embedder/* on embed failure (propagated from
`hive-milvus.embedder/embed-for-entry`).cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |