模块 org.redkale

程序包 org.redkale.cached.spi

类 CachedLocalSource

java.lang.Object

org.redkale.cached.spi.CachedLocalSource

所有已实现的接口:

Service

@AutoLoad(false)
public class CachedLocalSource
extends Object
implements Service

本地缓存源

详情见: https://redkale.org

从以下版本开始:

2.8.0

作者:

zhangjx

嵌套类概要

嵌套类

修饰符和类型	类	说明
protected static class	CachedLocalSource.CacheItem
protected static class	CachedLocalSource.CacheMap

构造器概要

构造器

构造器	说明
CachedLocalSource()

方法概要

修饰符和类型	方法	说明
long	del(String name, String key)
CompletableFuture<Long>	delAsync(String name, String key)
void	destroy(AnyValue conf)	进程退出时，调用Service销毁 远程模式下该方法会重载成空方法 注意： 在此方法内不能调用MessageClient.sendMessage 方法，因为Application关闭时会先destroy掉MessageClient
<T> T	get(String name, String key, Type type)
<T> CompletableFuture<T>	getAsync(String name, String key, Type type)
int	getSize(String name)
void	init(AnyValue conf)	该方法必须是可以重复调用， 当reload时需要重复调用init方法 远程模式下该方法会重载成空方法
<T> void	set(String name, String key, int localLimit, long millis, Type type, T value)
<T> CompletableFuture<Void>	setAsync(String name, String key, int localLimit, long millis, Type type, T value)
int	updateLimit(String name, int limit)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

CachedLocalSource

public CachedLocalSource()

方法详细资料

init

public void init(AnyValue conf)

从接口复制的说明: Service

该方法必须是可以重复调用， 当reload时需要重复调用init方法 远程模式下该方法会重载成空方法

指定者:

init 在接口中 Service

参数:

conf - 配置参数

destroy

public void destroy(AnyValue conf)

从接口复制的说明: Service

进程退出时，调用Service销毁 远程模式下该方法会重载成空方法 注意： 在此方法内不能调用MessageClient.sendMessage 方法，因为Application关闭时会先destroy掉MessageClient

指定者:

destroy 在接口中 Service

参数:

conf - 配置参数

set

public <T> void set(String name,
                    String key,
                    int localLimit,
                    long millis,
                    Type type,
                    T value)

get

public <T> T get(String name,
                 String key,
                 Type type)

del

public long del(String name,
                String key)

getAsync

public <T> CompletableFuture<T> getAsync(String name,
                                         String key,
                                         Type type)

delAsync

public CompletableFuture<Long> delAsync(String name,
                                        String key)

setAsync

public <T> CompletableFuture<Void> setAsync(String name,
                                            String key,
                                            int localLimit,
                                            long millis,
                                            Type type,
                                            T value)

getSize

public int getSize(String name)

updateLimit

public int updateLimit(String name,
                       int limit)