decoder.go

package main

//MetricMap maps name to float64 metric
type MetricMap map[string]float64

//StatsInfo describes  one statistic (queue or exchange): its name, vhost it belongs to, and all associated metrics.
type StatsInfo struct {
	labels  map[string]string
	metrics MetricMap
}

// RabbitReply is an inteface responsible for extracting usable
// information from RabbitMQ HTTP API replies, independent of the
// actual transfer format used.
type RabbitReply interface {
	// MakeMap makes a flat map from string to float values from a
	// RabbitMQ reply. Processing happens recursively and nesting
	// is represented by '.'-separated keys. Entries are added
	// only for values that can be reasonably converted to float
	// (numbers and booleans). Failure to parse should result in
	// an empty result map.
	MakeMap() MetricMap

	// MakeStatsInfo parses a list of details about some named
	// RabbitMQ objects (i.e. list of queues, exchanges, etc.).
	// Failure to parse should result in an empty result list.
	MakeStatsInfo([]string) []StatsInfo
}

// MakeReply instantiates the apropriate reply parser for a given
// reply and the current configuration.
func MakeReply(config rabbitExporterConfig, body []byte) (RabbitReply, error) {
	if isCapEnabled(config, rabbitCapBert) {
		return makeBERTReply(body), nil
	}
	return makeJSONReply(body), nil
}