org.redkale.source

接口 CacheSource<V>

类型参数:

V - value的类型

详情见: https://redkale.org

所有已知实现类:

CacheMemorySource

public interface CacheSource<V>

Redkale中缓存数据源的核心类。 主要供业务开发者使用， 技术开发者提供CacheSource的实现。
CacheSource提供三种数据类型操作: String、Long和泛型指定的数据类型。
String统一用setString、getString等系列方法。
Long统一用setLong、getLong、incr等系列方法。
其他则供自定义数据类型使用。

嵌套类概要

嵌套类

限定符和类型	接口和说明
static class	CacheSource.CacheEntry<T>
static class	CacheSource.CacheEntryType

方法概要

限定符和类型	方法和说明
void	appendListItem(java.lang.String key, V value)
java.util.concurrent.CompletableFuture<java.lang.Void>	appendListItemAsync(java.lang.String key, V value)
void	appendLongListItem(java.lang.String key, long value)
java.util.concurrent.CompletableFuture<java.lang.Void>	appendLongListItemAsync(java.lang.String key, long value)
void	appendLongSetItem(java.lang.String key, long value)
java.util.concurrent.CompletableFuture<java.lang.Void>	appendLongSetItemAsync(java.lang.String key, long value)
void	appendSetItem(java.lang.String key, V value)
java.util.concurrent.CompletableFuture<java.lang.Void>	appendSetItemAsync(java.lang.String key, V value)
void	appendStringListItem(java.lang.String key, java.lang.String value)
java.util.concurrent.CompletableFuture<java.lang.Void>	appendStringListItemAsync(java.lang.String key, java.lang.String value)
void	appendStringSetItem(java.lang.String key, java.lang.String value)
java.util.concurrent.CompletableFuture<java.lang.Void>	appendStringSetItemAsync(java.lang.String key, java.lang.String value)
long	decr(java.lang.String key)
long	decr(java.lang.String key, long num)
java.util.concurrent.CompletableFuture<java.lang.Long>	decrAsync(java.lang.String key)
java.util.concurrent.CompletableFuture<java.lang.Long>	decrAsync(java.lang.String key, long num)
boolean	exists(java.lang.String key)
java.util.concurrent.CompletableFuture<java.lang.Boolean>	existsAsync(java.lang.String key)
boolean	existsLongSetItem(java.lang.String key, long value)
java.util.concurrent.CompletableFuture<java.lang.Boolean>	existsLongSetItemAsync(java.lang.String key, long value)
boolean	existsSetItem(java.lang.String key, V value)
java.util.concurrent.CompletableFuture<java.lang.Boolean>	existsSetItemAsync(java.lang.String key, V value)
boolean	existsStringSetItem(java.lang.String key, java.lang.String value)
java.util.concurrent.CompletableFuture<java.lang.Boolean>	existsStringSetItemAsync(java.lang.String key, java.lang.String value)
V	get(java.lang.String key)
V	getAndRefresh(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<V>	getAndRefreshAsync(java.lang.String key, int expireSeconds)
default V	getAndRefreshIfAbsent(java.lang.String key, int expireSeconds, java.util.function.Function<java.lang.String,? extends V> mappingFunction)
default java.util.concurrent.CompletableFuture<V>	getAndRefreshIfAbsentAsync(java.lang.String key, int expireSeconds, java.util.function.Function<java.lang.String,? extends V> mappingFunction)
java.util.concurrent.CompletableFuture<V>	getAsync(java.lang.String key)
java.util.Collection<V>	getCollection(java.lang.String key)
java.util.Collection<V>	getCollectionAndRefresh(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<java.util.Collection<V>>	getCollectionAndRefreshAsync(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<java.util.Collection<V>>	getCollectionAsync(java.lang.String key)
int	getCollectionSize(java.lang.String key)
java.util.concurrent.CompletableFuture<java.lang.Integer>	getCollectionSizeAsync(java.lang.String key)
default V	getIfAbsent(java.lang.String key, java.util.function.Function<java.lang.String,? extends V> mappingFunction)
default java.util.concurrent.CompletableFuture<V>	getIfAbsentAsync(java.lang.String key, java.util.function.Function<java.lang.String,? extends V> mappingFunction)
int	getKeySize()
java.util.concurrent.CompletableFuture<java.lang.Integer>	getKeySizeAsync()
long	getLong(java.lang.String key, long defValue)
long	getLongAndRefresh(java.lang.String key, int expireSeconds, long defValue)
java.util.concurrent.CompletableFuture<java.lang.Long>	getLongAndRefreshAsync(java.lang.String key, int expireSeconds, long defValue)
java.util.concurrent.CompletableFuture<java.lang.Long>	getLongAsync(java.lang.String key, long defValue)
java.util.Collection<java.lang.Long>	getLongCollection(java.lang.String key)
java.util.Collection<java.lang.Long>	getLongCollectionAndRefresh(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<java.util.Collection<java.lang.Long>>	getLongCollectionAndRefreshAsync(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<java.util.Collection<java.lang.Long>>	getLongCollectionAsync(java.lang.String key)
java.lang.String	getString(java.lang.String key)
java.lang.String	getStringAndRefresh(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<java.lang.String>	getStringAndRefreshAsync(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<java.lang.String>	getStringAsync(java.lang.String key)
java.util.Collection<java.lang.String>	getStringCollection(java.lang.String key)
java.util.Collection<java.lang.String>	getStringCollectionAndRefresh(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<java.util.Collection<java.lang.String>>	getStringCollectionAndRefreshAsync(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<java.util.Collection<java.lang.String>>	getStringCollectionAsync(java.lang.String key)
java.lang.String	getType()
long	incr(java.lang.String key)
long	incr(java.lang.String key, long num)
java.util.concurrent.CompletableFuture<java.lang.Long>	incrAsync(java.lang.String key)
java.util.concurrent.CompletableFuture<java.lang.Long>	incrAsync(java.lang.String key, long num)
void	initTransient(boolean flag)
void	initValueType(java.lang.reflect.Type valueType)
default boolean	isOpen()
default java.util.concurrent.CompletableFuture<java.lang.Boolean>	isOpenAsync()
java.util.List<java.lang.String>	queryKeys()
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>	queryKeysAsync()
java.util.List<CacheSource.CacheEntry<java.lang.Object>>	queryList()
java.util.concurrent.CompletableFuture<java.util.List<CacheSource.CacheEntry<java.lang.Object>>>	queryListAsync()
void	refresh(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<java.lang.Void>	refreshAsync(java.lang.String key, int expireSeconds)
void	remove(java.lang.String key)
java.util.concurrent.CompletableFuture<java.lang.Void>	removeAsync(java.lang.String key)
void	removeListItem(java.lang.String key, V value)
java.util.concurrent.CompletableFuture<java.lang.Void>	removeListItemAsync(java.lang.String key, V value)
void	removeLongListItem(java.lang.String key, long value)
java.util.concurrent.CompletableFuture<java.lang.Void>	removeLongListItemAsync(java.lang.String key, long value)
void	removeLongSetItem(java.lang.String key, long value)
java.util.concurrent.CompletableFuture<java.lang.Void>	removeLongSetItemAsync(java.lang.String key, long value)
void	removeSetItem(java.lang.String key, V value)
java.util.concurrent.CompletableFuture<java.lang.Void>	removeSetItemAsync(java.lang.String key, V value)
void	removeStringListItem(java.lang.String key, java.lang.String value)
java.util.concurrent.CompletableFuture<java.lang.Void>	removeStringListItemAsync(java.lang.String key, java.lang.String value)
void	removeStringSetItem(java.lang.String key, java.lang.String value)
java.util.concurrent.CompletableFuture<java.lang.Void>	removeStringSetItemAsync(java.lang.String key, java.lang.String value)
void	set(int expireSeconds, java.lang.String key, V value)
void	set(java.lang.String key, V value)
java.util.concurrent.CompletableFuture<java.lang.Void>	setAsync(int expireSeconds, java.lang.String key, V value)
java.util.concurrent.CompletableFuture<java.lang.Void>	setAsync(java.lang.String key, V value)
void	setExpireSeconds(java.lang.String key, int expireSeconds)
java.util.concurrent.CompletableFuture<java.lang.Void>	setExpireSecondsAsync(java.lang.String key, int expireSeconds)
void	setLong(int expireSeconds, java.lang.String key, long value)
void	setLong(java.lang.String key, long value)
java.util.concurrent.CompletableFuture<java.lang.Void>	setLongAsync(int expireSeconds, java.lang.String key, long value)
java.util.concurrent.CompletableFuture<java.lang.Void>	setLongAsync(java.lang.String key, long value)
void	setString(int expireSeconds, java.lang.String key, java.lang.String value)
void	setString(java.lang.String key, java.lang.String value)
java.util.concurrent.CompletableFuture<java.lang.Void>	setStringAsync(int expireSeconds, java.lang.String key, java.lang.String value)
java.util.concurrent.CompletableFuture<java.lang.Void>	setStringAsync(java.lang.String key, java.lang.String value)

方法详细资料

getType

java.lang.String getType()

initValueType

void initValueType(java.lang.reflect.Type valueType)

initTransient

void initTransient(boolean flag)

isOpen

default boolean isOpen()

exists

boolean exists(java.lang.String key)

get

V get(java.lang.String key)

getIfAbsent

default V getIfAbsent(java.lang.String key,
                      java.util.function.Function<java.lang.String,? extends V> mappingFunction)

getAndRefresh

V getAndRefresh(java.lang.String key,
                int expireSeconds)

getAndRefreshIfAbsent

default V getAndRefreshIfAbsent(java.lang.String key,
                                int expireSeconds,
                                java.util.function.Function<java.lang.String,? extends V> mappingFunction)

refresh

void refresh(java.lang.String key,
             int expireSeconds)

set

void set(java.lang.String key,
         V value)

set

void set(int expireSeconds,
         java.lang.String key,
         V value)

setExpireSeconds

void setExpireSeconds(java.lang.String key,
                      int expireSeconds)

remove

void remove(java.lang.String key)

incr

long incr(java.lang.String key)

incr

long incr(java.lang.String key,
          long num)

decr

long decr(java.lang.String key)

decr

long decr(java.lang.String key,
          long num)

getCollection

java.util.Collection<V> getCollection(java.lang.String key)

getCollectionSize

int getCollectionSize(java.lang.String key)

getCollectionAndRefresh

java.util.Collection<V> getCollectionAndRefresh(java.lang.String key,
                                                int expireSeconds)

appendListItem

void appendListItem(java.lang.String key,
                    V value)

removeListItem

void removeListItem(java.lang.String key,
                    V value)

existsSetItem

boolean existsSetItem(java.lang.String key,
                      V value)

appendSetItem

void appendSetItem(java.lang.String key,
                   V value)

removeSetItem

void removeSetItem(java.lang.String key,
                   V value)

queryKeys

java.util.List<java.lang.String> queryKeys()

getKeySize

int getKeySize()

queryList

java.util.List<CacheSource.CacheEntry<java.lang.Object>> queryList()

getString

java.lang.String getString(java.lang.String key)

getStringAndRefresh

java.lang.String getStringAndRefresh(java.lang.String key,
                                     int expireSeconds)

setString

void setString(java.lang.String key,
               java.lang.String value)

setString

void setString(int expireSeconds,
               java.lang.String key,
               java.lang.String value)

getStringCollection

java.util.Collection<java.lang.String> getStringCollection(java.lang.String key)

getStringCollectionAndRefresh

java.util.Collection<java.lang.String> getStringCollectionAndRefresh(java.lang.String key,
                                                                     int expireSeconds)

appendStringListItem

void appendStringListItem(java.lang.String key,
                          java.lang.String value)

removeStringListItem

void removeStringListItem(java.lang.String key,
                          java.lang.String value)

existsStringSetItem

boolean existsStringSetItem(java.lang.String key,
                            java.lang.String value)

appendStringSetItem

void appendStringSetItem(java.lang.String key,
                         java.lang.String value)

removeStringSetItem

void removeStringSetItem(java.lang.String key,
                         java.lang.String value)

getLong

long getLong(java.lang.String key,
             long defValue)

getLongAndRefresh

long getLongAndRefresh(java.lang.String key,
                       int expireSeconds,
                       long defValue)

setLong

void setLong(java.lang.String key,
             long value)

setLong

void setLong(int expireSeconds,
             java.lang.String key,
             long value)

getLongCollection

java.util.Collection<java.lang.Long> getLongCollection(java.lang.String key)

getLongCollectionAndRefresh

java.util.Collection<java.lang.Long> getLongCollectionAndRefresh(java.lang.String key,
                                                                 int expireSeconds)

appendLongListItem

void appendLongListItem(java.lang.String key,
                        long value)

removeLongListItem

void removeLongListItem(java.lang.String key,
                        long value)

existsLongSetItem

boolean existsLongSetItem(java.lang.String key,
                          long value)

appendLongSetItem

void appendLongSetItem(java.lang.String key,
                       long value)

removeLongSetItem

void removeLongSetItem(java.lang.String key,
                       long value)

existsAsync

java.util.concurrent.CompletableFuture<java.lang.Boolean> existsAsync(java.lang.String key)

getAsync

java.util.concurrent.CompletableFuture<V> getAsync(java.lang.String key)

getIfAbsentAsync

default java.util.concurrent.CompletableFuture<V> getIfAbsentAsync(java.lang.String key,
                                                                   java.util.function.Function<java.lang.String,? extends V> mappingFunction)

getAndRefreshAsync

java.util.concurrent.CompletableFuture<V> getAndRefreshAsync(java.lang.String key,
                                                             int expireSeconds)

getAndRefreshIfAbsentAsync

default java.util.concurrent.CompletableFuture<V> getAndRefreshIfAbsentAsync(java.lang.String key,
                                                                             int expireSeconds,
                                                                             java.util.function.Function<java.lang.String,? extends V> mappingFunction)

refreshAsync

java.util.concurrent.CompletableFuture<java.lang.Void> refreshAsync(java.lang.String key,
                                                                    int expireSeconds)

setAsync

java.util.concurrent.CompletableFuture<java.lang.Void> setAsync(java.lang.String key,
                                                                V value)

setAsync

java.util.concurrent.CompletableFuture<java.lang.Void> setAsync(int expireSeconds,
                                                                java.lang.String key,
                                                                V value)

setExpireSecondsAsync

java.util.concurrent.CompletableFuture<java.lang.Void> setExpireSecondsAsync(java.lang.String key,
                                                                             int expireSeconds)

removeAsync

java.util.concurrent.CompletableFuture<java.lang.Void> removeAsync(java.lang.String key)

incrAsync

java.util.concurrent.CompletableFuture<java.lang.Long> incrAsync(java.lang.String key)

incrAsync

java.util.concurrent.CompletableFuture<java.lang.Long> incrAsync(java.lang.String key,
                                                                 long num)

decrAsync

java.util.concurrent.CompletableFuture<java.lang.Long> decrAsync(java.lang.String key)

decrAsync

java.util.concurrent.CompletableFuture<java.lang.Long> decrAsync(java.lang.String key,
                                                                 long num)

getCollectionAsync

java.util.concurrent.CompletableFuture<java.util.Collection<V>> getCollectionAsync(java.lang.String key)

getCollectionSizeAsync

java.util.concurrent.CompletableFuture<java.lang.Integer> getCollectionSizeAsync(java.lang.String key)

getCollectionAndRefreshAsync

java.util.concurrent.CompletableFuture<java.util.Collection<V>> getCollectionAndRefreshAsync(java.lang.String key,
                                                                                             int expireSeconds)

appendListItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> appendListItemAsync(java.lang.String key,
                                                                           V value)

removeListItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> removeListItemAsync(java.lang.String key,
                                                                           V value)

existsSetItemAsync

java.util.concurrent.CompletableFuture<java.lang.Boolean> existsSetItemAsync(java.lang.String key,
                                                                             V value)

appendSetItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> appendSetItemAsync(java.lang.String key,
                                                                          V value)

removeSetItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> removeSetItemAsync(java.lang.String key,
                                                                          V value)

queryKeysAsync

java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> queryKeysAsync()

getKeySizeAsync

java.util.concurrent.CompletableFuture<java.lang.Integer> getKeySizeAsync()

queryListAsync

java.util.concurrent.CompletableFuture<java.util.List<CacheSource.CacheEntry<java.lang.Object>>> queryListAsync()

getStringAsync

java.util.concurrent.CompletableFuture<java.lang.String> getStringAsync(java.lang.String key)

getStringAndRefreshAsync

java.util.concurrent.CompletableFuture<java.lang.String> getStringAndRefreshAsync(java.lang.String key,
                                                                                  int expireSeconds)

setStringAsync

java.util.concurrent.CompletableFuture<java.lang.Void> setStringAsync(java.lang.String key,
                                                                      java.lang.String value)

setStringAsync

java.util.concurrent.CompletableFuture<java.lang.Void> setStringAsync(int expireSeconds,
                                                                      java.lang.String key,
                                                                      java.lang.String value)

getStringCollectionAsync

java.util.concurrent.CompletableFuture<java.util.Collection<java.lang.String>> getStringCollectionAsync(java.lang.String key)

getStringCollectionAndRefreshAsync

java.util.concurrent.CompletableFuture<java.util.Collection<java.lang.String>> getStringCollectionAndRefreshAsync(java.lang.String key,
                                                                                                                  int expireSeconds)

appendStringListItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> appendStringListItemAsync(java.lang.String key,
                                                                                 java.lang.String value)

removeStringListItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> removeStringListItemAsync(java.lang.String key,
                                                                                 java.lang.String value)

existsStringSetItemAsync

java.util.concurrent.CompletableFuture<java.lang.Boolean> existsStringSetItemAsync(java.lang.String key,
                                                                                   java.lang.String value)

appendStringSetItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> appendStringSetItemAsync(java.lang.String key,
                                                                                java.lang.String value)

removeStringSetItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> removeStringSetItemAsync(java.lang.String key,
                                                                                java.lang.String value)

getLongAsync

java.util.concurrent.CompletableFuture<java.lang.Long> getLongAsync(java.lang.String key,
                                                                    long defValue)

getLongAndRefreshAsync

java.util.concurrent.CompletableFuture<java.lang.Long> getLongAndRefreshAsync(java.lang.String key,
                                                                              int expireSeconds,
                                                                              long defValue)

setLongAsync

java.util.concurrent.CompletableFuture<java.lang.Void> setLongAsync(java.lang.String key,
                                                                    long value)

setLongAsync

java.util.concurrent.CompletableFuture<java.lang.Void> setLongAsync(int expireSeconds,
                                                                    java.lang.String key,
                                                                    long value)

getLongCollectionAsync

java.util.concurrent.CompletableFuture<java.util.Collection<java.lang.Long>> getLongCollectionAsync(java.lang.String key)

getLongCollectionAndRefreshAsync

java.util.concurrent.CompletableFuture<java.util.Collection<java.lang.Long>> getLongCollectionAndRefreshAsync(java.lang.String key,
                                                                                                              int expireSeconds)

appendLongListItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> appendLongListItemAsync(java.lang.String key,
                                                                               long value)

removeLongListItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> removeLongListItemAsync(java.lang.String key,
                                                                               long value)

existsLongSetItemAsync

java.util.concurrent.CompletableFuture<java.lang.Boolean> existsLongSetItemAsync(java.lang.String key,
                                                                                 long value)

appendLongSetItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> appendLongSetItemAsync(java.lang.String key,
                                                                              long value)

removeLongSetItemAsync

java.util.concurrent.CompletableFuture<java.lang.Void> removeLongSetItemAsync(java.lang.String key,
                                                                              long value)

isOpenAsync

default java.util.concurrent.CompletableFuture<java.lang.Boolean> isOpenAsync()