feat: invalidate cache should be immediately. (#28)

Author: vuongxuongminh

caching_handler.go

@@ -228,14 +228,12 @@ func (c *Caching) handleMutationRequest(w http.ResponseWriter, r *cachingRequest
 	}
 
 	if c.DebugHeaders {
-		w.Header().Set("x-debug-purging-tags", strings.Join(purgeTags, "; "))
+		w.Header().Set("x-debug-purged-tags", strings.Join(purgeTags, "; "))
 	}
 
-	go func() {
-		if err := c.purgeQueryResultByTags(c.ctxBackground, purgeTags); err != nil {
-			c.logger.Info("fail to purge query result by tags", zap.Error(err))
-		}
-	}()
+	if err = c.purgeQueryResultByTags(c.ctxBackground, purgeTags); err != nil {
+		c.logger.Error("fail to purge query result by tags", zap.Error(err))
+	}
 
 	return err
 }

handler_test.go

@@ -492,7 +492,7 @@ caching {
 		actualHitTimes := resp.Header.Get("x-cache-hits")
 		actualStatus := resp.Header.Get("x-cache")
 		actualCachingTags := resp.Header.Get("x-debug-result-tags")
-		actualPurgingTags := resp.Header.Get("x-debug-purging-tags")
+		actualPurgingTags := resp.Header.Get("x-debug-purged-tags")
 
 		s.Require().Equalf(testCase.expectedBody, string(respBody), "case %s: unexpected payload", testCase.name)
 		s.Require().Equalf(string(testCase.expectedCachingStatus), actualStatus, "case %s: unexpected status", testCase.name)