topic

package
v4.0.9+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 24, 2020 License: MIT Imports: 11 Imported by: 0

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL