Kayrock.Client.ClusterMetadata (kayrock v1.0.1)

Copy Markdown View Source

Encapsulates what we know about the state of a Kafka broker cluster

Summary

Types

node_select_error()
t()

Functions

broker_by_node_id(cluster_metadata, node_id)
from_metadata_v1_response(metadata)
get_and_update_broker(cluster_metadata, node_id, cb)
known_topics(cluster_metadata)
merge_brokers(old_cluster_metadata, new_cluster_metadata)
select_node(cluster_metadata, node_id)

Types

node_select_error()

@type node_select_error() :: :no_such_node | :no_such_topic | :no_such_partition

t()

@type t() :: %Kayrock.Client.ClusterMetadata{
  brokers: term(),
  controller_id: term(),
  topics: term()
}

Functions

broker_by_node_id(cluster_metadata, node_id)

from_metadata_v1_response(metadata)

get_and_update_broker(cluster_metadata, node_id, cb)

known_topics(cluster_metadata)

merge_brokers(old_cluster_metadata, new_cluster_metadata)

select_node(cluster_metadata, node_id)

@spec select_node(t(), Kayrock.node_selector()) ::
  {:ok, Kayrock.node_id()} | {:error, node_select_error()}