[FEAT] Jedis - Zfunctions - Added functionality for zrange usability

Project.toml

@@ -1,7 +1,7 @@
 name = "Jedis"
 uuid = "b89ccfe0-2c5f-46f6-b89b-da3e1c2e286f"
 authors = ["Jack Chan <[email protected]>"]
-version = "0.2.5"
+version = "0.2.6"
 
 [deps]
 MbedTLS = "739be429-bea8-5141-9913-cc70e7f3736d"

src/Jedis.jl

@@ -6,8 +6,8 @@ export Client, Pipeline, RedisError, get_global_client, set_global_client, get_s
        ping, flushdb, flushall, quit, set, setnx, get, del, exists, hexists, hkeys, setex, 
        expire, ttl, multi, exec, multi_exec, pipeline, hset, hget, hgetall, hmget, hdel, rpush, 
        lpush, lpos, lrem, lpop, rpop, blpop, brpop, llen, lrange, publish, subscribe, unsubscribe, 
-       psubscribe, punsubscribe, incr, incrby, incrbyfloat, hincrby, hincrbyfloat, zincrby,
-       acquire_lock, release_lock, redis_lock, isredislocked
+       psubscribe, punsubscribe, incr, incrby, incrbyfloat, hincrby, hincrbyfloat, zincrby, zadd, 
+       zrange, zrangebyscore, zrem, acquire_lock, release_lock, redis_lock, isredislocked
 
 using Sockets
 using MbedTLS

src/commands.jl

@@ -333,4 +333,34 @@ hincrbyfloat(key, field, increment; client=get_global_client()) = execute(["HINC
 
 Increment the score of a member in a sorted set.
 """
-zincrby(key, field, increment; client=get_global_client()) = execute(["ZINCRBY", key, field, increment], client)
+zincrby(key, field, increment; client=get_global_client()) = execute(["ZINCRBY", key, field, increment], client)
+
+"""
+    zadd(key, score, member[, score_and_members...])
+
+Add one or more members to a sorted set, or update its score if it 
+already exists.
+"""
+zadd(key, score, member, score_and_members...; client=get_global_client()) = execute(["ZADD", key, score, member, score_and_members...], client)
+
+"""
+    zrange(key, min, max)
+
+Store a range of members from sorted set into another key.
+"""
+zrange(key, min, max; client=get_global_client()) = execute(["ZRANGE", key, min, max], client)
+
+"""
+    zrangebyscore(key, min, max)
+
+Return a range of members in a sorted set, by score.
+"""
+zrangebyscore(key, min, max; client=get_global_client()) = execute(["ZRANGEBYSCORE", key, min, max], client)
+
+"""
+    zrem(key, member[, members...])
+
+Remove one or more members from a sorted set.
+"""
+zrem(key, member, members...; client=get_global_client()) = execute(["ZREM", key, member, members...], client)
+

test/test_commands.jl

@@ -77,6 +77,20 @@ end
     flushall()
 end
 
+@testset "ZFUNC" begin
+    @test zadd("testscore", 1, "test1") == 1
+    @test zadd("testscore", 2, "test2") == 1
+    @test zrange("testscore", 0, -1) == ["test1", "test2"]
+    @test zrange("testscore", 0, 1) == ["test1", "test2"]
+    @test zrange("testscore", 1, 1) == ["test2"]
+    @test zrangebyscore("testscore", 1, 1) == ["test1"]
+    @test zrem("testscore", "test1") == 1
+    @test zadd("testscore", 1, "test1", 3, "test3") == 2
+    @test zrem("testscore", "test1", "test3") == 2
+    @test zrange("testscore", 0, -1) == ["test2"]
+    flushall()
+end
+
 # @testset "QUIT" begin
 #     @test quit() == "OK"
 #     @test_throws Base.IOError ping()