# Functions
GetReservedFields returns a map proto message types to field names considered reserved for internal use.
NewRequestThrottle initializes a RequestThrottle.
NewServer initializes a *Server.
NewTagHandler initializes a TagHandler.
NewZKTagStorage initializes a ZKTagStorage.
PartitionMapToReplicaAssignment takes a *kafkazk.PartitionMap and transforms it into an admin.ReplicaAssignment.
TopicSetFromSlice converts a slice into a TopicSet for convenience.
# Variables
ErrBrokerIDEmpty error.
ErrBrokerIDsEmpty error.
ErrBrokerNotExist error.
ErrFetchingBrokers error.
ErrFetchingTopics error.
ErrGroupIDEmpty error.
ErrInsufficientBrokers error.
ErrInvalidBrokerId error.
ErrInvalidKafkaObjectType error.
ErrKafkaObjectDoesNotExist error.
ErrNilTags error.
ErrNilTagSet error.
ErrRequestThrottleTimeout error.
ErrTopicAlreadyExists error.
ErrTopicFieldMissing error.
ErrTopicNameEmpty error.
ErrTopicNotExist error.
No description provided by the author
# Structs
Checkpoint holds a record emmitted from the MirrorCheckpointConnector in MirrorMaker2.
Config holds Server configurations.
ErrReservedTag error.
KafkaObject holds an object type (broker, topic) and object identifier (ID, name).
RequestThrottleConfig specifies the RequestThrottle burst capacity and per-second rate limit.
Server implements the registry APIs.
No description provided by the author
TagHandler provides object filtering by tags along with tag storage and retrieval.
TagHandlerConfig holds TagHandler configuration.
ZKTagStorage implements tag persistence in ZooKeeper.
ZKTagStorageConfig holds ZKTagStorage configs.
# Interfaces
RequestThrottle controls request rates with a configurable burst capacity and per-second rate backed with a token bucket.
TagStorage handles tag persistence to stable storage.
# Type aliases
BrokerSet is a mapping of broker IDs to *pb.Broker.
ReservedFields is a mapping of object types (topic, broker) to a set of fields reserved for internal use; these are default fields that become searchable through the tags interface.
Tags is a []string of "key:value" pairs.
TagSet is a map of key:values.
TopicSet is a mapping of topic name to *pb.Topic.