consumer_metric/consumer/consumer.go

package consumer

import (
	oc "git.loafle.net/overflow/consumer"
	"git.loafle.net/overflow/consumer_metric/config"
)

func New(_config *config.Config) *oc.Consumer {
	ch := &ConsumerHandlers{
		Config: _config,
	}
	ch.Name = "Metric"
	ch.ConsumerName = "metric"
	ch.InfluxDBClientName = "metric"

	c := &oc.Consumer{
		ConsumerHandler: ch,
	}

	return c
}