Packages
kafka_ex_tc
0.12.1-11-debug
0.13.0
0.12.1
0.12.1-51-1
0.12.1-50-3
0.12.1-50-2
0.12.1-50-1
0.12.1-49-2
0.12.1-49-1
0.12.1-49-0
0.12.1-48-2
0.12.1-48-1
0.12.1-47-1
0.12.1-46-2
0.12.1-45-2
0.12.1-45-1
0.12.1-44-1
0.12.1-43-1
0.12.1-42-8
0.12.1-42-6
0.12.1-42-5
0.12.1-42-4
0.12.1-42-1
0.12.1-41-2
0.12.1-41-1
0.12.1-40-9
0.12.1-40-8
0.12.1-40-7
0.12.1-40-6
0.12.1-40-5
0.12.1-40-4
0.12.1-40-3
0.12.1-40-2
0.12.1-40-10
0.12.1-40-1
0.12.1-39-2
0.12.1-39-1
0.12.1-36-3
0.12.1-36-2
0.12.1-36-1
0.12.1-34-b
0.12.1-34-a
0.12.1-33-1
0.12.1-32-a1
0.12.1-29-s-3
0.12.1-29-s-2
0.12.1-29-s-1
0.12.1-28-rumble-1
0.12.1-27-2
0.12.1-27-1
0.12.1-26-rumble-2
0.12.1-26-rumble-1
0.12.1-26-dev-1
0.12.1-26-dev.1
0.12.1-26-3
0.12.1-26-2
0.12.1-26-1
0.12.1-25-s-8
0.12.1-25-s-7
0.12.1-25-s-6
0.12.1-25-s-5
0.12.1-25-s-4
0.12.1-25-s-3
0.12.1-25-s-2
0.12.1-25-s-1
0.12.1-25-dev-22
0.12.1-25-dev
0.12.1-24-2
0.12.1-24-1
0.12.1-22-poc-b-7
0.12.1-20-poc-b-6
0.12.1-20-poc-b-5
0.12.1-20-poc-b-4
0.12.1-20-poc-b-3
0.12.1-19-poc-b-3
0.12.1-19-poc-b-2
0.12.1-19-poc-b-1
0.12.1-19-poc-7
0.12.1-19-poc-6
0.12.1-19-poc-4
0.12.1-19-poc-3
0.12.1-19-poc-2
0.12.1-19-poc-1
0.12.1-19-poc
0.12.1-11-debug-1
0.12.1-11-debug
0.12.1-39
0.12.1-38.a
0.12.1-38
0.12.1-37.c
0.12.1-37.b
0.12.1-37.a
0.12.1-37.1
0.12.1-37
0.12.1-35.b
0.12.1-35.a
0.12.1-34
0.12.1-33
0.12.1-32
0.12.1-31
0.12.1-30
0.12.1-29
0.12.1-28
0.12.1-27
0.12.1-26
0.12.1-25
0.12.1-24
0.12.1-23
0.12.1-22.1
0.12.1-22
0.12.1-21
0.12.1-20
0.12.1-19
0.12.1-18
0.12.1-17
0.12.1-16
0.12.1-15
0.12.1-14
0.12.1-13
0.12.1-12
0.12.1-11
0.12.1-10
0.12.1-9
0.12.1-8
0.12.1-7
0.12.1-6
0.12.1-5
0.12.1-4
0.12.1-3
0.12.1-2
0.12.1-1
Kafka client for Elixir/Erlang.
Current section
Files
Jump to
Current section
Files
lib/kafka_ex/new/node_selector.ex
defmodule KafkaEx.New.NodeSelector do
@moduledoc """
Defines node selector functions and macros
"""
alias KafkaEx.New.KafkaExAPI
alias KafkaEx.New.NodeSelector
defstruct strategy: nil,
node_id: nil,
topic: nil,
partition: nil,
consumer_group_name: nil
@type t :: %__MODULE__{}
@doc """
Select a specific node
"""
@spec node_id(KafkaExAPI.node_id()) :: t
def node_id(node_id) when is_integer(node_id) do
%NodeSelector{strategy: :node_id, node_id: node_id}
end
@doc """
Select a random node
"""
@spec random :: t
def random, do: %NodeSelector{strategy: :random}
@doc """
Select first available node
"""
@spec first_available :: t
def first_available, do: %NodeSelector{strategy: :first_available}
@doc """
Select the cluster's controller node
"""
@spec controller :: t
def controller, do: %NodeSelector{strategy: :controller}
@doc """
Select the controller for the given topic and partition
"""
@spec topic_partition(KafkaExAPI.topic_name(), KafkaExAPI.partition_id()) :: t
def topic_partition(topic, partition)
when is_binary(topic) and is_integer(partition) do
%NodeSelector{
strategy: :topic_partition,
topic: topic,
partition: partition
}
end
@doc """
Select the controller for the given consumer group
"""
@spec consumer_group(KafkaExAPI.consumer_group_name()) :: t
def consumer_group(consumer_group_name) when is_binary(consumer_group_name) do
%NodeSelector{
strategy: :consumer_group,
consumer_group_name: consumer_group_name
}
end
end