Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/alphazero/jredis
/ functions
Functions
1,421 in github.com/alphazero/jredis
⨍
Functions
1,421
◇
Types & classes
240
↓ 3 callers
Method
newConnection
Creates a connection to a redis server using the specified connection attributes. @param spec of the new connection @return a new {@link Connection} i
core/api/src/main/java/org/jredis/connector/Connection.java:395
↓ 3 callers
Method
newProviderInstance
()
extensions/ri/src/test/java/org/jredis/cluster/models/KetamaHashAlgoTest.java:38
↓ 3 callers
Method
onResponseHandlerError
(ClientRuntimeException cre, PendingRequest request)
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:374
↓ 3 callers
Method
onResponseHandlerError
(ClientRuntimeException cre, PendingRequest request)
core/ri/src/main/java/org/jredis/ri/alphazero/connection/PipelineConnectionBase.java:221
↓ 3 callers
Method
opsPerSecAtDelta
@param keyCount @return
core/bench/src/main/java/org/jredis/bench/Util.java:92
↓ 3 callers
Method
quit
Disconnects the client. @Redis QUIT
core/api/src/main/java/org/jredis/JRedisFuture.java:91
↓ 3 callers
Method
readControlLine
@param in @param checkForError @param ctlByte @return
core/ri/src/main/java/org/jredis/ri/alphazero/protocol/SyncProtocol.java:402
↓ 3 callers
Method
removeNode
Optional. <p> Must raise a {@link ClusterModel.Event.Type#NodeAdded} event with the new node as the event's info. Event must be raised after the mode
extensions/api/src/main/java/org/jredis/cluster/ClusterModel.java:73
↓ 3 callers
Method
rpop
@Redis RPOP @param listKey @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:465
↓ 3 callers
Method
setCredentials
(byte[] credentials)
core/api/src/main/java/org/jredis/connector/ConnectionSpec.java:291
↓ 3 callers
Method
supports
Indicates if the implementation supports the cluster type. @param type @return
extensions/api/src/main/java/org/jredis/cluster/ClusterModel.java:41
↓ 3 callers
Method
supportsReconfiguration
()
extensions/api/src/main/java/org/jredis/cluster/model/StaticHashCluster.java:111
↓ 3 callers
Method
take
()
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:515
↓ 3 callers
Method
zrange
@Redis ZRANGE @param setkey @param from @param to @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:701
↓ 2 callers
Method
STORE
Store the sort results in another key. <p> <b>This command alters the semantics of the {@link Query#exec()} (or {@link Query#execAsync()()}</b> to re
core/api/src/main/java/org/jredis/Sort.java:103
↓ 2 callers
Method
bgrewriteaof
@Redis BGREWRITEAOF @return ack message. @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:1035
↓ 2 callers
Method
bitclear
(final int bitsetin, Flag...flags)
core/api/src/main/java/org/jredis/protocol/Command.java:273
↓ 2 callers
Method
checkAndReportCompliance
(List<String> cmdlist, Class<?> jredis_class)
core/api/src/test/java/org/jredis/compliance/CheckRedisCompliance.java:73
↓ 2 callers
Method
checkStatus
Determines if a completed request encountered errors and will throw an {@link ExecutionException} wrapping the original cause. Called by the {@link P
core/ri/src/main/java/org/jredis/ri/alphazero/connection/PendingRequest.java:114
↓ 2 callers
Method
compress
@param data @return
core/ri/src/main/java/org/jredis/ri/alphazero/support/GZip.java:38
↓ 2 callers
Method
convert
(List<byte[]> bulkdata)
core/ri/src/main/java/org/jredis/ri/alphazero/JRedisFutureSupport.java:1695
↓ 2 callers
Method
debug
@Redis DEBUG OBJECT <key> @param key @return @throws RedisException @see {@link ObjectInfo}
core/api/src/main/java/org/jredis/JRedis.java:1094
↓ 2 callers
Method
decompress
@param data @return
core/ri/src/main/java/org/jredis/ri/alphazero/support/GZip.java:55
↓ 2 callers
Method
flush
()
core/ri/src/main/java/org/jredis/ri/alphazero/support/Log.java:101
↓ 2 callers
Method
get
(String key)
core/api/src/main/java/org/jredis/semantics/SemanticJRedis.java:81
↓ 2 callers
Method
getCommand
@return the associated {@link Command} if any
core/api/src/main/java/org/jredis/RedisException.java:66
↓ 2 callers
Method
getConnectionForKey
(byte[] key)
extensions/ri/src/main/java/org/jredis/ri/cluster/connection/ClusterConnectionBase.java:251
↓ 2 callers
Method
getCreated_on
()
core/ri/src/test/java/org/jredis/ri/JRedisTestSuiteBase.java:305
↓ 2 callers
Method
getInstance
@return the singleton instance of {@link ClusterSuiteTestData}
extensions/ri/src/test/java/org/jredis/cluster/ClusterSuiteTestData.java:86
↓ 2 callers
Method
getItem
()
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:448
↓ 2 callers
Method
getKeyForReplicationInstance
Each node in a consistent hashing scheme is represented a number of times to satisfy the requirements of the Consistent Hashing. The implementation m
extensions/api/src/main/java/org/jredis/cluster/ClusterNodeSpec.java:62
↓ 2 callers
Method
getMax
()
extensions/ri/src/test/java/org/jredis/test/util/RunningAverage.java:39
↓ 2 callers
Method
getMin
@return
extensions/ri/src/test/java/org/jredis/test/util/RunningAverage.java:38
↓ 2 callers
Method
getNext
()
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:451
↓ 2 callers
Method
getNodeForKey
Maps the given key to a specified node of the cluster, by returning its {@link ClusterNodeSpec}. @param key @return
extensions/api/src/main/java/org/jredis/cluster/ClusterModel.java:84
↓ 2 callers
Method
getObjectInfo
(ValueResponse resp)
core/ri/src/main/java/org/jredis/ri/alphazero/JRedisFutureSupport.java:1776
↓ 2 callers
Method
getRandomAsciiString
Creates a random ascii string @param length @return
examples/src/main/java/org/jredis/examples/commands/UsingZrangeSubset.java:195
↓ 2 callers
Method
getRedisType
(ValueResponse resp)
core/ri/src/main/java/org/jredis/ri/alphazero/JRedisFutureSupport.java:1569
↓ 2 callers
Method
getResultMap
(BulkResponse resp)
core/ri/src/main/java/org/jredis/ri/alphazero/JRedisFutureSupport.java:1745
↓ 2 callers
Method
hincrby
@Redis HINCRBY @param key @param entry @param increment @return
core/api/src/main/java/org/jredis/JRedisFuture.java:828
↓ 2 callers
Method
isEmpty
()
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:568
↓ 2 callers
Method
lastsave
@Redis LASTSAVE @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:1042
↓ 2 callers
Method
linsert
(K key, boolean after, byte[] oldvalue, byte[] newvalue)
core/ri/src/main/java/org/jredis/ri/alphazero/JRedisFutureSupport.java:212
↓ 2 callers
Method
mset
@Redis MSET @param keyValueMap a {@link Map}ping of {@link String} key names to byte[] values. @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:172
↓ 2 callers
Method
msetnx
@Redis MSETNX @param keyValueMap a {@link Map}ping of {@link String} key names to byte[] values. @return false if ANY of the keys in the map already e
core/api/src/main/java/org/jredis/JRedis.java:185
↓ 2 callers
Method
newSetWorker
does the SET
core/bench/src/main/java/org/jredis/bench/JRedisBenchmark.java:473
↓ 2 callers
Method
notifyListeners
(ClusterModel.Event e)
extensions/api/src/main/java/org/jredis/cluster/ClusterModel.java:279
↓ 2 callers
Method
onEvent
(ClusterModel.Event event)
extensions/api/src/main/java/org/jredis/cluster/ClusterModel.java:120
↓ 2 callers
Method
onNodeAddition
@param newNode @return
extensions/api/src/main/java/org/jredis/cluster/ClusterModel.java:290
↓ 2 callers
Method
packValueResult
(long number)
core/ri/src/main/java/org/jredis/ri/alphazero/JRedisFutureSupport.java:1656
↓ 2 callers
Method
ping
Ping redis
core/api/src/main/java/org/jredis/JRedisFuture.java:85
↓ 2 callers
Method
poll
(long timeout, TimeUnit unit)
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:479
↓ 2 callers
Method
queueRequest
(Command cmd, byte[]... args)
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ConnectionBase.java:151
↓ 2 callers
Method
randomkey
@Redis RANDOMKEY @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:302
↓ 2 callers
Method
readBulkData
Will read up expected bulkdata bytes from the input stream. Routine will also read in the last two bytes and will check that they are indeed CRLF. @
core/ri/src/main/java/org/jredis/ri/alphazero/protocol/SyncProtocol.java:426
↓ 2 callers
Method
removeListener
<b>Optional</b> event propagation method. Removes the specified listenr from the list of {@link Connection.Listener}s. @param connListener @return tr
core/api/src/main/java/org/jredis/connector/Connection.java:148
↓ 2 callers
Method
removeNode
@param nodeSpec @throws IllegalArgumentException if nodeSpec provided is already present.
extensions/api/src/main/java/org/jredis/cluster/ClusterSpec.java:68
↓ 2 callers
Method
rename
@Redis RENAME @param oldkey @param newkey @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:310
↓ 2 callers
Method
requestFlush
()
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:768
↓ 2 callers
Method
rpoplpush
@Redis RPOPLPUSH @param srcList @param destList @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:474
↓ 2 callers
Method
run
()
core/api/src/test/java/org/jredis/compliance/CheckRedisCompliance.java:68
↓ 2 callers
Method
run
()
core/ri/src/test/java/org/jredis/ri/adhoc/AdHocTestInfo.java:45
↓ 2 callers
Method
save
@Redis SAVE @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:1022
↓ 2 callers
Method
sdiff
@Redis SDIFF @param set1 @param sets @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:581
↓ 2 callers
Method
serviceRequest
(Command cmd, byte[]... args)
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ConnectionBase.java:142
↓ 2 callers
Method
setNext
(Node<E> update)
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:450
↓ 2 callers
Method
setResponse
Signals completion without error. <p> Sets the response, which also signals the completion of this {@link Future} object. When this method is invoked
core/ri/src/main/java/org/jredis/ri/alphazero/connection/PendingRequest.java:92
↓ 2 callers
Method
setSocketFlag
Set the {@link Connection.Socket.Flag} for the {@link ConnectionSpec} @param flag @param value @return {@link ConnectionSpec} this
core/api/src/main/java/org/jredis/connector/ConnectionSpec.java:110
↓ 2 callers
Method
setType
(ClusterType clusterType)
extensions/api/src/main/java/org/jredis/cluster/ClusterSpec.java:47
↓ 2 callers
Method
sinter
@Redis SINTER @param set1 @param sets @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:548
↓ 2 callers
Method
sinterstore
@Redis SINTERSTORE @param destSetKey @param sets @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:555
↓ 2 callers
Method
stopHandler
()
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:901
↓ 2 callers
Method
stopHandler
()
core/ri/src/main/java/org/jredis/ri/alphazero/connection/PipelineConnectionBase.java:367
↓ 2 callers
Method
sunion
@Redis SUNION @param set1 @param sets @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:564
↓ 2 callers
Method
sunionstore
@Redis SUNIONSTORE @param destSetKey @param sets @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:572
↓ 2 callers
Method
toArray
()
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:591
↓ 2 callers
Method
toLong
Convenience method to convert the address info to long. Ex: "0x101860" => 1054816. (Note that the returned number is (obviously) base 10.) @param add
core/api/src/main/java/org/jredis/ObjectInfo.java:84
↓ 2 callers
Method
ttl
@Redis TTL @param key @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:356
↓ 2 callers
Method
unpackValue
(List<byte[]> queryResult)
core/api/src/main/java/org/jredis/Query.java:66
↓ 2 callers
Method
useMSet
(JRedis jredis)
examples/src/main/java/org/jredis/examples/commands/UsingBulkCommands.java:66
↓ 2 callers
Method
useMSetNX
(JRedis jredis)
examples/src/main/java/org/jredis/examples/commands/UsingBulkCommands.java:86
↓ 2 callers
Method
useZRangeSubset
The z[rev]rangeSubset commands return non-standard results tpes (see {@link ZSetEntry}). Nothing that unexpected as far as the semantics are concerne
examples/src/main/java/org/jredis/examples/commands/UsingZrangeSubset.java:99
↓ 2 callers
Method
verifyAndGetKeyForRequest
(Command cmd, byte[]...args)
extensions/ri/src/main/java/org/jredis/ri/cluster/connection/ClusterConnectionBase.java:187
↓ 2 callers
Method
zcard
@Redis ZCARD @param setKey @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:651
↓ 2 callers
Method
zcount
@Redis ZCOUNT @param setkey @param minScore @param maxScore @return count of set members with score in the given range. @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:808
↓ 2 callers
Method
zincrby
@Redis ZINCRBY @param setkey @param score @param member @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:793
↓ 2 callers
Method
zrangebyscore
@Redis ZRANGE @param setkey @param minScore @param maxScore @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:753
↓ 2 callers
Method
zrem
@Redis ZREM @param setKey @param member @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:639
↓ 2 callers
Method
zremrangebyrank
@Redis ZREMRANGEBYRANK @param setkey @param minRank @param maxRank @return number of removed elements @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:783
↓ 2 callers
Method
zremrangebyscore
@Redis ZREMRANGEBYSCORE @param setkey @param minScore @param maxScore @return number of removed elements @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:773
↓ 2 callers
Method
zrevrange
@Redis ZREVRANGE @param setkey @param from @param to @return @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:711
↓ 1 callers
Method
affirmLackOfSupportFor
By default returns true. Override to veto default command mappings. @param cmd @return
extensions/ri/src/main/java/org/jredis/ri/cluster/connection/ClusterConnectionBase.java:280
↓ 1 callers
Method
affirmSupportFor
By default returns true. Override to veto default command mappings. @param cmd @return
extensions/ri/src/main/java/org/jredis/ri/cluster/connection/ClusterConnectionBase.java:273
↓ 1 callers
Method
basicStuff
()
examples/src/main/java/org/jredis/examples/UsingJRedisPipelineService.java:114
↓ 1 callers
Method
bgsave
@Redis BGSAVE @throws RedisException
core/api/src/main/java/org/jredis/JRedis.java:1028
↓ 1 callers
Method
bitclear
(final int bitset, Flag...flags)
core/api/src/main/java/org/jredis/connector/Connection.java:307
↓ 1 callers
Method
bitset
(Flag...flags)
core/api/src/main/java/org/jredis/connector/Connection.java:298
↓ 1 callers
Method
calcReqBuffSize
(Command cmd, byte[] ... args)
core/ri/src/main/java/org/jredis/ri/alphazero/connection/ChunkedPipelineConnection.java:658
↓ 1 callers
Method
cleandb
(JRedisFuture jredis)
core/bench/src/main/java/org/jredis/ri/alphazero/bench/SimpleBenchJRedisAsync.java:55
↓ 1 callers
Method
cleandb
(JRedis jredis)
core/bench/src/main/java/org/jredis/ri/alphazero/bench/SimpleBenchJRedisClient.java:48
← previous
next →
201–300 of 1,421, ranked by callers