Documentation
¶
Overview ¶
Package topic handles collection of Topic inventory and metric data
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FeedTopicPool ¶
func FeedTopicPool(topicChan chan<- *Topic, i *integration.Integration, collectedTopics []string)
FeedTopicPool sends Topic structs down the topicChan for workers to collect and build Topic structs
func GetTopics ¶
func GetTopics(client connection.Client) ([]string, error)
GetTopics retrieves the list of topics to collect based on the user-provided configuration
func StartTopicPool ¶
StartTopicPool Starts a pool of topicWorkers to handle collecting data for Topic entities. The channel returned is to be closed by the user.
Types ¶
type Topic ¶
type Topic struct {
Entity *integration.Entity
Name string
PartitionCount int
ReplicationFactor int
Configs []*sarama.ConfigEntry
Partitions []*partition
}
Topic is a storage struct for information about topics
Source Files
Click to show internal directories.
Click to hide internal directories.