Toggle navigation
Home
java.util.Map to org.redisson.api.RFuture
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'redisson'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Add or Remove Method invocation
evalRead(getName(),codec,new RedisCommand<Map<Object,Object>>("EVAL",new MapGetAllDecoder(new ArrayList<Object>(keys),0,true),ValueType.MAP_VALUE),"local expireHead = redis.call('zrange', KEYS[2], 0, 0, 'withscores');" + "local accessTimeout = ARGV[1]; " + "local currentTime = tonumber(ARGV[2]); "+ "local hasExpire = #expireHead == 2 and tonumber(expireHead[2]) <= currentTime; "+ "local map = {};"+ "for i=3, #ARGV, 5000 do "+ "local m = redis.call('hmget', KEYS[1], unpack(ARGV, i, math.min(i+4999, #ARGV))); "+ "for k,v in ipairs(m) do "+ "table.insert(map, v) "+ "end; "+ "end; "+ "local result = {};"+ "for i, value in ipairs(map) do "+ "if value ~= false then "+ "local key = ARGV[i+2]; "+ "if hasExpire then "+ "local expireDate = 92233720368547758; "+ "local expireDateScore = redis.call('zscore', KEYS[2], key); "+ "if expireDateScore ~= false then "+ "expireDate = tonumber(expireDateScore); "+ "end; "+ "if expireDate <= currentTime then "+ "value = false; "+ "end; "+ "end; "+ "end; "+ "table.insert(result, value); "+ "end; "+ "return result;",Arrays.<Object>asList(getName(),getTimeoutSetName(),getRemovedChannelName()),args.toArray())
to
commandExecutor.evalReadAsync(getName(),codec,new RedisCommand<Map<Object,Object>>("EVAL",new MapGetAllDecoder(new ArrayList<Object>(keys),0,true),ValueType.MAP_VALUE),"local expireHead = redis.call('zrange', KEYS[2], 0, 0, 'withscores');" + "local accessTimeout = ARGV[1]; " + "local currentTime = tonumber(ARGV[2]); "+ "local hasExpire = #expireHead == 2 and tonumber(expireHead[2]) <= currentTime; "+ "local map = {};"+ "for i=3, #ARGV, 5000 do "+ "local m = redis.call('hmget', KEYS[1], unpack(ARGV, i, math.min(i+4999, #ARGV))); "+ "for k,v in ipairs(m) do "+ "table.insert(map, v) "+ "end; "+ "end; "+ "local result = {};"+ "for i, value in ipairs(map) do "+ "if value ~= false then "+ "local key = ARGV[i+2]; "+ "if hasExpire then "+ "local expireDate = 92233720368547758; "+ "local expireDateScore = redis.call('zscore', KEYS[2], key); "+ "if expireDateScore ~= false then "+ "expireDate = tonumber(expireDateScore); "+ "end; "+ "if expireDate <= currentTime then "+ "value = false; "+ "end; "+ "end; "+ "end; "+ "table.insert(result, value); "+ "end; "+ "return result;",Arrays.<Object>asList(getName(),getTimeoutSetName(),getRemovedChannelName()),args.toArray())
evalWrite(getName(),codec,new RedisCommand<Map<Object,Object>>("EVAL",new MapGetAllDecoder(new ArrayList<Object>(keys),0,true),ValueType.MAP_VALUE),"local expireHead = redis.call('zrange', KEYS[2], 0, 0, 'withscores');" + "local accessTimeout = ARGV[1]; " + "local currentTime = tonumber(ARGV[2]); "+ "local hasExpire = #expireHead == 2 and tonumber(expireHead[2]) <= currentTime; "+ "local map = {};"+ "for i=3, #ARGV, 5000 do "+ "local m = redis.call('hmget', KEYS[1], unpack(ARGV, i, math.min(i+4999, #ARGV))); "+ "for k,v in ipairs(m) do "+ "table.insert(map, v) "+ "end; "+ "end; "+ "local result = {};"+ "for i, value in ipairs(map) do "+ "if value ~= false then "+ "local key = ARGV[i+2]; "+ "if hasExpire then "+ "local expireDate = 92233720368547758; "+ "local expireDateScore = redis.call('zscore', KEYS[2], key); "+ "if expireDateScore ~= false then "+ "expireDate = tonumber(expireDateScore); "+ "end; "+ "if expireDate <= currentTime then "+ "value = false; "+ "end; "+ "end; "+ "if accessTimeout == '0' then "+ "redis.call('hdel', KEYS[1], key); "+ "redis.call('zrem', KEYS[2], key); "+ "local msg = struct.pack('Lc0Lc0', string.len(key), key, string.len(value), value); "+ "redis.call('publish', KEYS[3], {key, value}); "+ "elseif accessTimeout ~= '-1' then "+ "redis.call('zadd', KEYS[2], accessTimeout, key); "+ "end; "+ "end; "+ "table.insert(result, value); "+ "end; "+ "return result;",Arrays.<Object>asList(getName(),getTimeoutSetName(),getRemovedChannelName()),args.toArray())
to
commandExecutor.evalWriteAsync(getName(),codec,new RedisCommand<Map<Object,Object>>("EVAL",new MapGetAllDecoder(new ArrayList<Object>(keys),0,true),ValueType.MAP_VALUE),"local expireHead = redis.call('zrange', KEYS[2], 0, 0, 'withscores');" + "local accessTimeout = ARGV[1]; " + "local currentTime = tonumber(ARGV[2]); "+ "local hasExpire = #expireHead == 2 and tonumber(expireHead[2]) <= currentTime; "+ "local map = {};"+ "for i=3, #ARGV, 5000 do "+ "local m = redis.call('hmget', KEYS[1], unpack(ARGV, i, math.min(i+4999, #ARGV))); "+ "for k,v in ipairs(m) do "+ "table.insert(map, v) "+ "end; "+ "end; "+ "local result = {};"+ "for i, value in ipairs(map) do "+ "if value ~= false then "+ "local key = ARGV[i+2]; "+ "if hasExpire then "+ "local expireDate = 92233720368547758; "+ "local expireDateScore = redis.call('zscore', KEYS[2], key); "+ "if expireDateScore ~= false then "+ "expireDate = tonumber(expireDateScore); "+ "end; "+ "if expireDate <= currentTime then "+ "value = false; "+ "end; "+ "end; "+ "if accessTimeout == '0' then "+ "redis.call('hdel', KEYS[1], key); "+ "redis.call('zrem', KEYS[2], key); "+ "local msg = struct.pack('Lc0Lc0', string.len(key), key, string.len(value), value); "+ "redis.call('publish', KEYS[3], {key, value}); "+ "elseif accessTimeout ~= '-1' then "+ "redis.call('zadd', KEYS[2], accessTimeout, key); "+ "end; "+ "end; "+ "table.insert(result, value); "+ "end; "+ "return result;",Arrays.<Object>asList(getName(),getTimeoutSetName(),getRemovedChannelName()),args.toArray())