Added the ability to cachepools as cachepolicy.

src/DR.Sleipner.EnyimMemcachedProvider/EnyimMemcachedProvider.cs

@@ -26,7 +26,7 @@ public EnyimMemcachedProvider(IMemcachedClient client)
 
         public CachedObject<TResult> GetItem<TResult>(ProxyRequest<T, TResult> proxyRequest, CachePolicy cachePolicy)
         {
-            var key = proxyRequest.CreateHash();
+            var key = proxyRequest.CreateHash(cachePolicy.CachePool);
 
             object value;
             if (_client.TryGet(key, out value))
@@ -56,7 +56,7 @@ public CachedObject<TResult> GetItem<TResult>(ProxyRequest<T, TResult> proxyRequ
 
         public void StoreItem<TResult>(ProxyRequest<T, TResult> proxyRequest, CachePolicy cachePolicy, TResult item)
         {
-            var key = proxyRequest.CreateHash();
+            var key = proxyRequest.CreateHash(cachePolicy.CachePool);
             var cachedObject = new MemcachedObject<TResult>()
                                    {
                                        Created = DateTime.Now,
@@ -75,7 +75,7 @@ public void StoreItem<TResult>(ProxyRequest<T, TResult> proxyRequest, CachePolic
 
         public void StoreException<TResult>(ProxyRequest<T, TResult> proxyRequest, CachePolicy cachePolicy, Exception exception)
         {
-            var key = proxyRequest.CreateHash();
+            var key = proxyRequest.CreateHash(cachePolicy.CachePool);
             var cachedObject = new MemcachedObject<TResult>()
             {
                 Created = DateTime.Now,
@@ -93,13 +93,13 @@ public void StoreException<TResult>(ProxyRequest<T, TResult> proxyRequest, Cache
             }
         }
 
-        public void Purge<TResult>(Expression<Func<T, TResult>> expression)
+        public void Purge<TResult>(Expression<Func<T, TResult>> expression, string cachePool)
         {
             var methodInfo = SymbolExtensions.GetMethodInfo(expression);
             var parameters = SymbolExtensions.GetParameter(expression);
             var proxyExpression = new ProxyRequest<T, TResult>(methodInfo, parameters);
 
-            var hash = proxyExpression.CreateHash();
+            var hash = proxyExpression.CreateHash(cachePool);
             _client.Remove(hash);
         }
 
@@ -116,9 +116,9 @@ public void Exterminatus()
             throw new NotImplementedException("Exterminatus cannot be performed on a memcached based provider (it would exterminate the entire memcached cluster)");
         }
 
-        public bool TryGetRaw<TResult>(ProxyRequest<T, TResult> proxyRequest, out object result)
+        public bool TryGetRaw<TResult>(ProxyRequest<T, TResult> proxyRequest, out object result, string cachePool)
         {
-            var key = proxyRequest.CreateHash();
+            var key = proxyRequest.CreateHash(cachePool);
             object value;
             if (_client.TryGet(key, out value))
             {

src/DR.Sleipner.EnyimMemcachedProvider/ProxyRequestExtensions.cs

@@ -11,14 +11,20 @@ namespace DR.Sleipner.EnyimMemcachedProvider
 {
     public static class ProxyRequestExtensions
     {
-        public static string CreateHash<T, TResult>(this ProxyRequest<T, TResult> proxyRequest) where T : class
+        public static string CreateHash<T, TResult>(this ProxyRequest<T, TResult> proxyRequest, string cachePool) where T : class
         {
             var sb = new StringBuilder();
             sb.Append(typeof (T).FullName);
             sb.Append(" - ");
             sb.Append(proxyRequest.Method);
+            if (!string.IsNullOrWhiteSpace(cachePool))
+            {
+                sb.Append(" - ");
+                sb.Append(cachePool);
+            }
             sb.Append(" - ");
             sb.AddParameterRepresentations(proxyRequest.Parameters);
+
 
             var bytes = Encoding.UTF8.GetBytes(sb.ToString());
             var hashAlgorithm = new SHA256Managed();

src/DR.Sleipner/CachePolicy.cs

@@ -6,5 +6,6 @@ public class CachePolicy
         public int MaxAge;
         public int ExceptionCacheDuration = 10;
         public bool BubbleExceptions;
+        public string CachePool = "";
     }
 }

src/DR.Sleipner/CacheProviders/DictionaryCache/DictionaryCache.cs

@@ -56,7 +56,7 @@ public void StoreException<TResult>(ProxyRequest<T, TResult> proxyRequest, Cache
             _cache[cacheKey] = new DictionaryCachedItem(exception, duration, absoluteDuration);
         }
 
-        public void Purge<TResult>(Expression<Func<T, TResult>> expression)
+        public void Purge<TResult>(Expression<Func<T, TResult>> expression, string cachePool)
         {
             var methodInfo = SymbolExtensions.GetMethodInfo(expression);
             var parameters = SymbolExtensions.GetParameter(expression);
@@ -76,7 +76,7 @@ public void Exterminatus()
             _cache.Clear();
         }
 
-        public bool TryGetRaw<TResult>(ProxyRequest<T, TResult> proxyRequest, out object result)
+        public bool TryGetRaw<TResult>(ProxyRequest<T, TResult> proxyRequest, out object result, string cachePool)
         {
             var cacheKey = new DictionaryCacheKey(proxyRequest.Method, proxyRequest.Parameters);
             if (_cache.ContainsKey(cacheKey))

src/DR.Sleipner/CacheProviders/ICacheProvider.cs

@@ -16,10 +16,10 @@ public interface ICacheProvider<T> where T : class
         void StoreItem<TResult>(ProxyRequest<T, TResult> proxyRequest, CachePolicy cachePolicy, TResult item);
         void StoreException<TResult>(ProxyRequest<T, TResult> proxyRequest, CachePolicy cachePolicy, Exception exception);
 
-        void Purge<TResult>(Expression<Func<T, TResult>> expression);
+        void Purge<TResult>(Expression<Func<T, TResult>> expression, string cachePool = "");
         CachedObjectState GetItemState(Expression<Action<T>> action);
         void Exterminatus();
 
-        bool TryGetRaw<TResult>(ProxyRequest<T, TResult> proxyRequest, out object result);
+        bool TryGetRaw<TResult>(ProxyRequest<T, TResult> proxyRequest, out object result, string cachePool = "");
     }
 }

src/DR.Sleipner/Config/IMethodFamilyConfigurationExpression.cs

@@ -41,5 +41,11 @@ public interface IMethodFamilyConfigurationExpression
         /// </summary>
         /// <returns></returns>
         IMethodFamilyConfigurationExpression BubbleExceptionsWhenStale();
+
+        /// <summary>
+        /// This is used to set a cachepool name.
+        /// </summary>
+        /// <returns></returns>
+        IMethodFamilyConfigurationExpression CachePool(string name);
     }
 }

src/DR.Sleipner/Config/MethodFamilyConfigExpression.cs

@@ -51,5 +51,12 @@ public IMethodFamilyConfigurationExpression BubbleExceptionsWhenStale()
 
             return this;
         }
+
+        public IMethodFamilyConfigurationExpression CachePool(string name)
+        {
+            _policy.CachePool = name;
+
+            return this;
+        }
     }
 }