Liking cljdoc? Tell your friends :D

franzy.clients.cluster

Helpers and useful functions for working with Cluster metadata.

Helpers and useful functions for working with Cluster metadata.
raw docstring

available-partitionsclj

(available-partitions cluster topic)

Retrieve a collection of available partitions for a topic in a cluster.

Retrieve a collection of available partitions for a topic in a cluster.
sourceraw docstring

bootstrap-clusterclj

(bootstrap-cluster addresses)

Bootstraps a cluster from a collection of InetAddresses.

Bootstraps a cluster from a collection of InetAddresses.
sourceraw docstring

bootstrap-cluster-hostsclj

(bootstrap-cluster-hosts host-map-coll)

Bootstraps a cluster from a collection of maps of host names and ports for InetAddresses.

ex: (bootstrap-cluster-hosts [{:host-name "localhost" :port 9092}])

Bootstraps a cluster from a collection of maps of host names and ports for InetAddresses.

ex: `(bootstrap-cluster-hosts [{:host-name "localhost" :port 9092}])`
sourceraw docstring

empty-clusterclj

(empty-cluster)
source

leader-forclj

(leader-for cluster {:keys [topic partition]})
(leader-for cluster topic partition)

Retrives the partition leader for a given topic partition.

Retrives the partition leader for a given topic partition.
sourceraw docstring

make-clusterclj

(make-cluster)
(make-cluster nodes partition-info)
(make-cluster nodes partition-info unauthorized-topics)

Creates a cluster from a given collection of nodes and partition info and an optional set of unauthorized topics.

If no parameters are provided, an empty cluster is created.

Creates a cluster from a given collection of nodes and partition info and an optional set of unauthorized topics.

If no parameters are provided, an empty cluster is created.
sourceraw docstring

mock-clusterclj

(mock-cluster node-count topic-partitions unauthorized-topics)

Creates a mock cluster for testing, dev, and as dummy data for Kafka functions requiring clusters such as partitioners.

Creates a mock cluster for testing, dev, and as dummy data for Kafka functions requiring clusters such as partitioners.
sourceraw docstring

mock-nodesclj

(mock-nodes node-count)

Creates a mock number of nodes based on the provided node count.

Creates a mock number of nodes based on the provided node count.
sourceraw docstring

node-by-idclj

(node-by-id cluster node-id)

Retrieves a node by its node id.

Retrieves a node by its node id.
sourceraw docstring

nodesclj

(nodes cluster)

Retrieves a collection of nodes in the cluster.

Retrieves a collection of nodes in the cluster.
sourceraw docstring

partition-countclj

(partition-count cluster topic)

Retrives the partition count for a given topic.

Retrives the partition count for a given topic.
sourceraw docstring

partition-info-for-topicclj

(partition-info-for-topic cluster {:keys [topic partition]})
(partition-info-for-topic cluster topic partition)

Retrieves the partition info for a given topic partition.

Retrieves the partition info for a given topic partition.
sourceraw docstring

partitions-for-nodeclj

(partitions-for-node cluster node-id)

Retrieves a collection of partitions with a leader matching the given node id.

Retrieves a collection of partitions with a leader matching the given node id.
sourceraw docstring

partitions-for-topicclj

(partitions-for-topic cluster topic)

Retrieves a collection of partitions for a given topic.

Retrieves a collection of partitions for a given topic.
sourceraw docstring

topicsclj

(topics cluster)

Retrieves a collection of topics in this cluster.

Retrieves a collection of topics in this cluster.
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close