Speedup and add init/terminate logs.

include/rig.hrl

@@ -5,14 +5,11 @@
 -define(GET_ENV(Key, Default), application:get_env(?APP, Key, Default)).
 -define(LOOKUP(Key, List, Default), rig_utils:lookup(Key, List, Default)).
 -define(SERVER, rig_server).
-
 %% ETS tables
 -define(ETS_TABLE_INDEX, rig_index).
-
 %% msgs
 -define(MSG_RELOAD, reload).
 -define(MSG_RELOAD_CONFIG, reload_config).
-
 %% defaults
 -define(DEFAULT_CLEANUP_DELAY, 500).
 -define(DEFAULT_CONFIGS, []).
@@ -22,20 +19,25 @@
 
 %% types
 -type basedir() :: string().
--type config()  :: {table(), file(), decoder(), options()}.
+-type config() :: {table(), file(), decoder(), options()}.
 -type decoder() :: fun((binary()) -> tuple()) | term | {module(), function()}.
--type file()    :: string().
--type key()     :: term().
--type option()  :: {key_element, pos_integer()} | {subscribers, [pid()]}.
+-type file() :: string().
+-type key() :: term().
+-type option() :: {key_element, pos_integer()} | {subscribers, [pid()]}.
 -type options() :: [option()].
--type table()   :: atom().
--type value()   :: term().
+-type table() :: atom().
+-type value() :: term().
 
 %% compatibility
 -ifdef(OTP_RELEASE). %% this implies 21 or higher
--define(EXCEPTION(Class, Reason, Stacktrace), Class:Reason:Stacktrace).
+
+-define( EXCEPTION( Class , Reason , Stacktrace ) , Class : Reason : Stacktrace ) .
+
 -define(GET_STACK(Stacktrace), Stacktrace).
+
 -else.
+
 -define(EXCEPTION(Class, Reason, _), Class:Reason).
 -define(GET_STACK(_), erlang:get_stacktrace()).
+
 -endif.

src/rig_persist.erl

@@ -0,0 +1,63 @@
+%% -*- erlang-indent-level: 4;indent-tabs-mode: nil -*-
+%% ex: ts=4 sw=4 et
+-module(rig_persist).
+
+% http://erlang.org/doc/design_principles/gen_server_concepts.html
+-behaviour(gen_server).
+
+-include("rig.hrl").
+
+-ifdef(EUNIT).
+
+-include_lib("eunit/include/eunit.hrl").
+
+-endif.
+
+% API
+-export([start_link/0]).
+% Callbacks
+-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2,
+         code_change/3]).
+
+-record(state, {}).
+
+-define(PERSIST_CRITERIA, application:get_env(?APP, persist_criteria, [])).
+
+-spec start_link() -> {ok, pid()}.
+start_link() ->
+    gen_server:start_link({local, ?MODULE}, ?MODULE, [], []).
+
+% Callbacks
+-spec init([]) -> {ok, term()}.
+init(_Args) ->
+    error_logger : info_msg( "rig_persist reporting to work in"),
+    {ok, #state{}}.
+
+-spec handle_call(term(), pid(), term()) -> {ok, term()}.
+handle_call(_Request, _From, State) ->
+    {reply, ignored, State}.
+
+-spec handle_cast(term(), term()) -> {ok, term()}.
+handle_cast(_Msg, State) ->
+    {noreply, State}.
+
+-spec handle_info(term(), term()) -> {ok, term()}.
+handle_info({rig_index, update, Table}, State) ->
+    Now = erlang:system_time(millisecond),
+    {ok, Records} = rig:all(Table),
+    rig_persist_utils:to_persistent_term(Records),
+    Then = erlang:system_time(millisecond),
+    error_logger : info_msg( "rig_persist persisted in ~p millsecs" , [ Then - Now ] ),
+    {noreply, State};
+handle_info(_Info, State) ->
+    {noreply, State}.
+
+-spec terminate(term(), term()) -> term().
+terminate(Reason, _State) ->
+    error_logger : info_msg( "rig_persist terminating with Reason: ~p~n",[Reason]),
+    ok.
+
+-spec code_change(term(), term(), term()) -> {ok, term()}.
+code_change(_OldVsn, State, _Extra) ->
+    {ok, State}.
+