topic

Documentation

Overview

Package topic handles collection of Topic inventory and metric data

Index

• func FeedTopicPool(topicChan chan<- *Topic, i *integration.Integration, collectedTopics []string)
• func GetTopics(client connection.Client) ([]string, error)
• func StartTopicPool(poolSize int, wg *sync.WaitGroup, client connection.Client) chan *Topic
• type Topic

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

func StartTopicPool(poolSize int, wg *sync.WaitGroup, client connection.Client) chan *Topic

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