Update connection cache to add short delay after 'set' call, ensuring…

… results are available if read back immediately. Closes #90
turbot · Apr 8, 2021 · 0324ad4 · 0324ad4
1 parent 295a219
commit 0324ad4
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/connection/cache.go b/connection/cache.go
@@ -26,9 +26,12 @@ func NewCache(config *ristretto.Config) *Cache {
 	return &Cache{cache}
 }
 
-func (cache *Cache) Set(key string, value interface{}) {
+func (cache *Cache) Set(key string, value interface{}) bool {
 	ttl := 1 * time.Hour
-	cache.cache.SetWithTTL(key, value, 1, ttl)
+	res := cache.cache.SetWithTTL(key, value, 1, ttl)
+	// wait for value to pass through buffers
+	time.Sleep(10 * time.Millisecond)
+	return res
 }
 
 func (cache *Cache) Get(key string) (interface{}, bool) {