feat: Support more redis commands

Author: codeba

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/CacheTemplate.java

@@ -1,17 +1,17 @@
 /*
  * Copyright (c) 2024-2025, redis-keeper ([email protected])
  *
- *    Licensed under the Apache License, Version 2.0 (the "License");
- *    you may not use this file except in compliance with the License.
- *    You may obtain a copy of the License at
+ *     Licensed under the Apache License, Version 2.0 (the "License");
+ *     you may not use this file except in compliance with the License.
+ *     You may obtain a copy of the License at
  *
- *        http://www.apache.org/licenses/LICENSE-2.0
+ *         http://www.apache.org/licenses/LICENSE-2.0
  *
- *    Unless required by applicable law or agreed to in writing, software
- *    distributed under the License is distributed on an "AS IS" BASIS,
- *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *    See the License for the specific language governing permissions and
- *    limitations under the License.
+ *     Unless required by applicable law or agreed to in writing, software
+ *     distributed under the License is distributed on an "AS IS" BASIS,
+ *     WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *     See the License for the specific language governing permissions and
+ *     limitations under the License.
  */
 
 package org.codeba.redis.keeper.core;
@@ -1441,6 +1441,14 @@ public interface CacheTemplate {
      */
     boolean lRem(String key, Object element);
 
+    /**
+     * L rem all.
+     *
+     * @param key     the key
+     * @param element the element
+     */
+    void lRemAll(String key, Object element);
+
     /**
      * L rem async completable future.
      *
@@ -1450,6 +1458,33 @@ public interface CacheTemplate {
      */
     CompletableFuture<Boolean> lRemAsync(String key, Object element);
 
+    /**
+     * L rem all async completable future.
+     *
+     * @param key     the key
+     * @param element the element
+     * @return the completable future
+     */
+    CompletableFuture<Boolean> lRemAllAsync(String key, Object element);
+
+    /**
+     * L rem optional.
+     *
+     * @param key   the key
+     * @param index the index
+     * @return the optional
+     */
+    Optional<Object> lRem(String key, int index);
+
+    /**
+     * L rem async completable future.
+     *
+     * @param key   the key
+     * @param index the index
+     * @return the completable future
+     */
+    CompletableFuture<Object> lRemAsync(String key, int index);
+
     /**
      * L set.
      *
@@ -3293,6 +3328,22 @@ public interface CacheTemplate {
      */
     boolean bfReserve(String key, long expectedInsertions, double falseProbability);
 
+    /**
+     * Delete bf boolean.
+     *
+     * @param key the key
+     * @return the boolean
+     */
+    boolean deleteBf(String key);
+
+    /**
+     * Delete bf async completable future.
+     *
+     * @param key the key
+     * @return the completable future
+     */
+    CompletableFuture<Boolean> deleteBfAsync(String key);
+
     /**
      * Try lock boolean.
      *
@@ -3415,6 +3466,44 @@ public interface CacheTemplate {
      */
     CompletableFuture<Long> existsAsync(String... keys);
 
+    /**
+     * Expire boolean.
+     *
+     * @param key        the key
+     * @param timeToLive the time to live
+     * @param timeUnit   the time unit
+     * @return the boolean
+     */
+    boolean expire(String key, long timeToLive, TimeUnit timeUnit);
+
+    /**
+     * Expire async completable future.
+     *
+     * @param key        the key
+     * @param timeToLive the time to live
+     * @param timeUnit   the time unit
+     * @return the completable future
+     */
+    CompletableFuture<Boolean> expireAsync(String key, long timeToLive, TimeUnit timeUnit);
+
+    /**
+     * Expire at boolean.
+     *
+     * @param key       the key
+     * @param timestamp the timestamp
+     * @return the boolean
+     */
+    boolean expireAt(String key, long timestamp);
+
+    /**
+     * Expire at async completable future.
+     *
+     * @param key       the key
+     * @param timestamp the timestamp
+     * @return the completable future
+     */
+    CompletableFuture<Boolean> expireAtAsync(String key, long timestamp);
+
     /**
      * Del long.
      *
@@ -3431,6 +3520,22 @@ public interface CacheTemplate {
      */
     CompletableFuture<Long> delAsync(String... keys);
 
+    /**
+     * Unlink long.
+     *
+     * @param keys the keys
+     * @return the long
+     */
+    long unlink(String... keys);
+
+    /**
+     * Unlink async completable future.
+     *
+     * @param keys the keys
+     * @return the completable future
+     */
+    CompletableFuture<Long> unlinkAsync(String... keys);
+
     /**
      * Ttl long.
      *
@@ -3447,6 +3552,22 @@ public interface CacheTemplate {
      */
     CompletableFuture<Long> ttlAsync(String key);
 
+    /**
+     * P ttl long.
+     *
+     * @param key the key
+     * @return the long
+     */
+    long pTTL(String key);
+
+    /**
+     * P ttl async completable future.
+     *
+     * @param key the key
+     * @return the completable future
+     */
+    CompletableFuture<Long> pTTLAsync(String key);
+
     /**
      * Scan iterable.
      *

redis-keeper-example/pom.xml

@@ -1,17 +1,17 @@
 <!--
   ~ Copyright (c) 2024-2025, redis-keeper ([email protected])
   ~
-  ~    Licensed under the Apache License, Version 2.0 (the "License");
-  ~    you may not use this file except in compliance with the License.
-  ~    You may obtain a copy of the License at
+  ~     Licensed under the Apache License, Version 2.0 (the "License");
+  ~     you may not use this file except in compliance with the License.
+  ~     You may obtain a copy of the License at
   ~
-  ~        http://www.apache.org/licenses/LICENSE-2.0
+  ~         http://www.apache.org/licenses/LICENSE-2.0
   ~
-  ~    Unless required by applicable law or agreed to in writing, software
-  ~    distributed under the License is distributed on an "AS IS" BASIS,
-  ~    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  ~    See the License for the specific language governing permissions and
-  ~    limitations under the License.
+  ~     Unless required by applicable law or agreed to in writing, software
+  ~     distributed under the License is distributed on an "AS IS" BASIS,
+  ~     WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~     See the License for the specific language governing permissions and
+  ~     limitations under the License.
   -->
 
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
-        <version>2.7.0</version>
+        <version>2.7.12</version>
         <relativePath/>
     </parent>
 

redis-keeper-spring/src/main/java/org/codeba/redis/keeper/spring/CacheTemplateProxy.java

@@ -1,17 +1,17 @@
 /*
  * Copyright (c) 2024-2025, redis-keeper ([email protected])
  *
- *    Licensed under the Apache License, Version 2.0 (the "License");
- *    you may not use this file except in compliance with the License.
- *    You may obtain a copy of the License at
+ *     Licensed under the Apache License, Version 2.0 (the "License");
+ *     you may not use this file except in compliance with the License.
+ *     You may obtain a copy of the License at
  *
- *        http://www.apache.org/licenses/LICENSE-2.0
+ *         http://www.apache.org/licenses/LICENSE-2.0
  *
- *    Unless required by applicable law or agreed to in writing, software
- *    distributed under the License is distributed on an "AS IS" BASIS,
- *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *    See the License for the specific language governing permissions and
- *    limitations under the License.
+ *     Unless required by applicable law or agreed to in writing, software
+ *     distributed under the License is distributed on an "AS IS" BASIS,
+ *     WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *     See the License for the specific language governing permissions and
+ *     limitations under the License.
  */
 
 package org.codeba.redis.keeper.spring;
@@ -22,12 +22,40 @@
 import org.codeba.redis.keeper.core.CacheTemplateProvider;
 import org.codeba.redis.keeper.core.Provider;
 
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Method;
+import java.lang.reflect.Proxy;
+import java.util.Optional;
+
 /**
  * The type Cache template proxy.
  *
  * @author codeba
  */
-public class CacheTemplateProxy {
+public class CacheTemplateProxy implements InvocationHandler {
+    private String datasource;
+    private CacheDatasourceStatus status;
+    private CacheTemplateProvider<?> templateProvider;
+
+    /**
+     * Instantiates a new Cache template proxy.
+     *
+     * @param datasource the datasource
+     */
+    public CacheTemplateProxy(String datasource) {
+        this.datasource = datasource;
+    }
+
+    /**
+     * Instantiates a new Cache template proxy.
+     *
+     * @param datasource the datasource
+     * @param status     the status
+     */
+    public CacheTemplateProxy(String datasource, CacheDatasourceStatus status) {
+        this.datasource = datasource;
+        this.status = status;
+    }
 
     /**
      * As template cache template.
@@ -59,7 +87,10 @@ public static CacheTemplate asTemplate(final String datasource, final CacheDatas
      * @return the t
      */
     public static <T> T asTemplate(final String datasource, Class<T> templateClass) {
-        return (T) getInvokeTemplate(datasource, null);
+        return (T) Proxy.newProxyInstance(
+                templateClass.getClassLoader(),
+                new Class[]{templateClass},
+                new CacheTemplateProxy(datasource));
     }
 
     /**
@@ -72,13 +103,30 @@ public static <T> T asTemplate(final String datasource, Class<T> templateClass)
      * @return the t
      */
     public static <T> T asTemplate(final String datasource, final CacheDatasourceStatus status, Class<T> templateClass) {
-        return (T) getInvokeTemplate(datasource, status);
+        return (T) Proxy.newProxyInstance(
+                templateClass.getClassLoader(),
+                new Class[]{templateClass},
+                new CacheTemplateProxy(datasource, status));
+    }
+
+    @Override
+    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
+        final String key = Provider.keyWithStatus(this.datasource, this.status);
+        final Optional<?> template = getTemplateProvider().getTemplate(key);
+        return method.invoke(template.get(), args);
     }
 
-    private static Object getInvokeTemplate(final String datasource, final CacheDatasourceStatus status) {
-        final CacheTemplateProvider provider = ApplicationContextUtil.getBean(CacheTemplateProvider.class);
-        final String key = Provider.keyWithStatus(datasource, status);
-        return provider.getTemplate(key).get();
+    /**
+     * Gets template provider.
+     *
+     * @return the template provider
+     */
+    private CacheTemplateProvider<?> getTemplateProvider() {
+        if (this.templateProvider == null) {
+            templateProvider = ApplicationContextUtil.getBean(CacheTemplateProvider.class);
+        }
+        return this.templateProvider;
     }
 
+
 }

redis-keeper-support/src/main/java/org/codeba/redis/keeper/support/CacheDatasource.java

@@ -1,17 +1,17 @@
 /*
  * Copyright (c) 2024-2025, redis-keeper ([email protected])
  *
- *    Licensed under the Apache License, Version 2.0 (the "License");
- *    you may not use this file except in compliance with the License.
- *    You may obtain a copy of the License at
+ *     Licensed under the Apache License, Version 2.0 (the "License");
+ *     you may not use this file except in compliance with the License.
+ *     You may obtain a copy of the License at
  *
- *        http://www.apache.org/licenses/LICENSE-2.0
+ *         http://www.apache.org/licenses/LICENSE-2.0
  *
- *    Unless required by applicable law or agreed to in writing, software
- *    distributed under the License is distributed on an "AS IS" BASIS,
- *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *    See the License for the specific language governing permissions and
- *    limitations under the License.
+ *     Unless required by applicable law or agreed to in writing, software
+ *     distributed under the License is distributed on an "AS IS" BASIS,
+ *     WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *     See the License for the specific language governing permissions and
+ *     limitations under the License.
  */
 
 package org.codeba.redis.keeper.support;

redis-keeper-support/src/main/java/org/codeba/redis/keeper/support/CacheKeeperConfig.java

@@ -1,17 +1,17 @@
 /*
  * Copyright (c) 2024-2025, redis-keeper ([email protected])
  *
- *    Licensed under the Apache License, Version 2.0 (the "License");
- *    you may not use this file except in compliance with the License.
- *    You may obtain a copy of the License at
+ *     Licensed under the Apache License, Version 2.0 (the "License");
+ *     you may not use this file except in compliance with the License.
+ *     You may obtain a copy of the License at
  *
- *        http://www.apache.org/licenses/LICENSE-2.0
+ *         http://www.apache.org/licenses/LICENSE-2.0
  *
- *    Unless required by applicable law or agreed to in writing, software
- *    distributed under the License is distributed on an "AS IS" BASIS,
- *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *    See the License for the specific language governing permissions and
- *    limitations under the License.
+ *     Unless required by applicable law or agreed to in writing, software
+ *     distributed under the License is distributed on an "AS IS" BASIS,
+ *     WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *     See the License for the specific language governing permissions and
+ *     limitations under the License.
  */
 
 package org.codeba.redis.keeper.support;