vmetrics

type KafkaConfig struct {
	BrokerList []string
	Config     *sarama.Config
	Topic      string
}

type Message struct {
	Namespace string
	Subsystem string
	Name      string
	// contains filtered or unexported fields
}

type Metric interface {
	Record(inf interface{})
	Consume() []string
	Clear()
	GetName() string
}

type Registry struct {
	Metrics  []Metric
	Config   *RegistryConfig
	Producer sarama.SyncProducer
	Logger   *log.Logger
}

type RegistryConfig struct {
	KafkaConfig
	Cycle time.Duration
}