Packages

kaffe

1.0.0
2.1.0 2.0.0 1.28.0 1.27.2 1.27.1 1.27.0 1.26.0 1.25.0 1.24.0 1.23.0 1.22.0 1.21.0 1.20.0 1.19.0 1.18.0 1.17.0 1.15.0 1.14.1 1.13.0 1.12.0 1.11.0 1.10.0 1.9.2 1.9.1 1.9.0 1.8.0 1.7.0 1.6.0 1.5.0 1.4.3 1.4.0 1.3.1 1.3.0 1.2.1 1.2.0 1.1.0 1.0.0 0.5.0

An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.

HexDocs

Current section

Files

Jump to
Readme
38 Versions
1 Dependency
5 Dependants
Files
Activity
kaffe lib kaffe group_member manager group_member_supervisor.ex
Raw

lib/kaffe/group_member/manager/group_member_supervisor.ex 

defmodule Kaffe.GroupMemberSupervisor do

  @moduledoc """

  The top-level supervisor for group members and subscribers.

  """



  use Supervisor



  require Logger



  def start_link do

    Supervisor.start_link(__MODULE__, :ok, name: name())

  end



  def start_worker_supervisor(supervisor_pid, subscriber_name) do

    Supervisor.start_child(supervisor_pid, supervisor(Kaffe.WorkerSupervisor, [subscriber_name]))

  end



  def start_group_member(supervisor_pid, subscriber_name, consumer_group,

      worker_manager_pid, topic) do

    Supervisor.start_child(supervisor_pid, worker(Kaffe.GroupMember,

      [subscriber_name, consumer_group, worker_manager_pid, topic],

      id: :"group_member_#{subscriber_name}_#{topic}"))

  end



  def init(:ok) do

    Logger.info "event#starting=#{__MODULE__}"



    children = [

      worker(Kaffe.GroupManager, [])

    ]



    # If we get a failure, we need to reset so the states are all consistent.

    supervise(children, strategy: :one_for_all, max_restarts: 0, max_seconds: 1)

  end



  defp name do

    :"group_member_supervisor_#{subscriber_name()}"

  end



  defp subscriber_name do

    Kaffe.Config.Consumer.configuration.subscriber_name

  end

end