Class DistributedCacher

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.Middleware

services.moleculer.cacher.Cacher

services.moleculer.cacher.DistributedCacher

All Implemented Interfaces:

MetricConstants, MoleculerLifecycle

Direct Known Subclasses:

JCacheCacher, RedisCacher

public abstract class DistributedCacher
extends Cacher

Abstract class of distributed cachers. Currently the RedisCacher and the certain types of the JCacheCacher can be distributed (without special development).

See Also:

• RedisCacher
• JCacheCacher

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	CONTENT
protected final ThreadLocal<MessageDigest>	hashers
protected int	maxParamsLength

Fields inherited from class Cacher

debug, metrics

Fields inherited from class MoleculerComponent

broker, logger, name

Fields inherited from interface MetricConstants

MOLECULER_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 Summary

Constructors

Constructor	Description
DistributedCacher()
DistributedCacher(int maxKeyLength)

Method Summary

Modifier and Type	Method	Description
String	getCacheKey(String name, io.datatree.Tree params, String... keys)	Creates a cacher-specific key by name and params.
int	getMaxParamsLength()
void	setMaxParamsLength(int maxParamsLength)

Methods inherited from class Cacher

appendToKey, appendTree, clean, del, get, getCacheKeys, install, isCachingDisabledByTheContext, isDebug, logClean, serializeKey, set, setDebug, started

Methods inherited from class MoleculerComponent

getBroker, getLogger, getName, stopped

Methods inherited from class Object

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

Field Details

CONTENT

protected static final String CONTENT

See Also:

• Constant Field Values

maxParamsLength

protected int maxParamsLength

hashers

protected final ThreadLocal<MessageDigest> hashers

Constructor Details

DistributedCacher

public DistributedCacher()

DistributedCacher

public DistributedCacher(int maxKeyLength)

Method Details

getCacheKey

public String getCacheKey(String name,
 io.datatree.Tree params,
 String... keys)

Creates a cacher-specific key by name and params. Concatenates the name and params.

Overrides:

getCacheKey in class Cacher

Parameters:

name - action name

params - input (JSON) structure

keys - keys in the "params" structure (optional)

Returns:

generated cache key String

getMaxParamsLength

public int getMaxParamsLength()

setMaxParamsLength

public void setMaxParamsLength(int maxParamsLength)