workque

type Data struct {
	Temperature string `json:"temperature"`
	Humidity    string `json:"humidity"`
}

type Dispatcher struct {
	// A pool of workers channels that are registered with the dispatcher
	WorkerPool chan chan Job
	// contains filtered or unexported fields
}

type Job struct {
	DB      *db.DB
	Message *sarama.ConsumerMessage
}

type Worker struct {
	WorkerPool chan chan Job
	JobChannel chan Job
}