# Functions
AboveMeanFn returns a BrokerFilterFn that filters brokers that are above the mean by d percent (0.00 < d).
BelowMeanFn returns a BrokerFilterFn that filters brokers that are below the mean by d percent (0.00 < d).
BrokerMapFromPartitionMap creates a BrokerMap from a partitionMap.
BrokerMetaMapFromStates takes a kafkaadmin.BrokerStates and translates it to a BrokerMetaMap.
TODO deprecate.
NewBrokerMap returns a new BrokerMap.
NewConstraints returns an empty *Constraints.
NewDegreeDistribution returns a new DegreeDistribution.
NewMappings returns a new Mappings.
NewPartitionMap returns an empty *PartitionMap with optionally provided PartitionMapOpts.
NewPartitionMetaMap returns an empty PartitionMetaMap.
NewRebuildParams initializes a RebuildParams.
NewZooKeeperStub returns a stub ZooKeeper.
PartitionMapFromString takes a json encoded string and returns a *PartitionMap.
PartitionMapFromTopicStates translates a kafkaadmin.TopicStates to a *PartitionMap.
Populate takes a name, partition count and replication factor and returns a PartitionMapOpt.
WriteMap takes a *PartitionMap and writes a JSON text file to the provided path.
# Constants
StubBrokerID is the platform int max.
# Variables
AllBrokersFn returns all brokers.
ErrInvalidSelectionMethod error.
ErrNoBrokers error.
No description provided by the author
No description provided by the author
# Structs
Broker associates metadata with a real broker by ID.
BrokerMeta holds metadata that describes a broker.
BrokerMetrics holds broker metric data fetched from ZK.
BrokerStatus summarizes change counts from an input and output broker list.
BrokerUseStats holds counts of partition ownership.
Constraints holds a map of IDs and locality key-values.
ConstraintsParams holds parameters for the SelectBroker method.
DegreeDistribution counts broker to broker relationships.
DegreeDistributionStats holds general statistical information describing the DegreeDistribution counts.
NoMappingForBroker error.
NoMappingForTopic error.
Partition represents the Kafka partition structure.
PartitionMap represents the Kafka partition map structure.
PartitionMeta holds partition metadata.
RebuildParams holds required parameters to call the Rebuild method on a *PartitionMap.
Stub stubs the Handler interface.
StubZnode stubs a ZooKeeper znode.
TopicState is used for unmarshalling ZooKeeper json data from a topic: e.g.
# Type aliases
BrokerFilterFn is a filter function for BrokerList and BrokerMap types.
BrokerList is a slice of brokers for sorting by used count.
BrokerMap holds a mapping of broker IDs to *Broker.
BrokerMetaMap is a map of broker IDs to BrokerMeta.
BrokerMetricsMap holds a mapping of broker ID to BrokerMetrics.
BrokerUseStatsList is a slice of *BrokerUseStats.
BrokerUseStatsList is a map of IDs to *BrokerUseStats.
Mappings is a mapping of broker IDs to currently held partition as a PartitionList.
PartitionList is a []Partition.
PartitionMapOpt is a function that configures a *PartitionMap at instantiation time.
PartitionMetaMap is a mapping of topic, partition number to PartitionMeta.
ReplicaSets is a mapping of partition number to Partition.Replicas.
SubstitutionAffinities is a mapping of an ID belonging to a *Broker marked for replacement and a replacement *Broker that will fill all previously filled replica slots held by the *Broker being replaced.