meeseeks-db.query — com.amobee/meeseeks-db 0.10.20

apply-scope clj

(apply-scope scope query)

approximated-bulk-scoped-queries clj

(approximated-bulk-scoped-queries
  client
  scope-spec
  queries-specs
  projected-hits-vector
  &
  [{:keys [wanted-hits p1 p2] :or {wanted-hits 500 p1 17 p2 11} :as options}])

bulk-scoped-queries clj

(bulk-scoped-queries client scope-spec queries-specs)

bulk-scoped-smarter-queries clj

(bulk-scoped-smarter-queries client scope-spec queries-specs reference-spec)

cleanup-query clj

(cleanup-query client query)

compile-query clj

(compile-query q)

Inputs: [q :- QueryExpression] Returns: Query

execute-on-shard clj

(execute-on-shard connection all-queries qids)

make-query-pipeline clj

(make-query-pipeline shard-num)

map->query-expr clj

(map->query-expr filters)

Inputs: [filters :- QueryMap] Returns: QueryExpression

multiple-queries->cursor clj

(multiple-queries->cursor client queries)

Query clj

query->command-list clj

(query->command-list query)

reduce-shards-results clj

(reduce-shards-results all-results shard-num)

run-query! clj

(run-query! client query)

Inputs: [client query :- Query] Returns: s/Int

run-stats clj

(run-stats jobs scope reference)

stats* clj

(stats* scope scope-sizes reference reference-sizes conn s-query r-query)

t-map->Query clj

upipeline-blocking clj

(upipeline-blocking n to f from)

Same as upipeline, but uses 'thread' instead of 'go'. Should be used for blocking IO.