celtuce.connector — dev.ecocore/celtuce-core 0.4.2

as-pubsub clj

(as-pubsub {:keys [redis-client codec]})

create-client-resource clj

(create-client-resource options-map)

You can create an instance of client resources in a clojuresque way; check out the class io.lettuce.core.resource.ClientResources for details.

It is useful to configure "plumbing" of client side redis connections such as: Netty threads, metrics, etc. But also it is good to have it for sharing the same NIO layer across multiple connections.

Currently only the number of threads are implemented. Also, you can call it without any param or with an empty map and it will create a default client resource, but that can be shared across client connections.

destroy-client-resource clj

(destroy-client-resource client-resources)

If you create a client resource, you must close/dispose it; otherwise you will not shutdown the Netty threads.

kw->cunit clj

kw->dbehavior clj

kw->rtrigger clj

kw->tunit clj

Listenable clj protocol

Register a celtuce.commands.PubSubListener on a stateful pubsub connection

add-listener! clj

(add-listener! this listener)

redis-cluster clj

(redis-cluster redis-uri
               &
               {codec :codec
                client-options :client-options
                {auto-flush :auto-flush
                 conn-timeout :timeout
                 conn-unit :unit
                 client-resources :client-resources
                 :or {auto-flush true}}
                  :conn-options
                :or {codec (nippy-codec) client-options {}}})

redis-server clj

(redis-server redis-uri
              &
              {codec :codec
               client-options :client-options
               {auto-flush :auto-flush
                conn-timeout :timeout
                conn-unit :unit
                client-resources :client-resources
                :or {auto-flush true}}
                 :conn-options
               :or {codec (nippy-codec) client-options {}}})

RedisConnector clj protocol

Manipulate Redis client and stateful connection

commands-dynamic clj

(commands-dynamic this cmd-class)

commands-sync clj

(commands-sync this)

flush-commands clj

(flush-commands this)

reset clj

(reset this)

set-options clj

(set-options this options)

shutdown clj

(shutdown this)