Analytics now a goroutine to speed up response time

TykTechnologies · Jul 24, 2014 · dfcb152 · dfcb152
1 parent 689980b
commit dfcb152
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 6 deletions.
diff --git a/handler_error.go b/handler_error.go
@@ -58,7 +58,7 @@ func (e ErrorHandler) HandleError(w http.ResponseWriter, r *http.Request, err st
 			e.Spec.APIDefinition.APIID,
 			e.Spec.APIDefinition.OrgID,
 			OauthClientID}
-		analytics.RecordHit(thisRecord)
+		go analytics.RecordHit(thisRecord)
 	}
 
 	w.WriteHeader(errCode)

diff --git a/handler_success.go b/handler_success.go
@@ -49,7 +49,6 @@ func (s SuccessHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 
 		thisSessionState := context.Get(r, SessionData).(SessionState)
 
-
 		thisRecord := AnalyticsRecord{
 			r.Method,
 			r.URL.Path,
@@ -67,7 +66,8 @@ func (s SuccessHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 			s.Spec.APIDefinition.APIID,
 			s.Spec.APIDefinition.OrgID,
 			thisSessionState.OauthClientID}
-		analytics.RecordHit(thisRecord)
+
+		go analytics.RecordHit(thisRecord)
 	}
 
 	s.Proxy.ServeHTTP(w, r)

diff --git a/storage_handlers.go b/storage_handlers.go
@@ -72,7 +72,6 @@ func (s InMemoryStorageManager) GetKeysAndValues() map[string]string {
 	return s.Sessions
 }
 
-
 // GetKeysAndValuesWithFilter does nothing here
 func (s InMemoryStorageManager) GetKeysAndValuesWithFilter(filter string) map[string]string {
 	log.Warning("NOT IMPLEMENTED")
@@ -149,7 +148,7 @@ func (r *RedisStorageManager) cleanKey(keyName string) string {
 func (r *RedisStorageManager) GetKey(keyName string) (string, error) {
 	db := r.pool.Get()
 	defer db.Close()
-	log.Info("Getting key: ", r.fixKey(keyName))
+	log.Debug("Getting key: ", r.fixKey(keyName))
 	if db == nil {
 		log.Info("Connection dropped, connecting..")
 		r.Connect()
@@ -171,7 +170,7 @@ func (r *RedisStorageManager) GetKey(keyName string) (string, error) {
 func (r *RedisStorageManager) SetKey(keyName string, sessionState string, timeout int64) {
 	db := r.pool.Get()
 	defer db.Close()
-	log.Info("Setting key: ", r.fixKey(keyName))
+	log.Debug("Setting key: ", r.fixKey(keyName))
 	if db == nil {
 		log.Info("Connection dropped, connecting..")
 		r.Connect()