1 |
|
-module(mongoose_redis). |
2 |
|
-author("bartlomiej.gorny@erlang-solutions.com"). |
3 |
|
|
4 |
|
%% API |
5 |
|
-export([cmd/1, cmd/2, cmds/1, cmds/2]). |
6 |
|
|
7 |
|
-ignore_xref([cmd/2, cmds/2]). |
8 |
|
|
9 |
|
%%%=================================================================== |
10 |
|
%%% API |
11 |
|
%%%=================================================================== |
12 |
|
|
13 |
|
-spec cmd(iolist()) -> undefined |
14 |
|
| binary() |
15 |
|
| [binary() | [binary() | integer()] | integer() | {'error', _}] |
16 |
|
| integer() |
17 |
|
| {'error', _}. |
18 |
|
cmd(Cmd) -> |
19 |
:-( |
cmd(Cmd, 5000). |
20 |
|
|
21 |
|
-spec cmds([iolist()]) -> undefined |
22 |
|
| binary() |
23 |
|
| [binary() | [binary() | integer()] | integer() | {'error', _}] |
24 |
|
| integer() |
25 |
|
| {'error', _}. |
26 |
|
cmds(Cmd) -> |
27 |
:-( |
cmds(Cmd, 5000). |
28 |
|
|
29 |
|
-spec cmd(iolist(), integer()) -> eredis:return_value() |
30 |
|
| {'error', _}. |
31 |
|
cmd(Cmd, Timeout) -> |
32 |
:-( |
{ok, Worker} = mongoose_wpool:get_worker(redis, global, default), |
33 |
:-( |
case eredis:q(Worker, Cmd, Timeout) of |
34 |
:-( |
{ok, Value} -> Value; |
35 |
:-( |
V -> V |
36 |
|
end. |
37 |
|
|
38 |
|
-spec cmds([iolist()], integer()) -> [eredis:return_value()] |
39 |
|
| {'error', _}. |
40 |
|
cmds(Cmd, Timeout) -> |
41 |
:-( |
{ok, Worker} = mongoose_wpool:get_worker(redis, global, default), |
42 |
:-( |
eredis:qp(Worker, Cmd, Timeout). |