kafe

% @hidden
-module(kafe_consumer_group_sup).
-compile([{parse_transform, lager_transform}]).

-behaviour(supervisor).

-export([
         start_link/0
         , stop_child/1
         , start_child/11
        ]).
-export([init/1]).

start_link() ->
  supervisor:start_link({local, ?MODULE}, ?MODULE, []).

stop_child(Pid) when is_pid(Pid) ->
  case erlang:is_process_alive(Pid) of
    true ->
      try
        supervisor:terminate_child(?MODULE, Pid)
      catch
        C:E ->
          lager:error("Can't terminate kafe_consumer_fetcher #~p: ~p:~p", [Pid, C, E]),
          {error, E}
      end;
    false ->
      {error, not_found}
  end.


start_child(Topic, Partition, FetchInterval,
            GroupID, Commit, FromBeginning,
            MinBytes, MaxBytes, MaxWaitTime,
            ErrorsActions, Callback) ->
  case supervisor:start_child(?MODULE, [Topic, Partition, FetchInterval,
                                        GroupID, Commit, FromBeginning,
                                        MinBytes, MaxBytes, MaxWaitTime,
                                        ErrorsActions, Callback]) of
    {ok, Child, _} -> {ok, Child};
    Other -> Other
  end.

init([]) ->
  {ok, {
     #{strategy => simple_one_for_one,
       intensity => 0,
       period => 1},
     [#{id => kafe_consumer_fetcher,
        start => {kafe_consumer_tp_group_sup, start_link, []},
        type => supervisor,
        shutdown => 5000}]
    }}.