CachedManager

src/main/java/org/redkale/cached/CachedManager.java

@@ -10,6 +10,7 @@ import java.util.concurrent.CompletableFuture;
 import java.util.function.Consumer;
 import org.redkale.cached.spi.CachedAction;
 import org.redkale.inject.Resourcable;
+import org.redkale.source.CacheSource;
 import org.redkale.util.ThrowSupplier;
 
 /**
@@ -47,6 +48,20 @@ public interface CachedManager extends Resourcable {
      */
     public String getSchema();
 
+    /**
+     * 获取本地缓存Source
+     *
+     * @return  {@link org.redkale.source.CacheSource}
+     */
+    public CacheSource getLocalSource();
+
+    /**
+     * 获取远程缓存Source, 可能为null
+     *
+     * @return  {@link org.redkale.source.CacheSource}
+     */
+    public CacheSource getRemoteSource();
+
     /**
      * 远程缓存订阅消息的管道名称
      *

src/main/java/org/redkale/cached/spi/CachedManagerService.java

@@ -179,6 +179,26 @@ public class CachedManagerService implements CachedManager, CachedActionFunc, Se
         }
     }
 
+    /**
+     * 获取本地缓存Source
+     *
+     * @return  {@link org.redkale.source.CacheSource}
+     */
+    @Override
+    public CacheSource getLocalSource() {
+        return localSource;
+    }
+
+    /**
+     * 获取远程缓存Source, 可能为null
+     *
+     * @return  {@link org.redkale.source.CacheSource}
+     */
+    @Override
+    public CacheSource getRemoteSource() {
+        return remoteSource;
+    }
+
     @Override
     public void addAction(CachedAction action) {
         actions.add(action);