Add items retrieve

Author: bajb

cache_test.go

@@ -76,3 +76,23 @@ func TestMaxLifetime(t *testing.T) {
 		t.Errorf("Expected empty cache to return no data")
 	}
 }
+
+func TestItems(t *testing.T) {
+	dur := time.Millisecond * 100
+
+	cache := ttlmap.New()
+	cache.Set("item1", "one", nil)
+	cache.Set("item2", "two", nil)
+	cache.Set("item3", "three", &dur)
+	cache.Set("item4", "four", nil)
+
+	if len(cache.Items()) != 4 {
+		t.Errorf("Expected cache to return 4 items")
+	}
+
+	time.Sleep(dur)
+
+	if len(cache.Items()) != 3 {
+		t.Errorf("Expected cache to return 3 items after cache expiry")
+	}
+}

items.go

@@ -0,0 +1,18 @@
+package ttlmap
+
+// Returns all items as map[string]interface{}
+func (m CacheMap) Items() map[string]interface{} {
+	tmp := make(map[string]interface{})
+
+	for i := 0; i < m.options.shardCount; i++ {
+		shard := m.items[i]
+		shard.RLock()
+		for key, itm := range shard.items {
+			if !itm.Expired() {
+				tmp[key] = itm.GetValue()
+			}
+		}
+		shard.RUnlock()
+	}
+	return tmp
+}