@param nodeSpec @return

EXPERIMENTAL @param cmd @param args @return @throws ProviderException @throws IllegalArgumentException

Creates a {@link Connection} with {@link Connection.Modality#Synchronous} semantics suitable for use by synchronous (blocking) JRedis clients. @param

@param nodeSpec @return

Example highlights usage pattern of pipeline with both the natural asynchronous semantics and synchronous semantics provided by {@link JRedisPipeline#

Alright, so here we're going to fiddle with the various TCP settings that the JRedisClient will use in its connection.

On the first try, We're not really using the {@link ConnectionSpec} here, but it shows how to use the {@link JRedisClient#JRedisClient(ConnectionSpec)

@Redis EXPIRE @param key @param ttlseconds @return @throws RedisException

Flushes all dbs in the connect Redis server, regardless of which db was selected on connect time. Remember that there is no rollback. @Redis FLUSHALL

Method is called once (and only once) by the constructor to set the final {@link Support#id} field. This (default) implementation simply creates a st

@return

Internal use only - @param password @return the bytes of password or null if none spec'd

Get more bytes from the underling {@link InputStream}. Only reads from input source if len exceeds available data in {@link FastBufferedInputStream#bu

@param unsigned @return

Return the consistent hash node map. Semantics of the this map are per the consistent hashing strategy paper and Ketama's implementation. @return @se

Extension point. @param connectionSpec used for creating the connection. @return the {@link JRedisFuture} implementation instance

Creates a random ascii string @param length @return

Generates a random {@link String} of length <code>size</code> using the default encoding scheme. String content is ASCII characters. @param size of t

@return

Get the {@link SocketFlag} for the {@link ConnectionSpec} @param flag @return the specified TCP socket flag used for the connection. @see SocketFlag

The {@link ConnectionSpec} of a Connection must be invariant during its life-cycle. @return the associated {@link ConnectionSpec} for this Connection.

@return

@return the ClusterSpec.Type that the provider is supposed to support

@param <E> @param n @param from @param to @param info @param clazz @return @throws E

@throws ProviderException @throws ClientRuntimeException @throws RedisException

Extension point: child classes may override for additional components: <pre> In the extended class: <code> protected void initializeComponents() {

Can be overriden, but extending classes MUST call super.initializeComponents() as the first statement in the overriding method.

Extension point for subclasses. This method is guaranteed to be called exactly once during the instantiation process.

@throws RedisException @throws ClientRuntimeException @throws ProviderException

@throws IllegalStateException if socket is null @throws IOException thrown by socket instance stream accessors

@throws ProviderException @throws ClientRuntimeException @throws RedisException

Non-blocking call immediately returns with the current status of the signal. @return true if signaled.

The meats and potatoes of this type of model. Invocation of this method means a complete computation of the node map per the current {@link ClusterSpe

Default implementation simply includes all {@link Command}s with {@link Command.RequestType}s that include key params in the request.

Creates a new {@link Connection.Modality#Asynchronous} {@link Connection} per {@link ConnectionSpec} settings. @param spec

@return a new (un-initialized) instance of {@link ClusterNodeMap}. This instance will be installed as the class's nodeMap attribute.

does the DBSIZE

does the DECR

does the DECR

Extensions are expected to plugin their specific {@link HashAlgorithm} here. @return

does the INCR

does the INCRBY

Extension point: override to return stream per requirement. Base implementation uses {@link FastBufferedInputStream} by default, with buffer size mat

does the LLEN

does the LPOP

does the LPUSH

Extension point: override to return stream per requirement. Base implementation simply returns the input param @param socketOutputStream @return

does the PING

Creates a {@link Protocol} instance for a connection per the specified {@link ConnectionSpec} @param connSpec @return the new {@link Protocol} instanc

Extension point: child classes may override to return specific {@link Protocol} implementations per their requirements. @return

Pipeline must use a concurrent protocol handler. @see org.jredis.ri.alphazero.connection.ConnectionBase#newProtocolHandler()

Pipeline must use a concurrent protocol handler. @see org.jredis.ri.alphazero.connection.ConnectionBase#newProtocolHandler()

Pipeline must use a concurrent protocol handler. @see org.jredis.ri.alphazero.connection.ConnectionBase#newProtocolHandler()

Extension point: Tests for specific implementations of <code>T</code> implement this method to create the provider instance. @return <code>T</code> i

does the RPOP

does the RPUSH

does the SADD

does the SCARD

does the SETNX

Instantiates a new {@link Socket}, sets its properties and flags using the {@link ConnectionBase#spec} and finally connects to the {@link ConnectionBa

does the SREM

Extension point -- callback on this method when {@link ConnectionBase} has connected to server. <b>It is important to note that the extension must cal

Extension point -- callback on this method when {@link ConnectionBase} has disconnected from server. <b>It is important to note that the extension mus