Bladeren bron

Cache

- refactoring
Alexey Kim 8 maanden geleden
bovenliggende
commit
efc626acb2
2 gewijzigde bestanden met toevoegingen van 15 en 15 verwijderingen
  1. 1 1
      cache/icache.go
  2. 14 14
      cache/ttl_cache.go

+ 1 - 1
cache/icache.go

@@ -6,5 +6,5 @@ type Cache interface {
 	service.Service
 
 	Get(elm Element) error
-	Set(elm ...Element)
+	Set(elm ...Element) error
 }

+ 14 - 14
cache/ttl_cache.go

@@ -32,25 +32,25 @@ func (c *ttlCache) Get(elm Element) error {
 	return nil
 }
 
-func (c *ttlCache) Set(items ...Element) {
+func (c *ttlCache) Set(items ...Element) error {
 	if items == nil {
-		return
+		return nil
 	}
 
-	go func() {
-		for _, item := range items {
-			if item == nil {
-				continue
-			}
-
-			buf, err := item.Marshal()
-			if err != nil {
-				continue
-			}
+	for _, item := range items {
+		if item == nil {
+			continue
+		}
 
-			c.buf.Add(item.Key(), buf)
+		buf, err := item.Marshal()
+		if err != nil {
+			return err
 		}
-	}()
+
+		c.buf.Add(item.Key(), buf)
+	}
+
+	return nil
 }
 
 func (c *ttlCache) String() string {