feat: Add pipeline method for bitmap,generic,geo,hash,hyperloglog

Author: codeba

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

@@ -0,0 +1,88 @@
+/*
+ * 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
+ *
+ *         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.
+ */
+
+package org.codeba.redis.keeper.core;
+
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * The interface K batch.
+ */
+public interface KBatch {
+    /**
+     * Gets bit map.
+     *
+     * @return the bit map
+     */
+    KBitSetAsync getBitMap();
+
+    /**
+     * Gets generic.
+     *
+     * @return the generic
+     */
+    KGenericAsync getGeneric();
+
+    /**
+     * Gets geo.
+     *
+     * @return the geo
+     */
+    KGeoAsync getGeo();
+
+    /**
+     * Gets hash.
+     *
+     * @return the hash
+     */
+    KMapAsync getHash();
+
+    /**
+     * Gets hyper log log.
+     *
+     * @return the hyper log log
+     */
+    KHyperLogLogAsync getHyperLogLog();
+
+
+    /**
+     * Execute.
+     */
+    void execute();
+
+    /**
+     * Execute async completable future.
+     *
+     * @return the completable future
+     */
+    CompletableFuture<Void> executeAsync();
+
+    /**
+     * Execute with responses list.
+     *
+     * @return the list
+     */
+    List<?> executeWithResponses();
+
+    /**
+     * Execute with responses async completable future.
+     *
+     * @return the completable future
+     */
+    CompletableFuture<List<?>> executeWithResponsesAsync();
+
+}

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

@@ -0,0 +1,100 @@
+/*
+ * 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
+ *
+ *         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.
+ */
+
+package org.codeba.redis.keeper.core;
+
+/**
+ * The interface K bit map.
+ */
+public interface KBitSet extends KBitSetAsync {
+    /**
+     * Bit count long.
+     *
+     * @param key the key
+     * @return the long
+     */
+    long bitCount(String key);
+
+    /**
+     * Bit field set signed long.
+     *
+     * @param key    the key
+     * @param size   the size
+     * @param offset the offset
+     * @param value  the value
+     * @return the long
+     */
+    long bitFieldSetSigned(String key, int size, long offset, long value);
+
+    /**
+     * Bit field set un signed long.
+     *
+     * @param key    the key
+     * @param size   the size
+     * @param offset the offset
+     * @param value  the value
+     * @return the long
+     */
+    long bitFieldSetUnSigned(String key, int size, long offset, long value);
+
+    /**
+     * Bit field get signed long.
+     *
+     * @param key    the key
+     * @param size   the size
+     * @param offset the offset
+     * @return the long
+     */
+    long bitFieldGetSigned(String key, int size, long offset);
+
+    /**
+     * Bit field get un signed long.
+     *
+     * @param key    the key
+     * @param size   the size
+     * @param offset the offset
+     * @return the long
+     */
+    long bitFieldGetUnSigned(String key, int size, long offset);
+
+    /**
+     * Bit op or.
+     *
+     * @param destKey the dest key
+     * @param keys    the keys
+     */
+    void bitOpOr(String destKey, String... keys);
+
+    /**
+     * Gets bit.
+     *
+     * @param key      the key
+     * @param bitIndex the bit index
+     * @return the bit
+     */
+    boolean getBit(String key, long bitIndex);
+
+    /**
+     * Sets bit.
+     *
+     * @param key    the key
+     * @param offset the offset
+     * @param value  the value
+     * @return the bit: the original bit value stored at offset.
+     */
+    boolean setBit(String key, long offset, boolean value);
+
+}

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

@@ -0,0 +1,103 @@
+/*
+ * 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
+ *
+ *         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.
+ */
+
+package org.codeba.redis.keeper.core;
+
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * The interface K bit map async.
+ */
+public interface KBitSetAsync {
+    /**
+     * Bit count async completable future.
+     *
+     * @param key the key
+     * @return the completable future
+     */
+    CompletableFuture<Long> bitCountAsync(String key);
+
+    /**
+     * Bit field set signed async completable future.
+     *
+     * @param key    the key
+     * @param size   the size
+     * @param offset the offset
+     * @param value  the value
+     * @return the completable future
+     */
+    CompletableFuture<Long> bitFieldSetSignedAsync(String key, int size, long offset, long value);
+
+    /**
+     * Bit field set un signed async completable future.
+     *
+     * @param key    the key
+     * @param size   the size
+     * @param offset the offset
+     * @param value  the value
+     * @return the completable future
+     */
+    CompletableFuture<Long> bitFieldSetUnSignedAsync(String key, int size, long offset, long value);
+
+    /**
+     * Bit field get signed async completable future.
+     *
+     * @param key    the key
+     * @param size   the size
+     * @param offset the offset
+     * @return the completable future
+     */
+    CompletableFuture<Long> bitFieldGetSignedAsync(String key, int size, long offset);
+
+    /**
+     * Bit field get un signed async completable future.
+     *
+     * @param key    the key
+     * @param size   the size
+     * @param offset the offset
+     * @return the completable future
+     */
+    CompletableFuture<Long> bitFieldGetUnSignedAsync(String key, int size, long offset);
+
+    /**
+     * Bit op or async completable future.
+     *
+     * @param destKey the dest key
+     * @param keys    the keys
+     * @return the completable future
+     */
+    CompletableFuture<Void> bitOpOrAsync(String destKey, String... keys);
+
+    /**
+     * Gets bit async.
+     *
+     * @param key      the key
+     * @param bitIndex the bit index
+     * @return the bit async
+     */
+    CompletableFuture<Boolean> getBitAsync(String key, long bitIndex);
+
+    /**
+     * Sets bit async.
+     *
+     * @param key    the key
+     * @param offset the offset
+     * @param value  the value
+     * @return the bit async
+     */
+    CompletableFuture<Boolean> setBitAsync(String key, long offset, boolean value);
+
+}