Skip to content
This repository has been archived by the owner. It is now read-only.
Permalink
Browse files
Merge pull request #39 from cloudant/15754-mem3-sync-backlog
Add an API for mem3_sync queue lengths

BugzID: 15754
  • Loading branch information
kocolosk committed Feb 21, 2013
2 parents 755759e + 4a94b1e commit 5e24a8901b1a4cd328b011b60c586390e4b4c88d
Showing 1 changed file with 4 additions and 1 deletion.
@@ -18,7 +18,7 @@
code_change/3]).

-export([start_link/0, get_active/0, get_queue/0, push/1, push/2,
remove_node/1, initial_sync/1]).
remove_node/1, initial_sync/1, get_backlog/0]).

-import(queue, [in/2, out/1, to_list/1, join/2, from_list/1, is_empty/1]).

@@ -45,6 +45,9 @@ get_active() ->
get_queue() ->
gen_server:call(?MODULE, get_queue).

get_backlog() ->
gen_server:call(?MODULE, get_backlog).

push(#shard{name = Name}, Target) ->
push(Name, Target);
push(Name, #shard{node=Node}) ->

0 comments on commit 5e24a89

Please sign in to comment.