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

as-pubsub clj

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

Converts a Redis connection to a pub/sub connection.

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

Map of keywords to Java ChronoUnit enum values for time duration conversions.

kw->dbehavior clj

Map of keywords to ClientOptions DisconnectedBehavior enum values.

kw->rtrigger clj

Map of keywords to ClusterTopologyRefreshOptions RefreshTrigger enum values.

kw->tunit clj

Map of keywords to Java TimeUnit enum values for time unit conversions.

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 {}}})

Creates a Redis cluster connection with optional configuration.

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 {}}})

Creates a Redis server connection with optional configuration.

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)