From 9ddd8472b15c3a6fc511603fd29701ae20c604ce Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Thu, 13 Jun 2024 15:34:34 +0800
Subject: [PATCH] CachedManager

---
 .../org/redkale/cached/CachedManager.java     | 15 ++++++++++++++
 .../cached/spi/CachedManagerService.java      | 20 +++++++++++++++++++
 2 files changed, 35 insertions(+)

diff --git a/src/main/java/org/redkale/cached/CachedManager.java b/src/main/java/org/redkale/cached/CachedManager.java
index 9df3358f9..1e3fcfdc1 100644
--- a/src/main/java/org/redkale/cached/CachedManager.java
+++ b/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();
+
     /**
      * 远程缓存订阅消息的管道名称
      *
diff --git a/src/main/java/org/redkale/cached/spi/CachedManagerService.java b/src/main/java/org/redkale/cached/spi/CachedManagerService.java
index a18fdfa9f..0c1f3537e 100644
--- a/src/main/java/org/redkale/cached/spi/CachedManagerService.java
+++ b/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);