util

type Collector struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type TomlConfig struct {
	Global struct {
		Port    string `toml:"port"`
		Timeout int    `toml:"timeout"`
	} `toml:"global"`
	Log struct {
		Format string `toml:"format"`
		Level  string `toml:"level"`
	} `toml:"log"`
	Kafka struct {
		DefaultRefreshRate int    `toml:"default_refresh_rate"`
		MinKafkaVersion    string `toml:"min_kafka_version"`
		AdminTimeout       int    `toml:"admin_timeout"`
	} `toml:"kafka"`
	Clusters map[string]clusters
}