Where the next ids to relocate come from.
The drain reads the head of the source collection and excludes what it already handled. It relies on relocation removing the row from the source, so the head is always fresh work — it never assumes the store returns rows in any order.
Where the next ids to relocate come from. The drain reads the head of the source collection and excludes what it already handled. It relies on relocation removing the row from the source, so the head is always fresh work — it never assumes the store returns rows in any order.
(-describe this)Data description of this source.
Data description of this source.
(-next-ids this n excluded)Up to n ids awaiting relocation, none of them in excluded.
Empty means the source is drained.
Up to `n` ids awaiting relocation, none of them in `excluded`. Empty means the source is drained.
(milvus-drain-source coll)Reads the head of a live Milvus collection.
Reads the head of a live Milvus collection.
(milvus-snapshot-source coll)Enumerates coll up front, then hands out each id once.
Enumerates `coll` up front, then hands out each id once.
(no-op-source)Always drained. The default when no source is supplied.
Always drained. The default when no source is supplied.
(seq-id-source ids-atom)Reads from an atom holding a vector of ids. Removing an id from the atom models the source-side delete a real relocation performs.
Reads from an atom holding a vector of ids. Removing an id from the atom models the source-side delete a real relocation performs.
(snapshot-source ids)Hands out each id from ids exactly once. For a COPY, where rows stay in the
source and the head would otherwise never empty.
Hands out each id from `ids` exactly once. For a COPY, where rows stay in the source and the head would otherwise never empty.
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 |