feat: support async update cache

README.md

@@ -55,7 +55,7 @@ func main() {
 4. Update (Update/Updates/UpdateColumn/UpdateColumns/Save)
 5. Row (Row/Rows/Scan)
 
-本库不支持Row操作的缓存。
+本库不支持Row操作的缓存。（WIP）
 
 ## 存储介质细节
 

cache/afterCreate.go

@@ -22,16 +22,23 @@ func AfterCreate(cache *Gorm2Cache) func(db *gorm.DB) {
 
 		if db.Error == nil && cache.Config.InvalidateWhenUpdate && util.ShouldCache(tableName, cache.Config.Tables) {
 			if cache.Config.CacheLevel == config.CacheLevelAll || cache.Config.CacheLevel == config.CacheLevelOnlySearch {
-				// We invalidate search cache here,
-				// because any newly created objects may cause search cache results to be outdated and invalid.
-				cache.Logger.CtxInfo(ctx, "[AfterCreate] now start to invalidate search cache for table: %s", tableName)
-				err := cache.InvalidateSearchCache(ctx, tableName)
-				if err != nil {
-					cache.Logger.CtxError(ctx, "[AfterCreate] invalidating search cache for table %s error: %v",
-						tableName, err)
-					return
+				invalidSearchCache := func() {
+					// We invalidate search cache here,
+					// because any newly created objects may cause search cache results to be outdated and invalid.
+					cache.Logger.CtxInfo(ctx, "[AfterCreate] now start to invalidate search cache for table: %s", tableName)
+					err := cache.InvalidateSearchCache(ctx, tableName)
+					if err != nil {
+						cache.Logger.CtxError(ctx, "[AfterCreate] invalidating search cache for table %s error: %v",
+							tableName, err)
+						return
+					}
+					cache.Logger.CtxInfo(ctx, "[AfterCreate] invalidating search cache for table: %s finished.", tableName)
+				}
+				if cache.Config.AsyncWrite {
+					go invalidSearchCache()
+				} else {
+					invalidSearchCache()
 				}
-				cache.Logger.CtxInfo(ctx, "[AfterCreate] invalidating search cache for table: %s finished.", tableName)
 			}
 		}
 	}

cache/afterDelete.go

@@ -70,7 +70,9 @@ func AfterDelete(cache *Gorm2Cache) func(db *gorm.DB) {
 				}
 			}()
 
-			wg.Wait()
+			if !cache.Config.AsyncWrite {
+				wg.Wait()
+			}
 		}
 	}
 }

cache/afterQuery.go

@@ -88,7 +88,9 @@ func AfterQuery(cache *Gorm2Cache) func(db *gorm.DB) {
 					}
 				}
 			}()
-			wg.Wait()
+			if !cache.Config.AsyncWrite {
+				wg.Wait()
+			}
 			return
 		}
 

cache/afterUpdate.go

@@ -71,7 +71,9 @@ func AfterUpdate(cache *Gorm2Cache) func(db *gorm.DB) {
 				}
 			}()
 
-			wg.Wait()
+			if !cache.Config.AsyncWrite {
+				wg.Wait()
+			}
 		}
 	}
 }

config/config.go

@@ -17,6 +17,9 @@ type CacheConfig struct {
 	// else we do nothing to outdated cache.
 	InvalidateWhenUpdate bool
 
+	// AsyncWrite if true, then we will write cache in async mode
+	AsyncWrite bool
+
 	// CacheTTL cache ttl in ms, where 0 represents forever
 	CacheTTL int64