Add a removeAll() method to Cache

core/src/main/scala/scalacache/Cache.scala

@@ -29,6 +29,11 @@ trait Cache {
    */
   def remove(key: String): Future[Unit]
 
+  /**
+   * Delete the entire contents of the cache. Use wisely!
+   */
+  def removeAll(): Future[Unit]
+
   /**
    * You should call this when you have finished using this Cache.
    * (e.g. when your application shuts down)

core/src/main/scala/scalacache/package.scala

@@ -50,6 +50,12 @@ package object scalacache extends StrictLogging {
   def remove(keyParts: Any*)(implicit scalaCache: ScalaCache): Future[Unit] =
     scalaCache.cache.remove(toKey(keyParts))
 
+  /**
+   * Delete the entire contents of the cache. Use wisely!
+   */
+  def removeAll()(implicit scalaCache: ScalaCache): Future[Unit] =
+    scalaCache.cache.removeAll()
+
   /**
    * Wrap the given block with a caching decorator.
    * First look in the cache. If the value is found, then return it immediately.

core/src/test/scala/scalacache/mocks.scala

@@ -8,20 +8,23 @@ class EmptyCache extends Cache {
   override def get[V](key: String): Future[Option[V]] = Future.successful(None)
   override def put[V](key: String, value: V, ttl: Option[Duration]) = Future.successful((): Unit)
   override def remove(key: String) = Future.successful((): Unit)
+  override def removeAll() = Future.successful((): Unit)
   override def close(): Unit = {}
 }
 
 class FullCache(value: Any) extends Cache {
   override def get[V](key: String): Future[Option[V]] = Future.successful(Some(value).asInstanceOf[Option[V]])
   override def put[V](key: String, value: V, ttl: Option[Duration]) = Future.successful((): Unit)
   override def remove(key: String) = Future.successful((): Unit)
+  override def removeAll() = Future.successful((): Unit)
   override def close(): Unit = {}
 }
 
 class FailedFutureReturningCache extends Cache {
   override def get[V](key: String): Future[Option[V]] = Future.failed(new RuntimeException("failed to read"))
   override def put[V](key: String, value: V, ttl: Option[Duration]): Future[Unit] = Future.failed(new RuntimeException("failed to write"))
   override def remove(key: String) = Future.successful((): Unit)
+  override def removeAll() = Future.successful((): Unit)
   override def close(): Unit = {}
 }
 
@@ -44,6 +47,9 @@ class MockCache extends Cache {
   def remove(key: String) =
     Future.successful(mmap.remove(key))
 
+  def removeAll() =
+    Future.successful(mmap.clear())
+
   def close(): Unit = {}
 
 }

ehcache/src/main/scala/scalacache/ehcache/EhcacheCache.scala

@@ -53,6 +53,8 @@ class EhcacheCache(underlying: Ehcache)
    */
   override def remove(key: String) = Future.successful(underlying.remove(key))
 
+  override def removeAll() = Future.successful(underlying.removeAll())
+
   override def close(): Unit = {
     // Nothing to do
   }

guava/src/main/scala/scalacache/guava/GuavaCache.scala

@@ -62,6 +62,8 @@ class GuavaCache(underlying: GCache[String, Object])
    */
   override def remove(key: String) = Future.successful(underlying.invalidate(key))
 
+  override def removeAll() = Future.successful(underlying.invalidateAll())
+
   override def close(): Unit = {
     // Nothing to do
   }

lrumap/src/main/scala/scalacache/lrumap/LruMapCache.scala

@@ -62,6 +62,8 @@ class LruMapCache(underlying: LruMap[String, Object])
   override def remove(key: String): Future[Unit] =
     Future.successful(underlying.remove(key))
 
+  override def removeAll() = Future.successful(underlying.clear())
+
   override def close(): Unit = {
     // Nothing to do
   }
@@ -85,4 +87,4 @@ object LruMapCache {
      */
     def isExpired: Boolean = expiresAt.exists(_.isBeforeNow)
   }
-}
+}

memcached/src/main/scala/scalacache/memcached/MemcachedCache.scala

@@ -71,6 +71,17 @@ class MemcachedCache(client: MemcachedClient, keySanitizer: MemcachedKeySanitize
     p.future
   }
 
+  override def removeAll() = {
+    val p = Promise[Unit]()
+    val f = client.flush()
+    f.addListener(new OperationCompletionListener {
+      def onComplete(g: OperationFuture[_]): Unit = p.complete {
+        Success(())
+      }
+    })
+    p.future
+  }
+
   override def close(): Unit = {
     client.shutdown()
   }

redis/src/main/scala/scalacache/redis/RedisCache.scala

@@ -75,6 +75,14 @@ class RedisCache(jedisPool: JedisPool, override val customClassloader: Option[Cl
     }
   }
 
+  override def removeAll() = Future {
+    blocking {
+      withJedisClient { client =>
+        client.flushDB()
+      }
+    }
+  }
+
   override def close(): Unit = {
     jedisPool.close()
   }