metrics

type KafkaProducer struct {
	Log *gologger.Logger
	// contains filtered or unexported fields
}

type Metric struct {
	Tags      []string `json:"tags"`
	Value     int      `json:"value"`
	Timestamp string   `json:"timestamp"`
	Type      string   `json:"type"`
}

type MetricsProducer interface {
	Consume(c chan Metric)
	Init()
	Produce()
}

type SSEBroker struct {

	// Create a map of Clients, the keys of the map are the channels
	// over which we can push messages to attached Clients.  (The values
	// are just booleans and are meaningless.)
	//
	Clients map[chan Metric]bool

	// Channel into which new Clients can be pushed
	//
	NewClients chan chan Metric

	// Channel into which disconnected Clients should be pushed
	//
	DefunctClients chan chan Metric

	// Channel into which messages are pushed to be broadcast out
	// to attahed Clients.
	//
	MetricsChannel chan Metric

	// the central logger
	Log *gologger.Logger
}

type SimpleProducer struct {
	// contains filtered or unexported fields
}

type Streamer struct {
	Clients map[chan Metric]bool
	Log     *gologger.Logger
	// contains filtered or unexported fields
}