public class RedisCacher extends DistributedCacher implements com.lambdaworks.redis.event.EventBus
MemoryCacher,
OHCacher| Modifier and Type | Field and Description |
|---|---|
protected RedisGetSetClient |
client |
protected MetricCounter |
counterClean |
protected MetricCounter |
counterDel |
protected MetricCounter |
counterFound |
protected MetricCounter |
counterGet |
protected MetricCounter |
counterSet |
protected java.util.concurrent.ExecutorService |
executor |
protected com.lambdaworks.redis.SetArgs |
expiration |
protected java.lang.String |
password |
protected java.util.concurrent.ScheduledExecutorService |
scheduler |
protected boolean |
secure |
protected Serializer |
serializer |
protected java.util.concurrent.atomic.AtomicInteger |
status |
protected static int |
STATUS_CONNECTED |
protected static int |
STATUS_CONNECTING |
protected static int |
STATUS_DISCONNECTED |
protected static int |
STATUS_DISCONNECTING |
protected static int |
STATUS_STOPPED |
protected int |
ttl |
protected java.lang.String[] |
urls |
CONTENT, hashers, maxParamsLengthbroker, logger, nameMOLECULER_CACHER_CLEAN_TIME, MOLECULER_CACHER_CLEAN_TIME_DESC, MOLECULER_CACHER_CLEAN_TOTAL, MOLECULER_CACHER_CLEAN_TOTAL_DESC, MOLECULER_CACHER_DEL_TIME, MOLECULER_CACHER_DEL_TIME_DESC, MOLECULER_CACHER_DEL_TOTAL, MOLECULER_CACHER_DEL_TOTAL_DESC, MOLECULER_CACHER_EXPIRED_TOTAL, MOLECULER_CACHER_EXPIRED_TOTAL_DESC, MOLECULER_CACHER_FOUND_TOTAL, MOLECULER_CACHER_FOUND_TOTAL_DESC, MOLECULER_CACHER_GET_TIME, MOLECULER_CACHER_GET_TIME_DESC, MOLECULER_CACHER_GET_TOTAL, MOLECULER_CACHER_GET_TOTAL_DESC, MOLECULER_CACHER_SET_TIME, MOLECULER_CACHER_SET_TIME_DESC, MOLECULER_CACHER_SET_TOTAL, MOLECULER_CACHER_SET_TOTAL_DESC, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL_DESC, MOLECULER_EVENT_BROADCAST_TOTAL, MOLECULER_EVENT_BROADCAST_TOTAL_DESC, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL_DESC, MOLECULER_EVENT_EMIT_TOTAL, MOLECULER_EVENT_EMIT_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_ACTIVE, MOLECULER_EVENT_RECEIVED_ACTIVE_DESC, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_TIME, MOLECULER_EVENT_RECEIVED_TIME_DESC, MOLECULER_EVENT_RECEIVED_TOTAL, MOLECULER_EVENT_RECEIVED_TOTAL_DESC, MOLECULER_EXECUTOR, MOLECULER_REQUEST_ACTIVE, MOLECULER_REQUEST_ACTIVE_DESC, MOLECULER_REQUEST_ERROR_TOTAL, MOLECULER_REQUEST_ERROR_TOTAL_DESC, MOLECULER_REQUEST_LEVELS, MOLECULER_REQUEST_LEVELS_DESC, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL_DESC, MOLECULER_REQUEST_TIME, MOLECULER_REQUEST_TIME_DESC, MOLECULER_REQUEST_TIMEOUT_TOTAL, MOLECULER_REQUEST_TIMEOUT_TOTAL_DESC, MOLECULER_REQUEST_TOTAL, MOLECULER_REQUEST_TOTAL_DESC, MOLECULER_SCHEDULER, MOLECULER_TRANSIT_CONNECTED, MOLECULER_TRANSIT_CONNECTED_DESC, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL_DESC, MOLECULER_TRANSIT_REQUESTS_ACTIVE, MOLECULER_TRANSIT_REQUESTS_ACTIVE_DESC, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL_DESC| Constructor and Description |
|---|
RedisCacher() |
RedisCacher(java.lang.String... urls) |
RedisCacher(java.lang.String password,
int defaultTtl,
boolean secure,
java.lang.String... urls) |
| Modifier and Type | Method and Description |
|---|---|
io.datatree.Promise |
clean(java.lang.String match)
Cleans this cache.
|
protected void |
connect() |
io.datatree.Promise |
del(java.lang.String key)
Deletes a content from this cache.
|
protected io.datatree.Promise |
disconnect() |
rx.Observable<com.lambdaworks.redis.event.Event> |
get() |
io.datatree.Promise |
get(java.lang.String key)
Gets a cached content by a key.
|
io.datatree.Promise |
getCacheKeys()
Lists all keys of cached entries.
|
java.lang.String |
getPassword() |
Serializer |
getSerializer() |
int |
getTtl() |
java.lang.String[] |
getUrls() |
boolean |
isSecure() |
void |
publish(com.lambdaworks.redis.event.Event event) |
protected void |
reconnect() |
io.datatree.Promise |
set(java.lang.String key,
io.datatree.Tree value,
int ttl)
Sets a content by key into the cache.
|
void |
setPassword(java.lang.String password) |
void |
setSecure(boolean useSSL) |
void |
setSerializer(Serializer serializer) |
void |
setTtl(int ttl) |
void |
setUrls(java.lang.String... urls) |
void |
started(ServiceBroker broker)
Initializes cacher instance.
|
void |
stopped() |
getCacheKey, getMaxParamsLength, setMaxParamsLengthappendToKey, appendTree, install, isCachingDisabledByTheContext, serializeKeygetBroker, getLogger, getNameprotected static final int STATUS_DISCONNECTING
protected static final int STATUS_DISCONNECTED
protected static final int STATUS_CONNECTING
protected static final int STATUS_CONNECTED
protected static final int STATUS_STOPPED
protected final java.util.concurrent.atomic.AtomicInteger status
protected java.lang.String password
protected int ttl
protected boolean secure
protected java.lang.String[] urls
protected RedisGetSetClient client
protected Serializer serializer
protected java.util.concurrent.ExecutorService executor
protected java.util.concurrent.ScheduledExecutorService scheduler
protected com.lambdaworks.redis.SetArgs expiration
protected MetricCounter counterGet
protected MetricCounter counterSet
protected MetricCounter counterDel
protected MetricCounter counterClean
protected MetricCounter counterFound
public RedisCacher()
public RedisCacher(java.lang.String... urls)
public RedisCacher(java.lang.String password,
int defaultTtl,
boolean secure,
java.lang.String... urls)
public void started(ServiceBroker broker) throws java.lang.Exception
started in interface MoleculerLifecyclestarted in class Cacherbroker - parent ServiceBrokerjava.lang.Exceptionprotected void connect()
protected io.datatree.Promise disconnect()
protected void reconnect()
public void stopped()
stopped in interface MoleculerLifecyclestopped in class MoleculerComponentpublic io.datatree.Promise get(java.lang.String key)
Cacherpublic io.datatree.Promise set(java.lang.String key,
io.datatree.Tree value,
int ttl)
Cacherpublic io.datatree.Promise del(java.lang.String key)
Cacherpublic io.datatree.Promise clean(java.lang.String match)
Cacherpublic io.datatree.Promise getCacheKeys()
getCacheKeys in class Cacherpublic void publish(com.lambdaworks.redis.event.Event event)
publish in interface com.lambdaworks.redis.event.EventBuspublic rx.Observable<com.lambdaworks.redis.event.Event> get()
get in interface com.lambdaworks.redis.event.EventBuspublic java.lang.String[] getUrls()
public void setUrls(java.lang.String... urls)
public java.lang.String getPassword()
public void setPassword(java.lang.String password)
public boolean isSecure()
public void setSecure(boolean useSSL)
public int getTtl()
public void setTtl(int ttl)
public Serializer getSerializer()
public void setSerializer(Serializer serializer)