services.moleculer.cacher

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 and Description
protected static java.lang.String	CONTENT
protected java.lang.ThreadLocal<java.security.MessageDigest>	hashers
protected int	maxParamsLength

Fields inherited from class services.moleculer.cacher.Cacher

metrics

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Fields inherited from interface services.moleculer.metrics.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 and Description
DistributedCacher()
DistributedCacher(int maxKeyLength)

Method Summary

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

Methods inherited from class services.moleculer.cacher.Cacher

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

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName, stopped

Methods inherited from class java.lang.Object

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

Field Detail

CONTENT

protected static final java.lang.String CONTENT

See Also:

Constant Field Values

maxParamsLength

protected int maxParamsLength

hashers

protected final java.lang.ThreadLocal<java.security.MessageDigest> hashers

Constructor Detail

DistributedCacher

public DistributedCacher()

DistributedCacher

public DistributedCacher(int maxKeyLength)

Method Detail

getCacheKey

public java.lang.String getCacheKey(java.lang.String name,
                                    io.datatree.Tree params,
                                    java.lang.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)