From 0c7c07adb442c5c95a0ca5647f12bc7b3ed6a17f Mon Sep 17 00:00:00 2001
From: Gregory Eremin <g@erem.in>
Date: Sat, 21 Mar 2015 21:10:50 +0700
Subject: [PATCH] DB query queueing

---
 db/db.go | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)

diff --git a/db/db.go b/db/db.go
index b4d3383..6aa19b0 100644
--- a/db/db.go
+++ b/db/db.go
@@ -10,12 +10,14 @@ import (
 )
 
 var (
-	db *sqlx.DB
+	db         *sqlx.DB
+	queryQueue = make(chan func(), 1000)
 )
 
 func Connect(params string) (err error) {
 	db, err = sqlx.Connect("mysql", params)
 	db.Mapper = reflectx.NewMapper("json")
+	go processQueue()
 	return
 }
 
@@ -42,6 +44,17 @@ func mustSelectN(dest interface{}, query string, params interface{}) {
 	}
 }
 
+func Queue(fun func()) {
+	queryQueue <- fun
+}
+
+func processQueue() {
+	for {
+		fun := <-queryQueue
+		fun()
+	}
+}
+
 func measure(op string, start time.Time) {
 	duration := time.Since(start).Nanoseconds()
 	outcome := "succeeded"