onyx.plugin.redis
inject-conn-specclj
(inject-conn-spec {:keys [onyx.core/params onyx.core/task-map] :as event}
{:keys [redis/param? redis/uri redis/read-timeout-ms]
:as lifecycle})perform-operationclj
(perform-operation config message)Validates a Redis operation submitted to RedisWriter and executes it.
Validates a Redis operation submitted to RedisWriter and executes it.
redis-commandsclj
(redis-commands)Loads the official Redis command reference. The original JSON file can be found on https://github.com/antirez/redis-doc/blob/master/commands.json.
Loads the official Redis command reference. The original JSON file can be found on https://github.com/antirez/redis-doc/blob/master/commands.json.
take-from-redisclj
(take-from-redis conn k batch-size timeout)conn: Carmine map for connecting to redis
key: The name of a redis key for looking up the relevant values
batch-size: The maximum size of a returned batch
timeout: stop processing new collections after timeout/ms''
In order to stay consistent in Redis list consumption, this function will finish processing the batch it's currently on before returning. This means that if your batch sizes are large and steps are small, it is possible to block for and extended ammount of time. Returns nil if the list is exausted.
conn: Carmine map for connecting to redis key: The name of a redis key for looking up the relevant values batch-size: The maximum size of a returned batch timeout: stop processing new collections after `timeout`/ms'' In order to stay consistent in Redis list consumption, this function will finish processing the batch it's currently on before returning. This means that if your batch sizes are large and steps are small, it is possible to block for and extended ammount of time. Returns nil if the list is exausted.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close