Skip to content

Commit ef8346f

Browse files
author
codeba
committed
feat: Add pipeline method for list,set,sortedset,string,script
1 parent f7ebc89 commit ef8346f

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

43 files changed

+5685
-7092
lines changed

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

Lines changed: 14 additions & 2408 deletions
Large diffs are not rendered by default.

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

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,40 @@ public interface KBatch {
5858
*/
5959
KHyperLogLogAsync getHyperLogLog();
6060

61+
/**
62+
* Gets list.
63+
*
64+
* @return the list
65+
*/
66+
KListAsync getList();
67+
68+
/**
69+
* Gets set.
70+
*
71+
* @return the set
72+
*/
73+
KSetAsync getSet();
74+
75+
/**
76+
* Gets sorted set.
77+
*
78+
* @return the sorted set
79+
*/
80+
KZSetAsync getSortedSet();
81+
82+
/**
83+
* Gets string.
84+
*
85+
* @return the string
86+
*/
87+
KStringAsync getString();
88+
89+
/**
90+
* Gets script.
91+
*
92+
* @return the script
93+
*/
94+
KScriptAsync getScript();
6195

6296
/**
6397
* Execute.
Lines changed: 83 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,83 @@
1+
/*
2+
* Copyright (c) 2024-2025, redis-keeper ([email protected])
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
17+
package org.codeba.redis.keeper.core;
18+
19+
import java.util.concurrent.CompletableFuture;
20+
21+
public interface KBloomFilter {
22+
/**
23+
* Bf add boolean.
24+
*
25+
* @param key the key
26+
* @param item the item
27+
* @return the boolean
28+
*/
29+
boolean bfAdd(String key, Object item);
30+
31+
/**
32+
* Bf card long.
33+
*
34+
* @param key the key
35+
* @return the long
36+
*/
37+
long bfCard(String key);
38+
39+
/**
40+
* Bf exists boolean.
41+
*
42+
* @param key the key
43+
* @param item the item
44+
* @return the boolean
45+
*/
46+
boolean bfExists(String key, Object item);
47+
48+
/**
49+
* Bfm add boolean.
50+
*
51+
* @param key the key
52+
* @param item the item
53+
* @return the boolean
54+
*/
55+
boolean bfmAdd(String key, Object item);
56+
57+
/**
58+
* Bf reserve boolean.
59+
*
60+
* @param key the key
61+
* @param expectedInsertions the expected insertions
62+
* @param falseProbability the false probability
63+
* @return the boolean
64+
*/
65+
boolean bfReserve(String key, long expectedInsertions, double falseProbability);
66+
67+
/**
68+
* Delete bf boolean.
69+
*
70+
* @param key the key
71+
* @return the boolean
72+
*/
73+
boolean deleteBf(String key);
74+
75+
/**
76+
* Delete bf async completable future.
77+
*
78+
* @param key the key
79+
* @return the completable future
80+
*/
81+
CompletableFuture<Boolean> deleteBfAsync(String key);
82+
83+
}

0 commit comments

Comments
 (0)