COLLECT: locate an entry's current physical collection and read its
record. Wraps the existing lookup/find-entry-collection +
query/get-entry-by-id chain in Result envelopes so the pipeline
sees them as data.
Imports the leaf hive-milvus.store.lookup ns rather than
hive-milvus.store.entries to keep the relocate pipeline cycle-free
(entries delegates routing-aware ops to the pipeline; the pipeline
must NOT loop back into entries).
COLLECT: locate an entry's current physical collection and read its record. Wraps the existing `lookup/find-entry-collection` + `query/get-entry-by-id` chain in Result envelopes so the pipeline sees them as data. Imports the leaf `hive-milvus.store.lookup` ns rather than `hive-milvus.store.entries` to keep the relocate pipeline cycle-free (entries delegates routing-aware ops to the pipeline; the pipeline must NOT loop back into entries).
(collect-existing-entry {:keys [config-atom id]})Locate id across known Milvus collections, read it back.
Bundle in: {:config-atom a :id id} Bundle out: {:id id :src-coll s :entry e :config-atom a}
Returns r/err :collector/not-found when the id resolves to no collection; r/err :collector/entry-vanished when located but the subsequent read returns nil (race window).
Side-effect: one Milvus get call per known collection until the id
hits. The underlying find-entry-collection already wraps Milvus
calls in try/catch internally so no raw exceptions escape into the
pipeline.
Locate `id` across known Milvus collections, read it back.
Bundle in: {:config-atom a :id id}
Bundle out: {:id id :src-coll s :entry e :config-atom a}
Returns r/err :collector/not-found when the id resolves to no
collection; r/err :collector/entry-vanished when located but the
subsequent read returns nil (race window).
Side-effect: one Milvus get call per known collection until the id
hits. The underlying `find-entry-collection` already wraps Milvus
calls in try/catch internally so no raw exceptions escape into the
pipeline.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 |