anything that needs to be done to setup the calls -- typically all time consuming data setup tasks go here ...

Makes blocking calls to input stream until it gets crlf. Should not be used for size/count lines. @param in

Attempt reconnect. Must be in a (previously) connected state when called. @throws IllegalStateException if not (logically) connected.

TODO: need to change this to getReplicationConstant and TODO: extend ClusterSpec to allow setting of arbitrary parameters so it can be user configured

this is not supposed to get called unless you actually run redis on port 9999 :P

Runs a set of command primitives test runs using concurrent clients. [TODO: add all commands - this is a sampling of a few.] <p><b>Be advised that thi

@throws InterruptedException

pipelines SET reqCnt times and then waits on response of the last INCR. If foverever flag is true, will do so forever. Each cycle prints out timing s

@Redis SDIFFSTORE @param destSetKey @param sets @throws RedisException

@param in

This extension point is really only necessary to allow this class to set the {@link FaultedConnection} when necessary, in course of the {@link SyncJRe

Set the default values for the {@link ConnectionSpec} other properties. @see ConnectionSpec @see Connection.Property @see Connection.Property @see Con

@param seconds heartbeat period @return the {@link ConnectionSpec}

Must be called by a BeforeTest method to set the jredis parameter. @param provider that is being tested.

@param cnt @return the {@link ConnectionSpec}

All providers to be tested with the same degree of test data. We're using random data and can't guarantee exact teset data. TODO: flip switch to use r

a do nothing method - keeping it around in case I change my mind about using the singleton test data class. @return

@throws IllegalStateException

@param type @return whether this codec supports the (en/de)coding of the type <code>T</code>

The basics of using {@link Future} objects and {@link JRedisFuture}. <p>Note the key differences between using {@link JRedis} and {@link JRedisFuture}

@param bs bytes of the ascii string representation of a double number. E.g. "2.002".getBytes() @return

Using the asynchronous interface

Using the asynchronous interface

Using the synchronous interface

Using the synchronous interface

@param spec

Typically just a tight loop calling the redis server for the given test and using the data prep'd in {@link BenchmarkWorker#prep()}

@Redis ZRANGEBYSCORE ... WITHSCORES @param setkey @param minScore @param maxScore @return @throws RedisException

@param spec @throws ClientRuntimeException

species the BY clause

@param clusterSpec

@throws Exception

@param message

Convenience form for default immediate connection to the nodes. @param model @throws ClientRuntimeException @see {@link ClusterConnectionBase#ClusterC

Each enum member directly corresponds to a Redis command, per specification. Command semantics is specified by the element constructor params. @param

@param command

Will create and initialize a socket per the connection spec. @See {@link ConnectionSpec} @param spec @param connectImmediately will connect the socket

TODO: not sure if specifying {@link SocketException} is a good idea. @param msg @param e

@param string @param e

@param string @param e

@param connSpec @throws IllegalArgumentException

Instantiates a default connection spec for the given host and port. @param address @param port @throws ClientRuntimeException for invalid port, or nul

@param src @param eType @param info

@param src @param type

@param src @param type @param info

@param in the input source @param bufferSize size of the {@link FastBufferedInputStream#iobuffer}

instantiates a faulted connection for the given {@link ConnectionSpec} @param connSpec @param errMsg