mongo2rethink/producer.go

// iterator
package main

//	"fmt"
// "log"
// "strconv"
// "time"

type produced struct {
	logins []MongoLogin
}

func producer() {

	for loop {

		wg.Wait()
		status = _Producer

		//start := time.Now()
		// estrae un userid dalla lista degli utenti che hanno fatto login
		logs := dbs.Mongo.Find(opts.MaxLogins)

		wg.Add(1)
		count.AddWG()

		consume <- produced{
			logins: logs,
		}
	}

	done <- true
}