Redis client for Elixir
Add this to the dependencies:
{ :exredis, "0.0.4", [ github: "artemeff/exredis", tag: "v0.0.4" ] }
As mixin
defmodule Pi do
use Exredis
def get, do: start |> query ["GET", "Pi"]
def set, do: start |> query ["SET", "Pi", "3.14"]
end
Pi.set
# => "OK"
Pi.get
# => "3.14"
Connect to the Redis server
client = Exredis.start
Disconnect from the server
Exredis.stop client
Set & Get
# set
Exredis.query(client, ["SET", "FOO", "BAR"])
# get
Exredis.query(client, ["GET", "FOO"])
# => "BAR"
Mset & Mget
# mset
Exredis.query(client, ["MSET" | ["key1", "value1", "key2", "value2", "key3", "value3"]])
# mget
Exredis.query(client, ["MGET" | ["key1", "key2", "key3"]])
# => ["value1","value2","value3"]
Transactions
# start
Exredis.query(client, ["MULTI"])
# exec
Exredis.query(client, ["SET", "foo", "bar"])
Exredis.query(client, ["SET", "bar", "baz"])
# commit
Exredis.query(client, ["EXEC"])
Pipelining
Exredis.query_pipe(client, [["SET", :a, "1"], ["LPUSH", :b, "3"], ["LPUSH", :b, "2"]])
Pub/sub
client_sub = Exredis.Sub.start
client = Exredis.start
pid = Kernel.self
client_sub |> Exredis.Sub.subscribe "foo", fn(msg) ->
pid <- msg
end
receive do
msg ->
IO.inspect msg
# => { :subscribed, "foo", #PID<0.85.0> }
end
client |> Exredis.Sub.publish "foo", "Hello World!"
receive do
msg ->
IO.inspect msg
# => { :message, "foo", "Hello World!", #PID<0.85.0> }
end
Pub/sub by a pattern
client_sub = Exredis.Sub.start
client = Exredis.start
pid = Kernel.self
client_sub |> Exredis.Sub.psubscribe "bar_*", fn(msg) ->
pid <- msg
end
receive do
msg ->
IO.inspect msg
# => { :subscribed, "bar_*", #PID<0.104.0> }
end
client |> Exredis.Sub.publish "bar_test", "Hello World!"
receive do
msg ->
IO.inspect msg
# => { :pmessage, "bar_*", "bar_test", "Hello World!", #PID<0.104.0> }
end
- Fork it
- Create your feature branch (
git checkout -b my-new-feature
) - Commit your changes (
git commit -am 'add some feature'
) - Push to the branch (
git push origin my-new-feature
) - Create new Pull Request