Index (moleculer-java 1.0.2 API)

A B C D E F G H I J K L M N O P Q R S T U V W X

A

ackDeadlineSeconds - Variable in class services.moleculer.transporter.GoogleTransporter
acknowledgeMode - Variable in class services.moleculer.transporter.JmsTransporter
Action - Interface in services.moleculer.service: Interface all Actions.
ActionEndpoint - Class in services.moleculer.service
ActionEndpoint(String, Tree) - Constructor for class services.moleculer.service.ActionEndpoint
actions - Variable in class services.moleculer.internal.NodeService: Implementation of the "$node.actions" action
addActions(String, Service) - Method in class services.moleculer.service.DefaultServiceRegistry
addActions(Tree) - Method in class services.moleculer.service.DefaultServiceRegistry
addActions(String, Service) - Method in class services.moleculer.service.ServiceRegistry
addActions(Tree) - Method in class services.moleculer.service.ServiceRegistry
addCacheConfiguration(String, Configuration<String, byte[]>) - Method in class services.moleculer.cacher.JCacheCacher
addEndpoint(T) - Method in class services.moleculer.strategy.ArrayBasedStrategy
addEndpoint(T) - Method in class services.moleculer.strategy.Strategy
addIgnoredType(Class<? extends Throwable>) - Method in class services.moleculer.breaker.CircuitBreaker
addListeners(String, Service) - Method in class services.moleculer.eventbus.DefaultEventbus
addListeners(Tree) - Method in class services.moleculer.eventbus.DefaultEventbus
addListeners(String, Service) - Method in class services.moleculer.eventbus.Eventbus
addListeners(Tree) - Method in class services.moleculer.eventbus.Eventbus
addOnlineActions(String, Service) - Method in class services.moleculer.service.DefaultServiceRegistry
addValue(long) - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory.Samples
AmqpTransporter - Class in services.moleculer.transporter: AMQP Transporter based on RabbitMQ's AMQP client API.
AmqpTransporter() - Constructor for class services.moleculer.transporter.AmqpTransporter
AmqpTransporter(String) - Constructor for class services.moleculer.transporter.AmqpTransporter
AmqpTransporter(String, String, SslContextFactory, String) - Constructor for class services.moleculer.transporter.AmqpTransporter
append(byte[]) - Method in class services.moleculer.transporter.tcp.SendBuffer: Adds a packet to the buffer's queue.
append(String, SendBuffer, byte[]) - Method in class services.moleculer.transporter.tcp.TcpWriter
appendMessages(StringBuilder, Throwable) - Method in class services.moleculer.logger.FastLogFormatter
appendMessages(LinkedList<String>, Throwable, int) - Method in class services.moleculer.logger.FastLogFormatter
appendToFile(String, byte[]) - Method in class services.moleculer.logger.AsyncFileLogger
appendToKey(StringBuilder, Tree) - Method in class services.moleculer.cacher.Cacher
appendTree(StringBuilder, Object) - Method in class services.moleculer.cacher.Cacher
ArrayBasedStrategy<T extends Endpoint> - Class in services.moleculer.strategy: Abstract class for Round-Robin and Random invocation strategies.
ArrayBasedStrategy(ServiceBroker, boolean) - Constructor for class services.moleculer.strategy.ArrayBasedStrategy
ArrayBasedStrategyFactory - Class in services.moleculer.strategy: Abstract class for Round-Robin and Random invocation strategy factories.
ArrayBasedStrategyFactory() - Constructor for class services.moleculer.strategy.ArrayBasedStrategyFactory
ArrayBasedStrategyFactory(boolean) - Constructor for class services.moleculer.strategy.ArrayBasedStrategyFactory
ArraySerializer() - Constructor for class services.moleculer.cacher.OHCacher.ArraySerializer
AsyncFileLogger - Class in services.moleculer.logger: To set up, add the following line to the JVM properties:

-Djava.util.logging.config.file=./config/logging.properties

...where the content of the "logging.properties" is...

handlers = services.moleculer.logger.AsyncFileLogger
services.moleculer.logger.AsyncFileLogger.directory = logs
services.moleculer.logger.AsyncFileLogger.prefix = moleculer-
services.moleculer.logger.AsyncFileLogger.encoding = UTF8
services.moleculer.logger.AsyncFileLogger.compressAfter = 30 days
services.moleculer.logger.AsyncFileLogger.deleteAfter = 365 days
services.moleculer.logger.AsyncFileLogger.logToConsole = true
services.moleculer.logger.AsyncFileLogger.level = INFO
.level = INFO
AsyncFileLogger() - Constructor for class services.moleculer.logger.AsyncFileLogger
asyncLocalInvocation - Variable in class services.moleculer.eventbus.DefaultEventbus: Invoke all local listeners via Thread pool (true) or directly (false)
asyncLocalInvocation - Variable in class services.moleculer.eventbus.LocalListenerEndpoint: Invoke all local listeners via Thread pool (true) or directly (false)
asyncLocalInvocation - Variable in class services.moleculer.service.DefaultServiceRegistry: Invoke all local services via Thread pool (true) or directly (false)
AT - Static variable in class services.moleculer.logger.FastLogFormatter
average - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory.Samples
averageSamples - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory: Number of samples used for average calculation.

B

batchingSettings - Variable in class services.moleculer.transporter.GoogleTransporter
blockerBuffer - Variable in class services.moleculer.transporter.tcp.SendBuffer
blockingTimeoutSeconds - Variable in class services.moleculer.transporter.MqttTransporter
BREAK - Static variable in class services.moleculer.logger.FastLogFormatter
BREAK_STRING - Static variable in class services.moleculer.logger.FastLogFormatter
broadcast(String, Object...) - Method in class services.moleculer.context.Context: Emits an event to ALL listeners from ALL (or the specified) event group(s), who are listening this event.
broadcast(String, Tree, Groups) - Method in class services.moleculer.context.Context: Emits an event to ALL listeners from the specified event group(s), who are listening this event.
broadcast(String, Tree) - Method in class services.moleculer.context.Context: Emits an event to ALL listeners from ALL event groups, who are listening this event.
broadcast(String, Tree, Groups, boolean) - Method in class services.moleculer.eventbus.DefaultEventbus
broadcast(String, Tree, Groups, boolean) - Method in class services.moleculer.eventbus.Eventbus
broadcast(String, Object...) - Method in class services.moleculer.ServiceBroker: Emits an event to ALL listeners from ALL (or the specified) event group(s), who are listening this event.
broadcast(String, Tree, Groups) - Method in class services.moleculer.ServiceBroker: Emits an event to ALL listeners from the specified event group(s), who are listening this event.
broadcast(String, Tree) - Method in class services.moleculer.ServiceBroker: Emits an event to ALL listeners from ALL event groups, who are listening this event.
broadcasterCache - Variable in class services.moleculer.eventbus.DefaultEventbus
broadcastInfoPacket() - Method in class services.moleculer.transporter.TcpTransporter
broadcastInfoPacket() - Method in class services.moleculer.transporter.Transporter
broadcastLocal(String, Object...) - Method in class services.moleculer.context.Context: Emits a LOCAL event to ALL listeners from ALL (or the specified) event group(s), who are listening this event.
broadcastLocal(String, Tree, Groups) - Method in class services.moleculer.context.Context: Emits a LOCAL event to ALL listeners from the specified event group(s), who are listening this event.
broadcastLocal(String, Tree) - Method in class services.moleculer.context.Context: Emits a LOCAL event to ALL listeners from ALL event groups, who are listening this event.
broadcastLocal(String, Object...) - Method in class services.moleculer.ServiceBroker: Emits a LOCAL event to ALL listeners from ALL (or the specified) event group(s), who are listening this event.
broadcastLocal(String, Tree, Groups) - Method in class services.moleculer.ServiceBroker: Emits a LOCAL event to ALL listeners from the specified event group(s), who are listening this event.
broadcastLocal(String, Tree) - Method in class services.moleculer.ServiceBroker: Emits a LOCAL event to ALL listeners from ALL event groups, who are listening this event.
broadcastNodeConnected(Tree, boolean) - Method in class services.moleculer.transporter.Transporter
broadcastNodeDisconnected(Tree, boolean) - Method in class services.moleculer.transporter.Transporter
broadcastNodeUpdated(Tree) - Method in class services.moleculer.transporter.Transporter
broadcastReceiver - Variable in class services.moleculer.transporter.tcp.UDPBroadcastReceiver: Broadcast receiver
broadcastServicesChanged(boolean) - Method in class services.moleculer.service.DefaultServiceRegistry
broker - Variable in class services.moleculer.service.MoleculerComponent
BsonSerializer - Class in services.moleculer.serializer: BSON Serializer

Binary BSON reader and writer.
BsonSerializer() - Constructor for class services.moleculer.serializer.BsonSerializer
BUFFER_IS_CLOSED - Static variable in class services.moleculer.transporter.tcp.SendBuffer
buffers - Variable in class services.moleculer.transporter.tcp.TcpWriter
build() - Method in class services.moleculer.config.ServiceBrokerBuilder
builder() - Static method in class services.moleculer.ServiceBroker: Creates a new ServiceBrokerBuilder instance.
bytesToKey(byte[]) - Method in class services.moleculer.cacher.OHCacher
bytesToValue(byte[]) - Method in class services.moleculer.cacher.OHCacher

C

Cache - Annotation Type in services.moleculer.cacher: Cache annotation to set the caching policy of Actions.
cache - Variable in class services.moleculer.cacher.MemoryCacher.MemoryPartition
cache - Variable in class services.moleculer.cacher.OHCacher
cacheConfigurations - Variable in class services.moleculer.cacher.JCacheCacher: Optional cache configurations by cache regions
cachedCPU - Static variable in class services.moleculer.monitor.Monitor: Cached CPU usage
cachedDescriptor - Variable in class services.moleculer.transporter.TcpTransporter: Current node descriptor
cachedHelloMessage - Variable in class services.moleculer.transporter.TcpTransporter
cachedPID - Static variable in class services.moleculer.monitor.Monitor: Cached process ID
cacheManager - Variable in class services.moleculer.cacher.JCacheCacher
Cacher - Class in services.moleculer.cacher: Base superclass of all Cacher implementations.
Cacher() - Constructor for class services.moleculer.cacher.Cacher
cacher(Cacher) - Method in class services.moleculer.config.ServiceBrokerBuilder
cacher - Variable in class services.moleculer.config.ServiceBrokerConfig
cacheTimeout - Variable in class services.moleculer.monitor.Monitor: CPU cache timeout in MILLISECONDS
call(String, Tree, CallOptions.Options, Context) - Method in class services.moleculer.breaker.CircuitBreaker
call(String, Tree, CallOptions.Options, Context, String, int) - Method in class services.moleculer.breaker.CircuitBreaker
call(String, Object...) - Method in class services.moleculer.context.Context: Calls an action (local or remote).
call(String, Tree) - Method in class services.moleculer.context.Context: Calls an action (local or remote).
call(String, Tree, CallOptions.Options) - Method in class services.moleculer.context.Context: Calls an action (local or remote).
call(String, Tree, CallOptions.Options, Context) - Method in class services.moleculer.service.DefaultServiceInvoker
call(String, Tree, CallOptions.Options, Context, String, int) - Method in class services.moleculer.service.DefaultServiceInvoker
call(String, Tree, CallOptions.Options, Context) - Method in class services.moleculer.service.ServiceInvoker
call(String, Object...) - Method in class services.moleculer.ServiceBroker: Calls an action (local or remote).
call(String, Tree) - Method in class services.moleculer.ServiceBroker: Calls an action (local or remote).
call(String, Tree, CallOptions.Options) - Method in class services.moleculer.ServiceBroker: Calls an action (local or remote).
CallOptions - Class in services.moleculer.context: Calling options (timeout, target nodeID, number of retries).
CallOptions() - Constructor for class services.moleculer.context.CallOptions
CallOptions.Options - Class in services.moleculer.context
callTimeoutTimer - Variable in class services.moleculer.service.DefaultServiceRegistry: Cancelable timer for handling timeouts of action calls
capacity - Variable in class services.moleculer.cacher.MemoryCacher: Maximum number of entries per partition
capacity - Variable in class services.moleculer.cacher.OHCacher: Maximum capacity of whole cache in MEGABYTES
CborSerializer - Class in services.moleculer.serializer: CBOR Serializer

CBOR is based on the wildly successful JSON data model: numbers, strings, arrays, maps (called objects in JSON), and a few values such as false, true, and null.
CborSerializer() - Constructor for class services.moleculer.serializer.CborSerializer
channel - Variable in class services.moleculer.transporter.AmqpTransporter
channel - Variable in class services.moleculer.transporter.tcp.SendBuffer
channel(String, String) - Method in class services.moleculer.transporter.Transporter
channelProvider - Variable in class services.moleculer.transporter.GoogleTransporter
checkedMiddlewares - Variable in class services.moleculer.service.ActionEndpoint
CheckedTree - Class in services.moleculer.util: For internal use only!
CheckedTree(Object) - Constructor for class services.moleculer.util.CheckedTree
checkServicesOnline() - Method in class services.moleculer.service.DefaultServiceRegistry
checkTimeouts() - Method in class services.moleculer.service.DefaultServiceRegistry
checkTimeouts() - Method in class services.moleculer.transporter.Transporter
checkTimeoutTimer - Variable in class services.moleculer.transporter.Transporter: Cancelable "Check Activities / Infos" timer
checkVersion - Variable in class services.moleculer.eventbus.DefaultEventbus: Check protocol version
checkVersion - Variable in class services.moleculer.service.DefaultServiceRegistry: Check protocol version
CircuitBreaker - Class in services.moleculer.breaker: Special service invoker with retry logic + circuit breaker.
CircuitBreaker() - Constructor for class services.moleculer.breaker.CircuitBreaker
clean(String) - Method in class services.moleculer.cacher.Cacher: Cleans this cache.
clean(String) - Method in class services.moleculer.cacher.JCacheCacher
clean(Cache<String, byte[]>, String) - Static method in class services.moleculer.cacher.JCacheCacher
clean(String) - Method in class services.moleculer.cacher.MemoryCacher
clean(String) - Method in class services.moleculer.cacher.MemoryCacher.MemoryPartition
clean(String) - Method in class services.moleculer.cacher.OHCacher
clean(String) - Method in class services.moleculer.cacher.RedisCacher
clean(String) - Method in class services.moleculer.util.redis.RedisGetSetClient: Deletes a group of items.
cleanSession - Variable in class services.moleculer.transporter.MqttTransporter
cleanup - Variable in class services.moleculer.breaker.CircuitBreaker: Cleanup period time, in SECONDS (0 = disable cleanup process)
cleanup - Variable in class services.moleculer.cacher.MemoryCacher: Cleanup period time, in SECONDS (0 = disable cleanup process)
cleanup() - Method in class services.moleculer.transporter.tcp.TcpWriter
clear() - Method in class services.moleculer.util.FastBuildMap
clearDescriptorCache() - Method in class services.moleculer.service.DefaultServiceRegistry
client - Variable in class services.moleculer.cacher.RedisCacher
client - Variable in class services.moleculer.transporter.AmqpTransporter
client - Variable in class services.moleculer.transporter.JmsTransporter
client - Variable in class services.moleculer.transporter.MqttTransporter
client - Variable in class services.moleculer.transporter.NatsTransporter
clientPub - Variable in class services.moleculer.transporter.RedisTransporter
clientSub - Variable in class services.moleculer.transporter.RedisTransporter
clock - Variable in class services.moleculer.transporter.GoogleTransporter
close() - Method in class services.moleculer.logger.AsyncFileLogger
close() - Method in class services.moleculer.transporter.tcp.SendBuffer
close(SelectionKey, Exception) - Method in class services.moleculer.transporter.tcp.TcpReader
close(String) - Method in class services.moleculer.transporter.tcp.TcpWriter
close(SelectionKey, Exception) - Method in class services.moleculer.transporter.tcp.TcpWriter
closeEmptyPartitions - Variable in class services.moleculer.cacher.JCacheCacher: Close empty caches
closeResources() - Method in class services.moleculer.transporter.tcp.SendBuffer
closeStream() - Method in class services.moleculer.logger.AsyncFileLogger
ColoredConsoleLogger - Class in services.moleculer.logger: "Colorized" ANSI logger.
ColoredConsoleLogger() - Constructor for class services.moleculer.logger.ColoredConsoleLogger
coloredPrinter - Variable in class services.moleculer.logger.ColoredConsoleLogger
command - Variable in class services.moleculer.monitor.CommandMonitor
CommandMonitor - Class in services.moleculer.monitor: CPU monitor, which detects the current CPU usage via command line.
CommandMonitor() - Constructor for class services.moleculer.monitor.CommandMonitor
CommandMonitor(String) - Constructor for class services.moleculer.monitor.CommandMonitor
CommonUtils - Class in services.moleculer.util: Common utilities.
CommonUtils() - Constructor for class services.moleculer.util.CommonUtils
compress(byte[], int) - Static method in class services.moleculer.util.CommonUtils
compressAbove - Variable in class services.moleculer.cacher.OHCacher: Compress key and/or value above this size (BYTES), 0 = disable compression
compressAfterDays - Variable in class services.moleculer.logger.AsyncFileLogger
compressionLevel - Variable in class services.moleculer.cacher.OHCacher: Compression level (best speed = 1, best compression = 9)
compressOrDeleteOldFiles() - Method in class services.moleculer.logger.AsyncFileLogger
config - Variable in class services.moleculer.config.ServiceBrokerBuilder
CONFIG - Static variable in class services.moleculer.logger.ColoredConsoleLogger
CONFIG - Static variable in class services.moleculer.logger.FastLogFormatter
CONFIG - Static variable in class services.moleculer.logger.SimpleConsoleLogger
config - Variable in class services.moleculer.service.ActionEndpoint
config - Variable in class services.moleculer.ServiceBroker: Configuration settings and internal components (event bus, cacher, service registry, etc.) of this node / broker.
configure() - Method in class services.moleculer.logger.AsyncFileLogger
connect() - Method in class services.moleculer.cacher.RedisCacher
connect() - Method in class services.moleculer.transporter.AmqpTransporter
connect() - Method in class services.moleculer.transporter.GoogleTransporter
connect() - Method in class services.moleculer.transporter.JmsTransporter
connect() - Method in class services.moleculer.transporter.KafkaTransporter
connect() - Method in class services.moleculer.transporter.MqttTransporter
connect() - Method in class services.moleculer.transporter.NatsTransporter
connect() - Method in class services.moleculer.transporter.NullTransporter
connect() - Method in class services.moleculer.transporter.RedisTransporter
connect() - Method in class services.moleculer.transporter.tcp.TcpReader
connect() - Method in class services.moleculer.transporter.tcp.TcpWriter
connect() - Method in class services.moleculer.transporter.tcp.UDPBroadcastReceiver
connect() - Method in class services.moleculer.transporter.tcp.UDPLocator
connect() - Method in class services.moleculer.transporter.tcp.UDPMulticastReceiver
connect() - Method in class services.moleculer.transporter.tcp.UDPReceiver
connect() - Method in class services.moleculer.transporter.TcpTransporter
connect() - Method in class services.moleculer.transporter.Transporter
connect() - Method in class services.moleculer.util.redis.RedisGetSetClient
connect() - Method in class services.moleculer.util.redis.RedisPubSubClient
connected - Variable in class services.moleculer.transporter.GoogleTransporter
connected(MqttClient, ConnectReturnCode) - Method in class services.moleculer.transporter.MqttTransporter
connected(SelectionKey, SocketChannel) - Method in class services.moleculer.transporter.tcp.SendBuffer
connected() - Method in class services.moleculer.transporter.Transporter
connected(boolean) - Method in class services.moleculer.transporter.Transporter
connectionFactoryJndiName - Variable in class services.moleculer.transporter.JmsTransporter
connectTimeoutSeconds - Variable in class services.moleculer.transporter.MqttTransporter
console - Variable in class services.moleculer.logger.AsyncFileLogger
ConsoleLogger - Interface in services.moleculer.logger
ConstantMonitor - Class in services.moleculer.monitor: "Fake" system monitor, which returns a constant value.
ConstantMonitor() - Constructor for class services.moleculer.monitor.ConstantMonitor
ConstantMonitor(int) - Constructor for class services.moleculer.monitor.ConstantMonitor
consumer - Variable in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
consumerProperties - Variable in class services.moleculer.transporter.KafkaTransporter
containsKey(Object) - Method in class services.moleculer.util.FastBuildMap
containsValue(Object) - Method in class services.moleculer.util.FastBuildMap
CONTENT - Static variable in class services.moleculer.cacher.DistributedCacher
CONTENT - Static variable in class services.moleculer.cacher.OHCacher
context(ContextFactory) - Method in class services.moleculer.config.ServiceBrokerBuilder
Context - Class in services.moleculer.context
Context(ServiceInvoker, Eventbus, String, String, Tree, CallOptions.Options) - Constructor for class services.moleculer.context.Context
Context(String, String, Tree, CallOptions.Options, Context) - Constructor for class services.moleculer.context.Context
Context(ServiceInvoker, Eventbus, String, String, Tree, CallOptions.Options, int, String, String) - Constructor for class services.moleculer.context.Context
contextFactory - Variable in class services.moleculer.breaker.CircuitBreaker
contextFactory - Variable in class services.moleculer.config.ServiceBrokerConfig
ContextFactory - Class in services.moleculer.context: Base superclass of all Context Factory implementations.
ContextFactory() - Constructor for class services.moleculer.context.ContextFactory
contextFactory - Variable in class services.moleculer.service.DefaultServiceInvoker
contextFactory - Variable in class services.moleculer.service.DefaultServiceRegistry
contextFactory - Variable in class services.moleculer.ServiceBroker: Context generator / factory.
convertAnnotations(Tree, Annotation[]) - Static method in class services.moleculer.util.CommonUtils
counter - Variable in class services.moleculer.strategy.RoundRobinStrategy
counter - Variable in class services.moleculer.uid.IncrementalUidGenerator
cpu - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
cpuDetectedAt - Static variable in class services.moleculer.monitor.Monitor: Timestamp of CPU detection
cpuSeq - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
CpuUsageStrategy<T extends Endpoint> - Class in services.moleculer.strategy: Lowest CPU usage invocation strategy.
CpuUsageStrategy(ServiceBroker, boolean, int, int, Transporter) - Constructor for class services.moleculer.strategy.CpuUsageStrategy
CpuUsageStrategyFactory - Class in services.moleculer.strategy: Factory of lowest CPU usage strategy.
CpuUsageStrategyFactory() - Constructor for class services.moleculer.strategy.CpuUsageStrategyFactory
CpuUsageStrategyFactory(boolean) - Constructor for class services.moleculer.strategy.CpuUsageStrategyFactory
CpuUsageStrategyFactory(boolean, int, int) - Constructor for class services.moleculer.strategy.CpuUsageStrategyFactory
cpuWhen - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
create(String, Tree, CallOptions.Options, Context) - Method in class services.moleculer.context.ContextFactory
create(String, Tree, CallOptions.Options, String, int, String, String) - Method in class services.moleculer.context.ContextFactory
create(String, Tree, CallOptions.Options, Context) - Method in class services.moleculer.context.DefaultContextFactory
create(String, Tree, CallOptions.Options, String, int, String, String) - Method in class services.moleculer.context.DefaultContextFactory
create() - Method in class services.moleculer.strategy.CpuUsageStrategyFactory
create() - Method in class services.moleculer.strategy.NanoSecRandomStrategyFactory
create() - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
create() - Method in class services.moleculer.strategy.RoundRobinStrategyFactory
create() - Method in class services.moleculer.strategy.SecureRandomStrategyFactory
create() - Method in class services.moleculer.strategy.StrategyFactory
create() - Method in class services.moleculer.strategy.XorShiftRandomStrategyFactory
createOrGetPublisher(String) - Method in class services.moleculer.transporter.JmsTransporter
createPingPacket(String) - Method in class services.moleculer.transporter.Transporter
createRequestPacket(Context) - Method in class services.moleculer.transporter.Transporter
createService(Service) - Method in class services.moleculer.ServiceBroker: Installs a new service instance and notifies other nodes about the actions/listeners of the new service.
createService(String, Service) - Method in class services.moleculer.ServiceBroker: Installs a new service with the specified name (eg.
credentialsProvider - Variable in class services.moleculer.transporter.GoogleTransporter
current - Variable in class services.moleculer.service.ActionEndpoint
currentDescriptor() - Method in class services.moleculer.service.DefaultServiceRegistry
currentNodeID - Variable in class services.moleculer.eventbus.RemoteListenerEndpoint
currentPort - Variable in class services.moleculer.transporter.tcp.TcpReader: Current TPC port
currentPort - Variable in class services.moleculer.transporter.TcpTransporter: Current TCP port

D

data - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory.Samples
data - Variable in class services.moleculer.util.ParseResult
DAY - Static variable in class services.moleculer.logger.AsyncFileLogger
debug - Variable in class services.moleculer.transporter.tcp.SendBuffer: Debug mode
debug - Variable in class services.moleculer.transporter.tcp.TcpReader: Debug mode
debug - Variable in class services.moleculer.transporter.tcp.TcpWriter: Debug mode
debug - Variable in class services.moleculer.transporter.tcp.UDPReceiver: Debug mode
debug - Variable in class services.moleculer.transporter.Transporter
decompress(byte[]) - Static method in class services.moleculer.util.CommonUtils
defaultConfiguration - Variable in class services.moleculer.cacher.JCacheCacher: Default cache cconfiguration
DefaultContextFactory - Class in services.moleculer.context: Default implementation of Context Factory.
DefaultContextFactory() - Constructor for class services.moleculer.context.DefaultContextFactory
DefaultEventbus - Class in services.moleculer.eventbus: Default EventBus implementation.
DefaultEventbus() - Constructor for class services.moleculer.eventbus.DefaultEventbus
DefaultEventbus(boolean) - Constructor for class services.moleculer.eventbus.DefaultEventbus
defaultExecutorProvider - Variable in class services.moleculer.transporter.GoogleTransporter
DefaultServiceInvoker - Class in services.moleculer.service: Default service invoker with retry logic.
DefaultServiceInvoker() - Constructor for class services.moleculer.service.DefaultServiceInvoker
DefaultServiceRegistry - Class in services.moleculer.service: Default implementation of the Service Registry.
DefaultServiceRegistry() - Constructor for class services.moleculer.service.DefaultServiceRegistry
DefaultServiceRegistry(boolean) - Constructor for class services.moleculer.service.DefaultServiceRegistry
del(String) - Method in class services.moleculer.cacher.Cacher: Deletes a content from this cache.
del(String) - Method in class services.moleculer.cacher.JCacheCacher
del(String) - Method in class services.moleculer.cacher.MemoryCacher
del(String) - Method in class services.moleculer.cacher.MemoryCacher.MemoryPartition
del(String) - Method in class services.moleculer.cacher.OHCacher
del(String) - Method in class services.moleculer.cacher.RedisCacher
del(String) - Method in class services.moleculer.util.redis.RedisGetSetClient: Deletes a content with the specified key.
deleteAfterDays - Variable in class services.moleculer.logger.AsyncFileLogger
deliveryMode - Variable in class services.moleculer.transporter.JmsTransporter
Dependencies - Annotation Type in services.moleculer.service
deregister(String) - Method in class services.moleculer.service.DefaultServiceRegistry
deserialize(ByteBuffer) - Method in class services.moleculer.cacher.OHCacher.ArraySerializer
detectPID() - Method in class services.moleculer.monitor.CommandMonitor: Returns the PID of Java VM.
detectPID() - Method in class services.moleculer.monitor.ConstantMonitor: Returns the system CPU usage, in percents, between 0 and 100.
detectPID() - Method in class services.moleculer.monitor.JmxMonitor: Returns the system CPU usage, in percents, between 0 and 100.
detectPID() - Method in class services.moleculer.monitor.Monitor: Returns the system CPU usage, in percents, between 0 and 100.
detectPID() - Method in class services.moleculer.monitor.SigarMonitor: Returns the PID of Java VM.
detectTotalCpuPercent() - Method in class services.moleculer.monitor.CommandMonitor: Returns the system CPU usage, in percents, between 0 and 100.
detectTotalCpuPercent() - Method in class services.moleculer.monitor.ConstantMonitor: Returns the system CPU usage, in percents, between 0 and 100.
detectTotalCpuPercent() - Method in class services.moleculer.monitor.JmxMonitor: Returns the system CPU usage, in percents, between 0 and 100.
detectTotalCpuPercent() - Method in class services.moleculer.monitor.Monitor: Returns the system CPU usage, in percents, between 0 and 100.
detectTotalCpuPercent() - Method in class services.moleculer.monitor.SigarMonitor: Returns the system CPU usage, in percents, between 0 and 100.
directory - Variable in class services.moleculer.logger.AsyncFileLogger
disconnect() - Method in class services.moleculer.cacher.RedisCacher
disconnect() - Method in class services.moleculer.transporter.AmqpTransporter
disconnect() - Method in class services.moleculer.transporter.GoogleTransporter
disconnect() - Method in class services.moleculer.transporter.JmsTransporter
disconnect() - Method in class services.moleculer.transporter.KafkaTransporter
disconnect() - Method in class services.moleculer.transporter.MqttTransporter
disconnect() - Method in class services.moleculer.transporter.NatsTransporter
disconnect() - Method in class services.moleculer.transporter.RedisTransporter
disconnect() - Method in class services.moleculer.transporter.tcp.TcpReader
disconnect() - Method in class services.moleculer.transporter.tcp.TcpWriter
disconnect() - Method in class services.moleculer.transporter.tcp.UDPBroadcastReceiver
disconnect() - Method in class services.moleculer.transporter.tcp.UDPLocator
disconnect() - Method in class services.moleculer.transporter.tcp.UDPMulticastReceiver
disconnect() - Method in class services.moleculer.transporter.tcp.UDPReceiver
disconnect() - Method in class services.moleculer.transporter.TcpTransporter
disconnect() - Method in class services.moleculer.util.redis.RedisGetSetClient
disconnect() - Method in class services.moleculer.util.redis.RedisPubSubClient
disconnectChannel - Variable in class services.moleculer.transporter.Transporter
disconnected(MqttClient, Throwable, boolean) - Method in class services.moleculer.transporter.MqttTransporter
discoverBroadcastChannel - Variable in class services.moleculer.transporter.Transporter
discoverChannel - Variable in class services.moleculer.transporter.Transporter
DistributedCacher - Class in services.moleculer.cacher: Abstract class of distributed cachers.
DistributedCacher() - Constructor for class services.moleculer.cacher.DistributedCacher
DistributedCacher(int) - Constructor for class services.moleculer.cacher.DistributedCacher
dontRandomize - Variable in class services.moleculer.transporter.NatsTransporter
dump(Throwable, int, int) - Method in class services.moleculer.logger.FastLogFormatter

E

emit(String, Object...) - Method in class services.moleculer.context.Context: Emits an event to ONE listener from ALL (or the specified) event group(s), who are listening this event.
emit(String, Tree, Groups) - Method in class services.moleculer.context.Context: Emits an event to ONE listener from the specified event group(s), who are listening this event.
emit(String, Tree) - Method in class services.moleculer.context.Context: Emits an event to ONE listener from ALL event groups, who are listening this event.
emit(String, Tree, Groups, boolean) - Method in class services.moleculer.eventbus.DefaultEventbus
emit(String, Tree, Groups, boolean) - Method in class services.moleculer.eventbus.Eventbus
emit(String, Object...) - Method in class services.moleculer.ServiceBroker: Emits an event to ONE listener from ALL (or the specified) event group(s), who are listening this event.
emit(String, Tree, Groups) - Method in class services.moleculer.ServiceBroker: Emits an event to ONE listener from the specified event group(s), who are listening this event.
emit(String, Tree) - Method in class services.moleculer.ServiceBroker: Emits an event to ONE listener from ALL event groups, who are listening this event.
emitterCache - Variable in class services.moleculer.eventbus.DefaultEventbus
enableColors - Variable in class services.moleculer.logger.AsyncFileLogger
Endpoint - Class in services.moleculer.service
Endpoint(String) - Constructor for class services.moleculer.service.Endpoint
endpointCache - Variable in class services.moleculer.strategy.ArrayBasedStrategy
EndpointKey - Class in services.moleculer.breaker
EndpointKey(String, String) - Constructor for class services.moleculer.breaker.EndpointKey
endpoints - Variable in class services.moleculer.strategy.ArrayBasedStrategy
entrySet() - Method in class services.moleculer.util.FastBuildMap
equals(Object) - Method in class services.moleculer.breaker.EndpointKey
equals(Object) - Method in class services.moleculer.eventbus.ListenerEndpoint
equals(Object) - Method in class services.moleculer.service.ActionEndpoint
error(Throwable) - Method in class services.moleculer.transporter.AmqpTransporter
error(Throwable) - Method in class services.moleculer.transporter.GoogleTransporter
error(Throwable) - Method in class services.moleculer.transporter.JmsTransporter
error(Throwable) - Method in class services.moleculer.transporter.KafkaTransporter
error(Throwable) - Method in class services.moleculer.transporter.MqttTransporter
error(Throwable) - Method in class services.moleculer.transporter.NatsTransporter
error(Throwable) - Method in class services.moleculer.transporter.RedisTransporter
error(Throwable) - Method in class services.moleculer.transporter.Transporter: Any I/O error occured.
ErrorCounter - Class in services.moleculer.breaker
ErrorCounter(long, long, int) - Constructor for class services.moleculer.breaker.ErrorCounter
errorCounters - Variable in class services.moleculer.breaker.CircuitBreaker
eventbus(Eventbus) - Method in class services.moleculer.config.ServiceBrokerBuilder
eventbus - Variable in class services.moleculer.config.ServiceBrokerConfig
eventbus - Variable in class services.moleculer.context.Context
eventbus - Variable in class services.moleculer.context.DefaultContextFactory
Eventbus - Class in services.moleculer.eventbus: Base superclass of all Event Bus implementations.
Eventbus() - Constructor for class services.moleculer.eventbus.Eventbus
eventbus - Variable in class services.moleculer.service.DefaultServiceRegistry
eventbus - Variable in class services.moleculer.ServiceBroker: Implementation of the event bus of the current node.
eventbus - Variable in class services.moleculer.transporter.Transporter
eventChannel - Variable in class services.moleculer.transporter.Transporter
events - Variable in class services.moleculer.internal.NodeService: Implementation of the "$node.events" action
exchangeProperties - Variable in class services.moleculer.transporter.AmqpTransporter
exchangeType - Variable in class services.moleculer.transporter.AmqpTransporter
exclusive - Variable in class services.moleculer.transporter.AmqpTransporter
executor - Variable in class services.moleculer.cacher.RedisCacher
executor(ExecutorService) - Method in class services.moleculer.config.ServiceBrokerBuilder
executor - Variable in class services.moleculer.config.ServiceBrokerConfig
executor - Variable in class services.moleculer.eventbus.DefaultEventbus
executor - Variable in class services.moleculer.eventbus.LocalListenerEndpoint
executor - Variable in class services.moleculer.logger.AsyncFileLogger
executor - Variable in class services.moleculer.service.DefaultServiceRegistry
executor - Variable in class services.moleculer.transporter.KafkaTransporter: Executor of reader loop for incoming messages
executor - Variable in class services.moleculer.transporter.tcp.TcpReader: Server's executor
executor - Variable in class services.moleculer.transporter.tcp.TcpWriter: Writer thread
executor - Variable in class services.moleculer.transporter.tcp.UDPReceiver: Receiver's executor
executor - Variable in class services.moleculer.transporter.Transporter
executorProvider - Variable in class services.moleculer.transporter.GoogleTransporter
expiration - Variable in class services.moleculer.cacher.RedisCacher
expireAt - Variable in class services.moleculer.cacher.MemoryCacher.PartitionEntry

F

factory - Variable in class services.moleculer.strategy.NetworkLatencyStrategy
factory - Variable in class services.moleculer.transporter.AmqpTransporter
factory - Variable in class services.moleculer.transporter.JmsTransporter
FastBuildEntrySet(int, String[], Object[]) - Constructor for class services.moleculer.util.FastBuildMap.FastBuildEntrySet
FastBuildMap - Class in services.moleculer.util: This Map is optimized for fast building and serialization.
FastBuildMap(int) - Constructor for class services.moleculer.util.FastBuildMap
FastBuildMap.FastBuildEntrySet - Class in services.moleculer.util
FastBuildTree - Class in services.moleculer.util: This Tree is optimized for fast building and serialization.
FastBuildTree() - Constructor for class services.moleculer.util.FastBuildTree
FastBuildTree(int) - Constructor for class services.moleculer.util.FastBuildTree
FastLogFormatter - Class in services.moleculer.logger: Fast log formatter for AsyncFileLogger.
FastLogFormatter() - Constructor for class services.moleculer.logger.FastLogFormatter
FILE_FORMAT - Variable in class services.moleculer.logger.AsyncFileLogger
fileEncoding - Variable in class services.moleculer.logger.AsyncFileLogger
finalize() - Method in class services.moleculer.transporter.tcp.TcpReader
finalize() - Method in class services.moleculer.transporter.tcp.TcpWriter
finalize() - Method in class services.moleculer.transporter.tcp.UDPLocator
findLogDirectory(File) - Method in class services.moleculer.logger.AsyncFileLogger
FINE - Static variable in class services.moleculer.logger.ColoredConsoleLogger
FINE - Static variable in class services.moleculer.logger.FastLogFormatter
FINE - Static variable in class services.moleculer.logger.SimpleConsoleLogger
FINER - Static variable in class services.moleculer.logger.ColoredConsoleLogger
FINER - Static variable in class services.moleculer.logger.FastLogFormatter
FINER - Static variable in class services.moleculer.logger.SimpleConsoleLogger
FINEST - Static variable in class services.moleculer.logger.ColoredConsoleLogger
FINEST - Static variable in class services.moleculer.logger.FastLogFormatter
FINEST - Static variable in class services.moleculer.logger.SimpleConsoleLogger
firstError - Static variable in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
flowControlSettings - Variable in class services.moleculer.transporter.GoogleTransporter
flush() - Method in class services.moleculer.logger.AsyncFileLogger
format(LogRecord) - Method in class services.moleculer.logger.FastLogFormatter
format - Variable in class services.moleculer.serializer.Serializer
formatNamoSec(long) - Static method in class services.moleculer.util.CommonUtils
formatNumber(Number) - Static method in class services.moleculer.util.CommonUtils
formatPath(String) - Static method in class services.moleculer.util.CommonUtils

G

generateGossipHello() - Method in class services.moleculer.transporter.TcpTransporter: Create Gossip HELLO packet.
generateListenerDescriptor(String) - Method in class services.moleculer.eventbus.DefaultEventbus
generateListenerDescriptor(String) - Method in class services.moleculer.eventbus.Eventbus
get(String) - Method in class services.moleculer.cacher.Cacher: Gets a cached content by a key.
get(String) - Method in class services.moleculer.cacher.JCacheCacher
get(String) - Method in class services.moleculer.cacher.MemoryCacher
get(String) - Method in class services.moleculer.cacher.MemoryCacher.MemoryPartition
get(String) - Method in class services.moleculer.cacher.OHCacher
get(String) - Method in class services.moleculer.cacher.RedisCacher
get() - Method in class services.moleculer.cacher.RedisCacher
get() - Method in class services.moleculer.transporter.RedisTransporter
get(Object) - Method in class services.moleculer.util.FastBuildMap
get(String) - Method in class services.moleculer.util.redis.RedisGetSetClient: Gets a content by a key.
getAckDeadlineSeconds() - Method in class services.moleculer.transporter.GoogleTransporter
getAcknowledgeMode() - Method in class services.moleculer.transporter.JmsTransporter
getAction() - Method in class services.moleculer.service.ActionEndpoint
getAction(String, String) - Method in class services.moleculer.service.DefaultServiceRegistry
getAction(String, String) - Method in class services.moleculer.service.ServiceRegistry
getAction(String) - Method in class services.moleculer.ServiceBroker: Returns an action by name.
getAction(String, String) - Method in class services.moleculer.ServiceBroker: Returns an action by name and nodeID.
getAddress(String) - Method in class services.moleculer.transporter.Transporter
getAllEndpoints() - Method in class services.moleculer.strategy.ArrayBasedStrategy
getAllEndpoints() - Method in class services.moleculer.strategy.Strategy
getAllNodeIDs() - Method in class services.moleculer.transporter.Transporter
getAverage() - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory.Samples
getAverageResponseTime(String) - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
getAverageSamples() - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
getBatchingSettings() - Method in class services.moleculer.transporter.GoogleTransporter
getBlockingTimeoutSeconds() - Method in class services.moleculer.transporter.MqttTransporter
getBroker() - Method in class services.moleculer.service.MoleculerComponent
getCacheConfigurations() - Method in class services.moleculer.cacher.JCacheCacher
getCacheKey(String, Tree, String...) - Method in class services.moleculer.cacher.Cacher: Creates a cacher-specific key by name and params.
getCacheKey(String, Tree, String...) - Method in class services.moleculer.cacher.DistributedCacher: Creates a cacher-specific key by name and params.
getCacheKey(String, Groups) - Method in class services.moleculer.eventbus.DefaultEventbus
getCacheManager() - Method in class services.moleculer.cacher.JCacheCacher
getCacher() - Method in class services.moleculer.config.ServiceBrokerConfig
getCapacity() - Method in class services.moleculer.cacher.MemoryCacher
getCapacity() - Method in class services.moleculer.cacher.OHCacher
getChannelProvider() - Method in class services.moleculer.transporter.GoogleTransporter
getCleanup() - Method in class services.moleculer.breaker.CircuitBreaker
getCleanup() - Method in class services.moleculer.cacher.MemoryCacher
getClock() - Method in class services.moleculer.transporter.GoogleTransporter
getCommand() - Method in class services.moleculer.monitor.CommandMonitor
getCompressAbove() - Method in class services.moleculer.cacher.OHCacher
getCompressionLevel() - Method in class services.moleculer.cacher.OHCacher
getConfig() - Method in class services.moleculer.service.ActionEndpoint
getConfig() - Method in class services.moleculer.ServiceBroker: Returns the configuration settings and internal components (event bus, cacher, service registry, etc.) of this node / broker.
getConnectionFactoryJndiName() - Method in class services.moleculer.transporter.JmsTransporter
getConnectTimeoutSeconds() - Method in class services.moleculer.transporter.MqttTransporter
getConsumerProperties() - Method in class services.moleculer.transporter.KafkaTransporter
getContextFactory() - Method in class services.moleculer.config.ServiceBrokerConfig
getCpuUsage(String) - Method in class services.moleculer.transporter.Transporter
getCredentialsProvider() - Method in class services.moleculer.transporter.GoogleTransporter
getCurrentPort() - Method in class services.moleculer.transporter.tcp.TcpReader
getCurrentPort() - Method in class services.moleculer.transporter.TcpTransporter
getDefaultConfiguration() - Method in class services.moleculer.cacher.JCacheCacher
getDeliveryMode() - Method in class services.moleculer.transporter.JmsTransporter
getDescriptor() - Method in class services.moleculer.service.DefaultServiceRegistry
getDescriptor() - Method in class services.moleculer.service.ServiceRegistry
getDescriptor() - Method in class services.moleculer.transporter.TcpTransporter
getDescriptor(String) - Method in class services.moleculer.transporter.Transporter
getEndpoint(String) - Method in class services.moleculer.strategy.ArrayBasedStrategy
getEndpoint(String) - Method in class services.moleculer.strategy.Strategy
getEndpointsByNodeID(String) - Method in class services.moleculer.strategy.ArrayBasedStrategy
getEventbus() - Method in class services.moleculer.config.ServiceBrokerConfig
getExchangeProperties() - Method in class services.moleculer.transporter.AmqpTransporter
getExchangeType() - Method in class services.moleculer.transporter.AmqpTransporter
getExecutor() - Method in class services.moleculer.config.ServiceBrokerConfig
getExecutorProvider() - Method in class services.moleculer.transporter.GoogleTransporter
getFactory() - Method in class services.moleculer.transporter.AmqpTransporter
getFlowControlSettings() - Method in class services.moleculer.transporter.GoogleTransporter
getFormat() - Method in class services.moleculer.serializer.Serializer
getFormat(String) - Static method in class services.moleculer.util.CommonUtils
getGossipPeriod() - Method in class services.moleculer.transporter.TcpTransporter
getGroup() - Method in class services.moleculer.eventbus.ListenerEndpoint
getHashTableSize() - Method in class services.moleculer.cacher.OHCacher
getHeaderProvider() - Method in class services.moleculer.transporter.GoogleTransporter
getHeartbeatInterval() - Method in class services.moleculer.transporter.Transporter
getHeartbeatTimeout() - Method in class services.moleculer.transporter.Transporter
getHostName() - Static method in class services.moleculer.util.CommonUtils
getHostOrIP(boolean, Tree) - Static method in class services.moleculer.util.CommonUtils
getIgnoredTypes() - Method in class services.moleculer.breaker.CircuitBreaker
getJsonReader() - Method in class services.moleculer.config.ServiceBrokerConfig
getJsonWriter() - Method in class services.moleculer.config.ServiceBrokerConfig
getKeepAliveSeconds() - Method in class services.moleculer.transporter.MqttTransporter
getLastHeartbeatTime(String) - Method in class services.moleculer.transporter.Transporter
getLocalService(String) - Method in class services.moleculer.ServiceBroker: Returns a local service by name (eg.
getLogger() - Method in class services.moleculer.service.MoleculerComponent
getLogger() - Method in class services.moleculer.ServiceBroker: Returns the SLF4J logger of this broker instance.
getLogger(Class<?>) - Method in class services.moleculer.ServiceBroker: Returns a logger named corresponding to the class passed as parameter.
getLogger(String) - Method in class services.moleculer.ServiceBroker: Return a logger named according to the name parameter.
getLowCpuUsage() - Method in class services.moleculer.strategy.CpuUsageStrategyFactory
getMaxAckExtensionPeriod() - Method in class services.moleculer.transporter.GoogleTransporter
getMaxCallLevel() - Method in class services.moleculer.context.DefaultContextFactory
getMaxConnections() - Method in class services.moleculer.transporter.TcpTransporter
getMaxErrors() - Method in class services.moleculer.breaker.CircuitBreaker
getMaxInFlightMessages() - Method in class services.moleculer.transporter.MqttTransporter
getMaxPacketSize() - Method in class services.moleculer.transporter.TcpTransporter
getMaxParamsLength() - Method in class services.moleculer.cacher.DistributedCacher
getMaxPingsOut() - Method in class services.moleculer.transporter.NatsTransporter
getMaxSameNodes() - Method in class services.moleculer.breaker.CircuitBreaker
getMaxTries() - Method in class services.moleculer.breaker.CircuitBreaker
getMaxTries() - Method in class services.moleculer.strategy.CpuUsageStrategyFactory
getMaxTries() - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
getMessageProperties() - Method in class services.moleculer.transporter.AmqpTransporter
getMessageResendIntervalSeconds() - Method in class services.moleculer.transporter.MqttTransporter
getMonitor() - Method in class services.moleculer.config.ServiceBrokerConfig
getName() - Method in class services.moleculer.service.MoleculerComponent
getNamespace() - Method in class services.moleculer.config.ServiceBrokerConfig
getNamespace() - Method in class services.moleculer.transporter.Transporter
getNodeID() - Method in class services.moleculer.config.ServiceBrokerConfig
getNodeID() - Method in class services.moleculer.service.Endpoint
getNodeID() - Method in class services.moleculer.ServiceBroker: Returns the unique ServiceBroker.nodeID of this node (~= ServiceBroker instance).
getNodeInfos(ServiceBroker, Transporter) - Static method in class services.moleculer.util.CommonUtils
getOfflineTimeout() - Method in class services.moleculer.transporter.Transporter
getOrCreatePublisher(String) - Method in class services.moleculer.transporter.GoogleTransporter
getParallelPullCount() - Method in class services.moleculer.transporter.GoogleTransporter
getPassword() - Method in class services.moleculer.cacher.RedisCacher
getPassword() - Method in class services.moleculer.transporter.AmqpTransporter
getPassword() - Method in class services.moleculer.transporter.JmsTransporter
getPassword() - Method in class services.moleculer.transporter.MqttTransporter
getPassword() - Method in class services.moleculer.transporter.NatsTransporter
getPassword() - Method in class services.moleculer.transporter.RedisTransporter
getPID() - Method in class services.moleculer.monitor.Monitor: Returns the cached PID of Java VM.
getPingInterval() - Method in class services.moleculer.transporter.NatsTransporter
getPingPeriod() - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
getPingTimeout() - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
getPort() - Method in class services.moleculer.transporter.TcpTransporter
getPrefix() - Method in class services.moleculer.transporter.Transporter
getPrefix() - Method in class services.moleculer.uid.IncrementalUidGenerator
getPriority() - Method in class services.moleculer.transporter.JmsTransporter
getProducerProperties() - Method in class services.moleculer.transporter.KafkaTransporter
getProjectID() - Method in class services.moleculer.transporter.GoogleTransporter
getProperty(String, String) - Method in class services.moleculer.logger.AsyncFileLogger
getQos() - Method in class services.moleculer.transporter.MqttTransporter
getQueueProperties() - Method in class services.moleculer.transporter.AmqpTransporter
getRetrySettings() - Method in class services.moleculer.transporter.GoogleTransporter
getScheduler() - Method in class services.moleculer.config.ServiceBrokerConfig
getSegmentCount() - Method in class services.moleculer.cacher.OHCacher
getSerializer() - Method in class services.moleculer.cacher.OHCacher
getSerializer() - Method in class services.moleculer.cacher.RedisCacher
getSerializer() - Method in class services.moleculer.transporter.Transporter
getService(String) - Method in class services.moleculer.service.DefaultServiceRegistry
getService(String) - Method in class services.moleculer.service.ServiceRegistry
getServiceInvoker() - Method in class services.moleculer.config.ServiceBrokerConfig
getServiceName() - Method in class services.moleculer.eventbus.ListenerEndpoint
getServiceRegistry() - Method in class services.moleculer.config.ServiceBrokerConfig
getSslContext() - Method in class services.moleculer.transporter.NatsTransporter
getSslContextFactory() - Method in class services.moleculer.transporter.AmqpTransporter
getStrategyFactory() - Method in class services.moleculer.config.ServiceBrokerConfig
getSubscribe() - Method in class services.moleculer.eventbus.ListenerEndpoint
getSubscriptionTimeout() - Method in class services.moleculer.transporter.Transporter
getTimeout() - Method in class services.moleculer.transporter.NatsTransporter
getTimestamp() - Method in class services.moleculer.service.DefaultServiceRegistry
getTimestamp() - Method in class services.moleculer.service.ServiceRegistry
getTopicConnectionFactory() - Method in class services.moleculer.transporter.JmsTransporter
getTotalCpuPercent() - Method in class services.moleculer.monitor.ConstantMonitor: Returns the system CPU usage, in percents, between 0 and 100.
getTotalCpuPercent() - Method in class services.moleculer.monitor.Monitor: Returns the cached system CPU usage, in percents, between 0 and 100.
getTransportChannelProvider() - Method in class services.moleculer.transporter.GoogleTransporter
getTransporter() - Method in class services.moleculer.config.ServiceBrokerConfig
getTtl() - Method in class services.moleculer.cacher.MemoryCacher
getTtl() - Method in class services.moleculer.cacher.OHCacher
getTtl() - Method in class services.moleculer.cacher.RedisCacher
getTtl() - Method in class services.moleculer.transporter.JmsTransporter
getUdpBindAddress() - Method in class services.moleculer.transporter.TcpTransporter
getUdpMaxDiscovery() - Method in class services.moleculer.transporter.TcpTransporter
getUdpMulticast() - Method in class services.moleculer.transporter.TcpTransporter
getUdpMulticastTTL() - Method in class services.moleculer.transporter.TcpTransporter
getUdpPeriod() - Method in class services.moleculer.transporter.TcpTransporter
getUdpPort() - Method in class services.moleculer.transporter.TcpTransporter
getUidGenerator() - Method in class services.moleculer.config.ServiceBrokerConfig
getUnsentPackets() - Method in class services.moleculer.transporter.tcp.SendBuffer
getUrl() - Method in class services.moleculer.transporter.AmqpTransporter
getUrl() - Method in class services.moleculer.transporter.MqttTransporter
getUrls() - Method in class services.moleculer.cacher.RedisCacher
getUrls() - Method in class services.moleculer.transporter.KafkaTransporter
getUrls() - Method in class services.moleculer.transporter.NatsTransporter
getUrls() - Method in class services.moleculer.transporter.RedisTransporter
getUrls() - Method in class services.moleculer.transporter.TcpTransporter
getUsername() - Method in class services.moleculer.transporter.AmqpTransporter
getUsername() - Method in class services.moleculer.transporter.JmsTransporter
getUsername() - Method in class services.moleculer.transporter.MqttTransporter
getUsername() - Method in class services.moleculer.transporter.NatsTransporter
getWindowLength() - Method in class services.moleculer.breaker.CircuitBreaker
GoogleTransporter - Class in services.moleculer.transporter: Google Cloud Pub/Sub Transporter.
GoogleTransporter() - Constructor for class services.moleculer.transporter.GoogleTransporter
GoogleTransporter(String) - Constructor for class services.moleculer.transporter.GoogleTransporter
GoogleTransporter(Tree) - Constructor for class services.moleculer.transporter.GoogleTransporter
GoogleTransporter(Credentials) - Constructor for class services.moleculer.transporter.GoogleTransporter
gossiperTimer - Variable in class services.moleculer.transporter.TcpTransporter: Cancelable timer of gossiper
gossipPeriod - Variable in class services.moleculer.transporter.TcpTransporter: Gossiping period time, in SECONDS.
Group - Annotation Type in services.moleculer.eventbus: Event group.
group - Variable in class services.moleculer.eventbus.ListenerEndpoint
Groups - Class in services.moleculer.eventbus
groups() - Method in class services.moleculer.eventbus.Groups
groups - Variable in class services.moleculer.util.ParseResult

H

handler(Context) - Method in interface services.moleculer.service.Action: Action's main method.
handler(Context) - Method in class services.moleculer.service.ActionEndpoint
hashCode - Variable in class services.moleculer.breaker.EndpointKey
hashCode() - Method in class services.moleculer.breaker.EndpointKey
hashCode - Variable in class services.moleculer.eventbus.ListenerEndpoint
hashCode() - Method in class services.moleculer.eventbus.ListenerEndpoint
hashCode - Variable in class services.moleculer.service.ActionEndpoint
hashCode() - Method in class services.moleculer.service.ActionEndpoint
hashers - Variable in class services.moleculer.cacher.DistributedCacher
hashTableSize - Variable in class services.moleculer.cacher.OHCacher: Hash table size (must be a power of 2), defaults to 8192
headerProvider - Variable in class services.moleculer.transporter.GoogleTransporter
health - Variable in class services.moleculer.internal.NodeService: Implementation of the "$node.health" action
heartbeatChannel - Variable in class services.moleculer.transporter.Transporter
heartbeatInterval - Variable in class services.moleculer.transporter.Transporter: Heartbeat sending period in SECONDS.
heartbeatTimeout - Variable in class services.moleculer.transporter.Transporter: Heartbeat timeout in SECONDS.
heartBeatTimer - Variable in class services.moleculer.transporter.Transporter: Cancelable "Heart Beat" timer
host - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
host - Variable in class services.moleculer.transporter.tcp.RemoteAddress
host - Variable in class services.moleculer.transporter.tcp.SendBuffer

I

id - Variable in class services.moleculer.context.Context: Unique context ID
ignoredTypes - Variable in class services.moleculer.breaker.CircuitBreaker
immediate - Variable in class services.moleculer.transporter.AmqpTransporter
increment(ErrorCounter, EndpointKey, Throwable, long) - Method in class services.moleculer.breaker.CircuitBreaker
increment(long) - Method in class services.moleculer.breaker.ErrorCounter
IncrementalUidGenerator - Class in services.moleculer.uid: Fast UidGenerator, based on nodeID and an atomic sequence number.
IncrementalUidGenerator() - Constructor for class services.moleculer.uid.IncrementalUidGenerator
INFO - Static variable in class services.moleculer.logger.ColoredConsoleLogger
INFO - Static variable in class services.moleculer.logger.FastLogFormatter
INFO - Static variable in class services.moleculer.logger.SimpleConsoleLogger
info - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
infoBroadcastChannel - Variable in class services.moleculer.transporter.Transporter
infoChannel - Variable in class services.moleculer.transporter.Transporter
infoScheduled - Variable in class services.moleculer.transporter.Transporter
install(Action, Tree) - Method in class services.moleculer.cacher.Cacher
install(Action, Tree) - Method in class services.moleculer.service.Middleware
internal - Variable in class services.moleculer.transporter.AmqpTransporter
internalServices(boolean) - Method in class services.moleculer.config.ServiceBrokerBuilder
internalServices - Variable in class services.moleculer.config.ServiceBrokerConfig: Install internal ($node) services?
invalidMonitor - Static variable in class services.moleculer.monitor.Monitor
invoker(ServiceInvoker) - Method in class services.moleculer.config.ServiceBrokerBuilder
IonSerializer - Class in services.moleculer.serializer: Amazon ION Serializer

Description: Amazon Ion is a richly-typed, self-describing, hierarchical data serialization format offering interchangeable binary and text representations.
IonSerializer() - Constructor for class services.moleculer.serializer.IonSerializer
isAsyncLocalInvocation() - Method in class services.moleculer.eventbus.DefaultEventbus
isAsyncLocalInvocation() - Method in class services.moleculer.service.DefaultServiceRegistry
isAvailable(long) - Method in class services.moleculer.breaker.ErrorCounter
isCheckVersion() - Method in class services.moleculer.eventbus.DefaultEventbus
isCheckVersion() - Method in class services.moleculer.service.DefaultServiceRegistry
isCleanSession() - Method in class services.moleculer.transporter.MqttTransporter
isCloseEmptyPartitions() - Method in class services.moleculer.cacher.JCacheCacher
isDebug() - Method in class services.moleculer.transporter.Transporter
isDontRandomize() - Method in class services.moleculer.transporter.NatsTransporter
isEmpty() - Method in class services.moleculer.strategy.ArrayBasedStrategy
isEmpty() - Method in class services.moleculer.strategy.Strategy
isEmpty() - Method in class services.moleculer.util.FastBuildMap
isExclusive() - Method in class services.moleculer.transporter.AmqpTransporter
isImmediate() - Method in class services.moleculer.transporter.AmqpTransporter
isInternal() - Method in class services.moleculer.transporter.AmqpTransporter
isInternalServices() - Method in class services.moleculer.config.ServiceBrokerConfig
isLocal() - Method in class services.moleculer.eventbus.ListenerEndpoint
isLocal() - Method in class services.moleculer.eventbus.LocalListenerEndpoint
isLocal() - Method in class services.moleculer.eventbus.RemoteListenerEndpoint
isMandatory() - Method in class services.moleculer.transporter.AmqpTransporter
isOnline(String) - Method in class services.moleculer.transporter.Transporter
isPreferHostname() - Method in class services.moleculer.transporter.Transporter
isPreferLocal() - Method in class services.moleculer.strategy.ArrayBasedStrategyFactory
isSecure() - Method in class services.moleculer.cacher.RedisCacher
isSecure() - Method in class services.moleculer.transporter.NatsTransporter
isSecure() - Method in class services.moleculer.transporter.RedisTransporter
isServicesOnline(Collection<String>) - Method in class services.moleculer.service.DefaultServiceRegistry
isShutDownThreadPools() - Method in class services.moleculer.config.ServiceBrokerConfig
isTlsDebug() - Method in class services.moleculer.transporter.NatsTransporter
isTransacted() - Method in class services.moleculer.transporter.JmsTransporter
isUdpBroadcast() - Method in class services.moleculer.transporter.TcpTransporter
isUdpReuseAddr() - Method in class services.moleculer.transporter.TcpTransporter
isUseHostname() - Method in class services.moleculer.transporter.TcpTransporter
isVerbose() - Method in class services.moleculer.transporter.NatsTransporter
iterator() - Method in class services.moleculer.util.FastBuildMap.FastBuildEntrySet

J

JAVA - Static variable in class services.moleculer.logger.FastLogFormatter
JCacheCacher - Class in services.moleculer.cacher: JSR-107 JCache is a standardized caching API that is Java 6 compatible and introduced in JEE 8.
JCacheCacher() - Constructor for class services.moleculer.cacher.JCacheCacher
JCacheCacher(URI) - Constructor for class services.moleculer.cacher.JCacheCacher
JCacheCacher(CacheManager) - Constructor for class services.moleculer.cacher.JCacheCacher
JmsTransporter - Class in services.moleculer.transporter: JMS Transporter.
JmsTransporter() - Constructor for class services.moleculer.transporter.JmsTransporter
JmsTransporter(String) - Constructor for class services.moleculer.transporter.JmsTransporter
JmsTransporter(TopicConnectionFactory) - Constructor for class services.moleculer.transporter.JmsTransporter
JmsTransporter(String, String, String) - Constructor for class services.moleculer.transporter.JmsTransporter
JmsTransporter(String, String, TopicConnectionFactory) - Constructor for class services.moleculer.transporter.JmsTransporter
JmxMonitor - Class in services.moleculer.monitor: JMX-based System Monitor.
JmxMonitor() - Constructor for class services.moleculer.monitor.JmxMonitor
jsonReader - Variable in class services.moleculer.config.ServiceBrokerConfig: Name of the JSON deserializer API ("jackson", "boon", "builtin", "gson", "fastjson", "genson", etc., null = autodetect)
JsonSerializer - Class in services.moleculer.serializer: Generic JSON serializer

JSON (JavaScript Object Notation) is a lightweight data-interchange format.
JsonSerializer() - Constructor for class services.moleculer.serializer.JsonSerializer
jsonWriter - Variable in class services.moleculer.config.ServiceBrokerConfig: Name of the JSON serializer API ("jackson", "boon", "builtin", "gson", "fast", "genson", "flex", "nano", etc., null = autodetect)

K

KafkaPoller(KafkaTransporter) - Constructor for class services.moleculer.transporter.KafkaTransporter.KafkaPoller
KafkaTransporter - Class in services.moleculer.transporter: Kafka Transporter.
KafkaTransporter() - Constructor for class services.moleculer.transporter.KafkaTransporter
KafkaTransporter(String...) - Constructor for class services.moleculer.transporter.KafkaTransporter
KafkaTransporter.KafkaPoller - Class in services.moleculer.transporter
keepAliveSeconds - Variable in class services.moleculer.transporter.MqttTransporter
key - Variable in class services.moleculer.transporter.tcp.SendBuffer
keys - Variable in class services.moleculer.util.FastBuildMap
keySet() - Method in class services.moleculer.util.FastBuildMap
keyToBytes(String) - Method in class services.moleculer.cacher.OHCacher

L

level - Variable in class services.moleculer.context.Context: Request level (in nested-calls) - the first level is 1
line - Variable in class services.moleculer.logger.FastLogFormatter
list - Variable in class services.moleculer.internal.NodeService: Implementation of the "$node.list" action
Listener - Interface in services.moleculer.eventbus: Interface of all local event listeners.
listener - Variable in class services.moleculer.eventbus.LocalListenerEndpoint: Listener instance (it's a field / inner class in Service object)
ListenerEndpoint - Class in services.moleculer.eventbus
ListenerEndpoint(String, String, String, String) - Constructor for class services.moleculer.eventbus.ListenerEndpoint
listeners - Variable in class services.moleculer.eventbus.DefaultEventbus
local - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
LocalActionEndpoint - Class in services.moleculer.service
LocalActionEndpoint(DefaultServiceRegistry, ExecutorService, String, Tree, Action) - Constructor for class services.moleculer.service.LocalActionEndpoint
localBroadcasterCache - Variable in class services.moleculer.eventbus.DefaultEventbus
LocalListenerEndpoint - Class in services.moleculer.eventbus
LocalListenerEndpoint(ExecutorService, String, String, String, String, Listener, boolean) - Constructor for class services.moleculer.eventbus.LocalListenerEndpoint
localNodeID - Variable in class services.moleculer.internal.NodeService
locator - Variable in class services.moleculer.transporter.TcpTransporter: UDP broadcaster
locked - Variable in class services.moleculer.breaker.ErrorCounter
lockTimeout - Variable in class services.moleculer.breaker.CircuitBreaker: Half-open timeout in MILLISECONDS
lockTimeout - Variable in class services.moleculer.breaker.ErrorCounter
log(LinkedList<LogRecord>, StringBuilder) - Method in class services.moleculer.logger.ColoredConsoleLogger
log(LinkedList<LogRecord>, StringBuilder) - Method in interface services.moleculer.logger.ConsoleLogger
log(LinkedList<LogRecord>, StringBuilder) - Method in class services.moleculer.logger.SimpleConsoleLogger
logDirectory - Variable in class services.moleculer.logger.AsyncFileLogger
logger - Variable in class services.moleculer.eventbus.ListenerEndpoint
logger - Variable in class services.moleculer.monitor.Monitor
logger - Static variable in class services.moleculer.service.ActionEndpoint
logger - Variable in class services.moleculer.service.MoleculerComponent
logger - Static variable in class services.moleculer.ServiceBroker: SLF4J logger of this class.
logger - Static variable in class services.moleculer.transporter.tcp.SendBuffer
logger - Static variable in class services.moleculer.transporter.tcp.TcpReader
logger - Static variable in class services.moleculer.transporter.tcp.TcpWriter
logger - Static variable in class services.moleculer.transporter.tcp.UDPLocator
logger - Static variable in class services.moleculer.transporter.tcp.UDPReceiver
logToConsole - Variable in class services.moleculer.logger.AsyncFileLogger
lowCpuUsage - Variable in class services.moleculer.strategy.CpuUsageStrategy: lowCpuUsage ~= zero CPU usage
lowCpuUsage - Variable in class services.moleculer.strategy.CpuUsageStrategyFactory: lowCpuUsage ~= zero CPU usage

M

main(String[]) - Static method in class services.moleculer.config.MoleculerRunner: Starts/stops Moleculer as a standalone application or as a Windows service.
mandatory - Variable in class services.moleculer.transporter.AmqpTransporter
map - Variable in class services.moleculer.util.FastBuildTree
markAsOffline() - Method in class services.moleculer.transporter.tcp.NodeDescriptor
markAsOffline(long) - Method in class services.moleculer.transporter.tcp.NodeDescriptor
markAsOnline(Tree) - Method in class services.moleculer.transporter.tcp.NodeDescriptor
Matcher - Class in services.moleculer.eventbus: Event mask matcher (eg.
Matcher() - Constructor for class services.moleculer.eventbus.Matcher
matches(String, String) - Static method in class services.moleculer.eventbus.Matcher
max - Variable in class services.moleculer.breaker.ErrorCounter
maxAckExtensionPeriod - Variable in class services.moleculer.transporter.GoogleTransporter
maxCallLevel - Variable in class services.moleculer.context.DefaultContextFactory: Max call level (0 = disabled / unlimited)
maxConnections - Variable in class services.moleculer.transporter.tcp.TcpWriter: Max number of opened connections
maxConnections - Variable in class services.moleculer.transporter.TcpTransporter: Max number of keep-alive connections (-1 = unlimited, 0 = disable keep-alive connections).
maxErrors - Variable in class services.moleculer.breaker.CircuitBreaker: Maximum number of errors in time-window
maxInFlightMessages - Variable in class services.moleculer.transporter.MqttTransporter
maxPacketSize - Variable in class services.moleculer.transporter.tcp.TcpReader: Maximum size of an incoming packet
maxPacketSize - Variable in class services.moleculer.transporter.TcpTransporter: Max enable packet size (BYTES).
maxParamsLength - Variable in class services.moleculer.cacher.DistributedCacher
maxPingsOut - Variable in class services.moleculer.transporter.NatsTransporter
maxSameNodes - Variable in class services.moleculer.breaker.CircuitBreaker: Exit from "maxTries" loop, when strategy returns number of "maxSameNodes" corresponding node IDs
maxTries - Variable in class services.moleculer.breaker.CircuitBreaker: Number of max tries
maxTries - Variable in class services.moleculer.strategy.CpuUsageStrategy: This strategy compares number of 'maxTries' random node.
maxTries - Variable in class services.moleculer.strategy.CpuUsageStrategyFactory: This strategy compares number of 'maxTries' random node.
maxTries - Variable in class services.moleculer.strategy.NetworkLatencyStrategy: This strategy compares number of 'maxTries' random node.
maxTries - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory: This strategy compares number of 'maxTries' random node.
MemoryCacher - Class in services.moleculer.cacher: On-heap memory cache.
MemoryCacher() - Constructor for class services.moleculer.cacher.MemoryCacher
MemoryCacher(int, int) - Constructor for class services.moleculer.cacher.MemoryCacher
MemoryCacher(int, int, int) - Constructor for class services.moleculer.cacher.MemoryCacher
MemoryCacher.MemoryPartition - Class in services.moleculer.cacher
MemoryCacher.PartitionEntry - Class in services.moleculer.cacher
MemoryPartition(int) - Constructor for class services.moleculer.cacher.MemoryCacher.MemoryPartition
message(byte[], byte[]) - Method in class services.moleculer.transporter.RedisTransporter
message(byte[], byte[], byte[]) - Method in class services.moleculer.transporter.RedisTransporter
messageProperties - Variable in class services.moleculer.transporter.AmqpTransporter
messageResendIntervalSeconds - Variable in class services.moleculer.transporter.MqttTransporter
messages - Variable in class services.moleculer.logger.AsyncFileLogger
Middleware - Class in services.moleculer.service
Middleware() - Constructor for class services.moleculer.service.Middleware
Middleware(String) - Constructor for class services.moleculer.service.Middleware
middlewares - Variable in class services.moleculer.service.DefaultServiceRegistry
middlewares - Variable in class services.moleculer.ServiceBroker: Middlewares which defined and added to the Broker before the boot process.
min - Variable in class services.moleculer.breaker.ErrorCounter
MoleculerComponent - Class in services.moleculer.service
MoleculerComponent() - Constructor for class services.moleculer.service.MoleculerComponent
MoleculerComponent(String) - Constructor for class services.moleculer.service.MoleculerComponent
MoleculerRunner - Class in services.moleculer.config: Runs Service Broker as a standalone Java application (or Windows service).
MoleculerRunner() - Constructor for class services.moleculer.config.MoleculerRunner
monitor(Monitor) - Method in class services.moleculer.config.ServiceBrokerBuilder
monitor - Variable in class services.moleculer.config.ServiceBrokerConfig
monitor - Variable in class services.moleculer.internal.NodeService
Monitor - Class in services.moleculer.monitor: Base superclass of all System Monitor implementations.
Monitor() - Constructor for class services.moleculer.monitor.Monitor
monitor - Variable in class services.moleculer.transporter.Transporter
MqttTransporter - Class in services.moleculer.transporter: MQTT Transporter (eg.
MqttTransporter() - Constructor for class services.moleculer.transporter.MqttTransporter
MqttTransporter(String) - Constructor for class services.moleculer.transporter.MqttTransporter
MqttTransporter(String, String, String) - Constructor for class services.moleculer.transporter.MqttTransporter
MsgPackSerializer - Class in services.moleculer.serializer: MessagePack serializer

MessagePack is an efficient binary serialization format.
MsgPackSerializer() - Constructor for class services.moleculer.serializer.MsgPackSerializer
multicastReceiver - Variable in class services.moleculer.transporter.tcp.UDPMulticastReceiver: Multicast receiver
mxBean - Variable in class services.moleculer.monitor.JmxMonitor

N

name - Variable in class services.moleculer.breaker.EndpointKey
name - Variable in class services.moleculer.context.Context: Action name
name - Variable in class services.moleculer.service.ActionEndpoint
name - Variable in class services.moleculer.service.MoleculerComponent
Name - Annotation Type in services.moleculer.service: Human readable name of a Moleculer Component (eg.
nameOf(String, Field) - Static method in class services.moleculer.util.CommonUtils
nameOf(Object, boolean) - Static method in class services.moleculer.util.CommonUtils
names - Variable in class services.moleculer.service.DefaultServiceRegistry
namespace(String) - Method in class services.moleculer.config.ServiceBrokerBuilder
namespace - Variable in class services.moleculer.config.ServiceBrokerConfig
namespace - Variable in class services.moleculer.transporter.tcp.UDPReceiver: Current namespace
namespace - Variable in class services.moleculer.transporter.Transporter
NanoSecRandomStrategy<T extends Endpoint> - Class in services.moleculer.strategy: Nanosec-based pseudorandom invocation strategy.
NanoSecRandomStrategy(ServiceBroker, boolean) - Constructor for class services.moleculer.strategy.NanoSecRandomStrategy
NanoSecRandomStrategyFactory - Class in services.moleculer.strategy: Factory of nanosec-based pseudorandom invocation strategy.
NanoSecRandomStrategyFactory() - Constructor for class services.moleculer.strategy.NanoSecRandomStrategyFactory
NanoSecRandomStrategyFactory(boolean) - Constructor for class services.moleculer.strategy.NanoSecRandomStrategyFactory
NatsTransporter - Class in services.moleculer.transporter: NATS Transporter.
NatsTransporter() - Constructor for class services.moleculer.transporter.NatsTransporter
NatsTransporter(String...) - Constructor for class services.moleculer.transporter.NatsTransporter
NatsTransporter(String, String, boolean, String...) - Constructor for class services.moleculer.transporter.NatsTransporter
netIf - Variable in class services.moleculer.transporter.tcp.UDPMulticastReceiver: Network interface (or null)
NetworkLatencyStrategy<T extends Endpoint> - Class in services.moleculer.strategy: Lowest network latency strategy.
NetworkLatencyStrategy(ServiceBroker, boolean, int, NetworkLatencyStrategyFactory) - Constructor for class services.moleculer.strategy.NetworkLatencyStrategy
NetworkLatencyStrategyFactory - Class in services.moleculer.strategy: Factory of lowest network latency strategy.
NetworkLatencyStrategyFactory() - Constructor for class services.moleculer.strategy.NetworkLatencyStrategyFactory
NetworkLatencyStrategyFactory(boolean) - Constructor for class services.moleculer.strategy.NetworkLatencyStrategyFactory
NetworkLatencyStrategyFactory.Samples - Class in services.moleculer.strategy
next(Endpoint[]) - Method in class services.moleculer.strategy.ArrayBasedStrategy
next(Endpoint[]) - Method in class services.moleculer.strategy.CpuUsageStrategy
next(Endpoint[]) - Method in class services.moleculer.strategy.NanoSecRandomStrategy
next(Endpoint[]) - Method in class services.moleculer.strategy.NetworkLatencyStrategy
next(Endpoint[]) - Method in class services.moleculer.strategy.RoundRobinStrategy
next(Endpoint[]) - Method in class services.moleculer.strategy.SecureRandomStrategy
next(Endpoint[]) - Method in class services.moleculer.strategy.XorShiftRandomStrategy
nextIndex - Variable in class services.moleculer.transporter.tcp.UDPLocator
nextUID() - Method in class services.moleculer.uid.IncrementalUidGenerator
nextUID() - Method in class services.moleculer.uid.StandardUidGenerator
nextUID() - Method in class services.moleculer.uid.UidGenerator
NodeDescriptor - Class in services.moleculer.transporter.tcp: Node descriptor of all (remote and local) nodes.
NodeDescriptor(String, boolean, boolean) - Constructor for class services.moleculer.transporter.tcp.NodeDescriptor
NodeDescriptor(String, boolean, String, int) - Constructor for class services.moleculer.transporter.tcp.NodeDescriptor
NodeDescriptor(String, boolean, boolean, Tree) - Constructor for class services.moleculer.transporter.tcp.NodeDescriptor
nodeID - Variable in class services.moleculer.breaker.EndpointKey
nodeID(String) - Method in class services.moleculer.config.ServiceBrokerBuilder
nodeID - Variable in class services.moleculer.config.ServiceBrokerConfig
nodeID(String) - Static method in class services.moleculer.context.CallOptions
nodeID - Variable in class services.moleculer.context.CallOptions.Options: Target nodeID (null = select automatically by the Invocation Strategy)
nodeID(String) - Method in class services.moleculer.context.CallOptions.Options
nodeID - Variable in class services.moleculer.eventbus.DefaultEventbus: Local Node ID
nodeID - Variable in class services.moleculer.service.DefaultServiceRegistry
nodeID - Variable in class services.moleculer.service.Endpoint
nodeID - Variable in class services.moleculer.ServiceBroker: Unique ID of this node (~= ServiceBroker instance).
nodeID - Variable in class services.moleculer.strategy.ArrayBasedStrategy
nodeID - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory
nodeID - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
nodeID - Variable in class services.moleculer.transporter.tcp.SendBuffer
nodeID - Variable in class services.moleculer.transporter.tcp.UDPLocator: Current NodeID
nodeID - Variable in class services.moleculer.transporter.tcp.UDPReceiver: Current NodeID
nodeID - Variable in class services.moleculer.transporter.Transporter
nodes - Variable in class services.moleculer.transporter.Transporter
NodeService - Class in services.moleculer.internal: The broker contains some internal services to check the health of node or get broker statistics.
NodeService() - Constructor for class services.moleculer.internal.NodeService
normalizeLine(String) - Method in class services.moleculer.logger.FastLogFormatter
normalizeWord(String) - Method in class services.moleculer.logger.FastLogFormatter
NullTransporter - Class in services.moleculer.transporter: "Null" / empty transporter.
NullTransporter() - Constructor for class services.moleculer.transporter.NullTransporter
numberOfSubmittedPackets - Variable in class services.moleculer.transporter.tcp.UDPLocator

O

of(String...) - Static method in class services.moleculer.eventbus.Groups
offlineSince - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
offlineTimeout - Variable in class services.moleculer.transporter.Transporter: How long keep information in registry about the offline nodes (SECONDS).
OHCacher - Class in services.moleculer.cacher: Off-heap cache implementation (it's similar to MemoryCacher, but stores entries in the off-heap RAM).
OHCacher() - Constructor for class services.moleculer.cacher.OHCacher: Creates Off-heap Cacher with the default settings.
OHCacher(long, int) - Constructor for class services.moleculer.cacher.OHCacher: Creates Off-heap Cacher.
OHCacher(long, int, int, int, int) - Constructor for class services.moleculer.cacher.OHCacher: Creates Off-heap Cacher.
OHCacher.ArraySerializer - Class in services.moleculer.cacher
on(Tree) - Method in interface services.moleculer.eventbus.Listener
on(String, Tree, Groups, boolean) - Method in class services.moleculer.eventbus.ListenerEndpoint
on(String, Tree, Groups, boolean) - Method in class services.moleculer.eventbus.LocalListenerEndpoint
on(String, Tree, Groups, boolean) - Method in class services.moleculer.eventbus.RemoteListenerEndpoint
onDisconnect(ConnectionEvent) - Method in class services.moleculer.transporter.NatsTransporter
onMessage(Message) - Method in class services.moleculer.transporter.NatsTransporter
opened - Variable in class services.moleculer.transporter.tcp.TcpWriter
openedFile - Variable in class services.moleculer.logger.AsyncFileLogger
openedStream - Variable in class services.moleculer.logger.AsyncFileLogger
Options(String, long, int) - Constructor for class services.moleculer.context.CallOptions.Options
opts - Variable in class services.moleculer.context.Context: Calling options
opts - Variable in class services.moleculer.util.ParseResult

P

PACKET_DISCONNECT - Static variable in class services.moleculer.transporter.Transporter
PACKET_DISCOVER - Static variable in class services.moleculer.transporter.Transporter
PACKET_EVENT - Static variable in class services.moleculer.transporter.Transporter
PACKET_EVENT_ID - Static variable in class services.moleculer.transporter.TcpTransporter
PACKET_GOSSIP_HELLO_ID - Static variable in class services.moleculer.transporter.TcpTransporter
PACKET_GOSSIP_REQ_ID - Static variable in class services.moleculer.transporter.TcpTransporter
PACKET_GOSSIP_RSP_ID - Static variable in class services.moleculer.transporter.TcpTransporter
PACKET_HEARTBEAT - Static variable in class services.moleculer.transporter.Transporter
PACKET_INFO - Static variable in class services.moleculer.transporter.Transporter
PACKET_PING - Static variable in class services.moleculer.transporter.Transporter
PACKET_PING_ID - Static variable in class services.moleculer.transporter.TcpTransporter
PACKET_PONG - Static variable in class services.moleculer.transporter.Transporter
PACKET_PONG_ID - Static variable in class services.moleculer.transporter.TcpTransporter
PACKET_REQUEST - Static variable in class services.moleculer.transporter.Transporter
PACKET_REQUEST_ID - Static variable in class services.moleculer.transporter.TcpTransporter
PACKET_RESPONSE - Static variable in class services.moleculer.transporter.Transporter
PACKET_RESPONSE_ID - Static variable in class services.moleculer.transporter.TcpTransporter
parallelPullCount - Variable in class services.moleculer.transporter.GoogleTransporter
params - Variable in class services.moleculer.context.Context: Request parameters (including meta)
parentID - Variable in class services.moleculer.context.Context: Parent context ID (in nested-calls)
parseParams(Object[]) - Static method in class services.moleculer.util.CommonUtils
ParseResult - Class in services.moleculer.util
parseURLs(Tree, String, String[]) - Static method in class services.moleculer.util.CommonUtils
parseURLs(String[], String, boolean) - Static method in class services.moleculer.util.redis.RedisGetSetClient
PartitionEntry(Tree, long) - Constructor for class services.moleculer.cacher.MemoryCacher.PartitionEntry
partitionPosition(String, boolean) - Static method in class services.moleculer.cacher.JCacheCacher
partitionPosition(String, boolean) - Static method in class services.moleculer.cacher.MemoryCacher
partitions - Variable in class services.moleculer.cacher.JCacheCacher
partitions - Variable in class services.moleculer.cacher.MemoryCacher
password - Variable in class services.moleculer.cacher.RedisCacher
password - Variable in class services.moleculer.transporter.AmqpTransporter
password - Variable in class services.moleculer.transporter.JmsTransporter
password - Variable in class services.moleculer.transporter.MqttTransporter
password - Variable in class services.moleculer.transporter.NatsTransporter
password - Variable in class services.moleculer.transporter.RedisTransporter
PendingPromise - Class in services.moleculer.service: Promise container of a pending action calls.
ping(long, String) - Method in class services.moleculer.service.DefaultServiceRegistry
ping(long, String) - Method in class services.moleculer.service.ServiceRegistry
ping(String) - Method in class services.moleculer.ServiceBroker: Sends a PING message to the specified node.
ping(long, String) - Method in class services.moleculer.ServiceBroker: Sends a PING message to the specified node.
pingChannel - Variable in class services.moleculer.transporter.Transporter
pingInterval - Variable in class services.moleculer.transporter.NatsTransporter
pingPeriod - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory: Ping period time, in SECONDS.
pingTimeout - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory: Ping period time, in MILLISECONDS.
pingTimer - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory: Cancelable timer of ping loop
pointer - Variable in class services.moleculer.breaker.ErrorCounter
pointer - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory.Samples
poller - Variable in class services.moleculer.transporter.KafkaTransporter
pongChannel - Variable in class services.moleculer.transporter.Transporter
port - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
port - Variable in class services.moleculer.transporter.tcp.RemoteAddress
port - Variable in class services.moleculer.transporter.tcp.SendBuffer
port - Variable in class services.moleculer.transporter.tcp.UDPReceiver: TCP port (used by the Transporter and Gossiper services)
port - Variable in class services.moleculer.transporter.TcpTransporter: TCP port (used by the Transporter and Gossiper services).
position - Variable in class services.moleculer.logger.FastLogFormatter
preferHostname - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
preferHostname - Variable in class services.moleculer.transporter.Transporter: Use hostnames instead of IP addresses As the DHCP environment is dynamic, any later attempt to use IPs instead hostnames would most likely yield false results.
preferLocal - Variable in class services.moleculer.strategy.ArrayBasedStrategy
preferLocal - Variable in class services.moleculer.strategy.ArrayBasedStrategyFactory: Invoke local actions if possible
prefix - Variable in class services.moleculer.logger.AsyncFileLogger
prefix - Variable in class services.moleculer.transporter.Transporter
prefix - Variable in class services.moleculer.uid.IncrementalUidGenerator: UID prefix (empty = hostname)
previousNodeID - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory
prevTimeoutAt - Variable in class services.moleculer.service.DefaultServiceRegistry: Next scheduled time to check timeouts
priority - Variable in class services.moleculer.transporter.JmsTransporter
processGossipHello(Tree) - Method in class services.moleculer.transporter.TcpTransporter
processGossipRequest(Tree) - Method in class services.moleculer.transporter.TcpTransporter
processGossipResponse(Tree) - Method in class services.moleculer.transporter.TcpTransporter
processPacket(byte[], int) - Method in class services.moleculer.transporter.tcp.TcpReader
processReceivedMessage(DatagramPacket, byte[]) - Method in class services.moleculer.transporter.tcp.UDPReceiver
processReceivedMessage(String, byte[]) - Method in class services.moleculer.transporter.Transporter: Process incoming message directly (without new Task).
producer - Variable in class services.moleculer.transporter.KafkaTransporter
producerProperties - Variable in class services.moleculer.transporter.KafkaTransporter
projectID - Variable in class services.moleculer.transporter.GoogleTransporter
promise - Variable in class services.moleculer.service.PendingPromise
promise - Variable in class services.moleculer.service.ServiceListener
promises - Variable in class services.moleculer.service.DefaultServiceRegistry
PROTOCOL_VERSION - Static variable in class services.moleculer.ServiceBroker: Version of the implemented Moleculer Protocol.
psubscribed(byte[], long) - Method in class services.moleculer.transporter.RedisTransporter
publish(Event) - Method in class services.moleculer.cacher.RedisCacher
publish(LogRecord) - Method in class services.moleculer.logger.AsyncFileLogger
publish(String, Tree) - Method in class services.moleculer.transporter.AmqpTransporter
publish(String, Tree) - Method in class services.moleculer.transporter.GoogleTransporter
publish(String, Tree) - Method in class services.moleculer.transporter.JmsTransporter
publish(String, Tree) - Method in class services.moleculer.transporter.KafkaTransporter
publish(String, Tree) - Method in class services.moleculer.transporter.MqttTransporter
publish(String, Tree) - Method in class services.moleculer.transporter.NatsTransporter
publish(String, Tree) - Method in class services.moleculer.transporter.NullTransporter
publish(String, Tree) - Method in class services.moleculer.transporter.RedisTransporter
publish(Event) - Method in class services.moleculer.transporter.RedisTransporter
publish(String, Tree) - Method in class services.moleculer.transporter.TcpTransporter
publish(String, String, Tree) - Method in class services.moleculer.transporter.Transporter
publish(String, Tree) - Method in class services.moleculer.transporter.Transporter
publish(String, byte[]) - Method in class services.moleculer.util.redis.RedisPubSubClient
published(MqttClient, PublishMessage) - Method in class services.moleculer.transporter.MqttTransporter
publishers - Variable in class services.moleculer.transporter.GoogleTransporter
publishers - Variable in class services.moleculer.transporter.JmsTransporter
publishReceived(MqttClient, PublishMessage) - Method in class services.moleculer.transporter.MqttTransporter
punsubscribed(byte[], long) - Method in class services.moleculer.transporter.RedisTransporter
put(String, Object) - Method in class services.moleculer.util.FastBuildMap: WARNING: All key must be unique!
putAll(Map) - Method in class services.moleculer.util.FastBuildMap
putUnsafe(String, Object) - Method in class services.moleculer.util.FastBuildTree
putUnsafe(String, Tree) - Method in class services.moleculer.util.FastBuildTree
putUnsafe(String, FastBuildTree) - Method in class services.moleculer.util.FastBuildTree

Q

qos - Variable in class services.moleculer.transporter.MqttTransporter
queue - Variable in class services.moleculer.transporter.tcp.SendBuffer
queueProperties - Variable in class services.moleculer.transporter.AmqpTransporter

R

read(byte[]) - Method in class services.moleculer.serializer.Serializer
reader(String) - Method in class services.moleculer.config.ServiceBrokerBuilder
reader - Variable in class services.moleculer.serializer.Serializer
reader - Variable in class services.moleculer.transporter.TcpTransporter: Socket reader
readerLock - Variable in class services.moleculer.cacher.MemoryCacher.MemoryPartition
readFully(InputStream) - Static method in class services.moleculer.util.CommonUtils
readLock - Variable in class services.moleculer.breaker.ErrorCounter
readLock - Variable in class services.moleculer.cacher.JCacheCacher
readLock - Variable in class services.moleculer.cacher.MemoryCacher
readLock - Variable in class services.moleculer.eventbus.DefaultEventbus: Reader lock of the Event Bus
readLock - Variable in class services.moleculer.service.DefaultServiceRegistry: Reader lock of configuration
readLock - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
readTree(String) - Static method in class services.moleculer.util.CommonUtils
readTree(InputStream, String) - Static method in class services.moleculer.util.CommonUtils
receive() - Method in class services.moleculer.transporter.tcp.UDPBroadcastReceiver
receive() - Method in class services.moleculer.transporter.tcp.UDPMulticastReceiver
receive() - Method in class services.moleculer.transporter.tcp.UDPReceiver
received(byte, byte[]) - Method in class services.moleculer.transporter.TcpTransporter
received(String, byte[]) - Method in class services.moleculer.transporter.Transporter: Process incoming message later (in a new Runnable or JoinForkTask).
receiveEvent(Tree) - Method in class services.moleculer.eventbus.DefaultEventbus
receiveEvent(Tree) - Method in class services.moleculer.eventbus.Eventbus
receivePong(Tree) - Method in class services.moleculer.service.DefaultServiceRegistry
receivePong(Tree) - Method in class services.moleculer.service.ServiceRegistry
receiveRequest(Tree) - Method in class services.moleculer.service.DefaultServiceRegistry
receiveRequest(Tree) - Method in class services.moleculer.service.ServiceRegistry
receiveResponse(Tree) - Method in class services.moleculer.service.DefaultServiceRegistry
receiveResponse(Tree) - Method in class services.moleculer.service.ServiceRegistry
receivers - Variable in class services.moleculer.transporter.tcp.UDPLocator
reconnect() - Method in class services.moleculer.cacher.RedisCacher
reconnect() - Method in class services.moleculer.transporter.AmqpTransporter
reconnect(Throwable) - Method in class services.moleculer.transporter.GoogleTransporter
reconnect(Throwable) - Method in class services.moleculer.transporter.JmsTransporter
reconnect(Throwable) - Method in class services.moleculer.transporter.KafkaTransporter
reconnect(Throwable) - Method in class services.moleculer.transporter.MqttTransporter
reconnect() - Method in class services.moleculer.transporter.NatsTransporter
reconnect() - Method in class services.moleculer.transporter.RedisTransporter
reconnect() - Method in class services.moleculer.transporter.TcpTransporter
RedisCacher - Class in services.moleculer.cacher: Redis-based distributed cache.
RedisCacher() - Constructor for class services.moleculer.cacher.RedisCacher
RedisCacher(String...) - Constructor for class services.moleculer.cacher.RedisCacher
RedisCacher(String, int, boolean, String...) - Constructor for class services.moleculer.cacher.RedisCacher
RedisGetSetClient - Class in services.moleculer.util.redis: Promise-based get/set Redis client.
RedisGetSetClient(String[], String, boolean, ExecutorService, EventBus) - Constructor for class services.moleculer.util.redis.RedisGetSetClient
RedisPubSubClient - Class in services.moleculer.util.redis: Promise-based pub/sub Redis client.
RedisPubSubClient(String[], String, boolean, ExecutorService, EventBus, RedisPubSubListener<byte[], byte[]>) - Constructor for class services.moleculer.util.redis.RedisPubSubClient
RedisTransporter - Class in services.moleculer.transporter: Redis Transporter.
RedisTransporter() - Constructor for class services.moleculer.transporter.RedisTransporter
RedisTransporter(String...) - Constructor for class services.moleculer.transporter.RedisTransporter
RedisTransporter(String, boolean, String...) - Constructor for class services.moleculer.transporter.RedisTransporter
register(String, Promise, long) - Method in class services.moleculer.service.DefaultServiceRegistry
registerAsNewNode(String, String, int) - Method in class services.moleculer.transporter.TcpTransporter
registry(ServiceRegistry) - Method in class services.moleculer.config.ServiceBrokerBuilder
registry - Variable in class services.moleculer.transporter.Transporter
RemoteActionEndpoint - Class in services.moleculer.service
RemoteActionEndpoint(DefaultServiceRegistry, Transporter, String, Tree) - Constructor for class services.moleculer.service.RemoteActionEndpoint
RemoteAddress - Class in services.moleculer.transporter.tcp
RemoteAddress(String, int) - Constructor for class services.moleculer.transporter.tcp.RemoteAddress
RemoteListenerEndpoint - Class in services.moleculer.eventbus
RemoteListenerEndpoint(Transporter, String, String, String, String) - Constructor for class services.moleculer.eventbus.RemoteListenerEndpoint
remove(String) - Method in class services.moleculer.strategy.ArrayBasedStrategy
remove(String) - Method in class services.moleculer.strategy.Strategy
remove(Object) - Method in class services.moleculer.util.FastBuildMap
removeActions(String) - Method in class services.moleculer.service.DefaultServiceRegistry
removeActions(String) - Method in class services.moleculer.service.ServiceRegistry
removeCacheConfiguration(String) - Method in class services.moleculer.cacher.JCacheCacher
removeIgnoredType(Class<? extends Throwable>) - Method in class services.moleculer.breaker.CircuitBreaker
removeListeners(String) - Method in class services.moleculer.eventbus.DefaultEventbus
removeListeners(String) - Method in class services.moleculer.eventbus.Eventbus
removeOldEntries(long) - Method in class services.moleculer.cacher.MemoryCacher.MemoryPartition
repl() - Method in class services.moleculer.ServiceBroker: Starts a local (System in/out) developer console.
repl(boolean) - Method in class services.moleculer.ServiceBroker: Starts a local (System in/out) or a remote (telnet-based) developer console.
requestChannel - Variable in class services.moleculer.transporter.Transporter
requestID - Variable in class services.moleculer.context.Context: Request ID (= first context ID)
reschedule(long) - Method in class services.moleculer.service.DefaultServiceRegistry: Recalculates the next timeout checking time
reset() - Method in class services.moleculer.breaker.ErrorCounter
resolveUnit(String) - Static method in class services.moleculer.util.CommonUtils
responseChannel - Variable in class services.moleculer.transporter.Transporter
responseTimes - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory
retry(Throwable, String, Tree, CallOptions.Options, Context, String, int) - Method in class services.moleculer.breaker.CircuitBreaker
retry(Throwable, String, Tree, CallOptions.Options, Context, String, int) - Method in class services.moleculer.service.DefaultServiceInvoker
retryCount - Variable in class services.moleculer.context.CallOptions.Options: Number of retries (0 = disable retries)
retryCount(int) - Method in class services.moleculer.context.CallOptions.Options
retryCount(int) - Static method in class services.moleculer.context.CallOptions
retrySettings - Variable in class services.moleculer.transporter.GoogleTransporter
rnd - Variable in class services.moleculer.strategy.SecureRandomStrategy
rnd - Variable in class services.moleculer.strategy.XorShiftRandomStrategy
rnd - Variable in class services.moleculer.transporter.TcpTransporter: Random generator.
RoundRobinStrategy<T extends Endpoint> - Class in services.moleculer.strategy: Round-Robin invocation strategy.
RoundRobinStrategy(ServiceBroker, boolean) - Constructor for class services.moleculer.strategy.RoundRobinStrategy
RoundRobinStrategyFactory - Class in services.moleculer.strategy: Factory of Round-Robin invocation strategy.
RoundRobinStrategyFactory() - Constructor for class services.moleculer.strategy.RoundRobinStrategyFactory
RoundRobinStrategyFactory(boolean) - Constructor for class services.moleculer.strategy.RoundRobinStrategyFactory
run() - Method in class services.moleculer.cacher.MemoryCacher
run() - Method in class services.moleculer.logger.AsyncFileLogger
run() - Method in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
run() - Method in class services.moleculer.transporter.tcp.TcpReader
run() - Method in class services.moleculer.transporter.tcp.TcpWriter

S

Samples(int) - Constructor for class services.moleculer.strategy.NetworkLatencyStrategyFactory.Samples
scheduler - Variable in class services.moleculer.cacher.RedisCacher
scheduler(ScheduledExecutorService) - Method in class services.moleculer.config.ServiceBrokerBuilder
scheduler - Variable in class services.moleculer.config.ServiceBrokerConfig
scheduler - Variable in class services.moleculer.service.DefaultServiceRegistry
scheduler - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory
scheduler - Variable in class services.moleculer.transporter.tcp.UDPLocator: Sender's executor
scheduler - Variable in class services.moleculer.transporter.Transporter
secure - Variable in class services.moleculer.cacher.RedisCacher
secure - Variable in class services.moleculer.transporter.NatsTransporter
secure - Variable in class services.moleculer.transporter.RedisTransporter
SecureRandomStrategy<T extends Endpoint> - Class in services.moleculer.strategy: Java Random/SecureRandom-based invocation strategy.
SecureRandomStrategy(ServiceBroker, boolean) - Constructor for class services.moleculer.strategy.SecureRandomStrategy
SecureRandomStrategyFactory - Class in services.moleculer.strategy: Factory of Java SecureRandom-based invocation strategy.
SecureRandomStrategyFactory() - Constructor for class services.moleculer.strategy.SecureRandomStrategyFactory
SecureRandomStrategyFactory(boolean) - Constructor for class services.moleculer.strategy.SecureRandomStrategyFactory
segmentCount - Variable in class services.moleculer.cacher.OHCacher: Number of segments (must be a power of 2), defaults to number-of-cores * 2
selector - Variable in class services.moleculer.transporter.tcp.TcpReader
selector - Variable in class services.moleculer.transporter.tcp.TcpWriter
send(String, byte[]) - Method in class services.moleculer.transporter.tcp.TcpWriter
send() - Method in class services.moleculer.transporter.tcp.UDPBroadcastReceiver
send() - Method in class services.moleculer.transporter.tcp.UDPLocator
send() - Method in class services.moleculer.transporter.tcp.UDPMulticastReceiver
send() - Method in class services.moleculer.transporter.tcp.UDPReceiver
SendBuffer - Class in services.moleculer.transporter.tcp: Attachment of TcpWriter's SelectionKeys.
SendBuffer(String, String, int, boolean) - Constructor for class services.moleculer.transporter.tcp.SendBuffer
sendDisconnectPacket() - Method in class services.moleculer.transporter.TcpTransporter
sendDisconnectPacket() - Method in class services.moleculer.transporter.Transporter
sendDiscoverPacket(String) - Method in class services.moleculer.transporter.Transporter
sendGossipRequest() - Method in class services.moleculer.transporter.TcpTransporter: Create and send a Gossip request packet.
sendGossipToRandomEndpoint(String[], int, byte[], Tree) - Method in class services.moleculer.transporter.TcpTransporter
sendHeartbeatPacket() - Method in class services.moleculer.transporter.Transporter
sendInfoPacket(String) - Method in class services.moleculer.transporter.Transporter
sendNextPing() - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
sendPing(String) - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
sendPongPacket(String, Tree) - Method in class services.moleculer.transporter.Transporter
seq - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
serialize(byte[], ByteBuffer) - Method in class services.moleculer.cacher.OHCacher.ArraySerializer
serialize(byte, Tree) - Method in class services.moleculer.transporter.TcpTransporter
serializedSize(byte[]) - Method in class services.moleculer.cacher.OHCacher.ArraySerializer
serializeKey(StringBuilder, Tree, String...) - Method in class services.moleculer.cacher.Cacher
serializer - Variable in class services.moleculer.cacher.JCacheCacher
serializer - Variable in class services.moleculer.cacher.OHCacher
serializer - Variable in class services.moleculer.cacher.RedisCacher
Serializer - Class in services.moleculer.serializer: Base superclass of all data serializer implementations.
Serializer(String) - Constructor for class services.moleculer.serializer.Serializer
serializer - Variable in class services.moleculer.transporter.Transporter
serverChannel - Variable in class services.moleculer.transporter.tcp.TcpReader
Service - Class in services.moleculer.service
Service() - Constructor for class services.moleculer.service.Service
Service(String) - Constructor for class services.moleculer.service.Service
ServiceBroker - Class in services.moleculer: The ServiceBroker is the main component of Moleculer.
ServiceBroker(ServiceBrokerConfig) - Constructor for class services.moleculer.ServiceBroker: Creates a new ServiceBroker by the specified configuration.
ServiceBroker() - Constructor for class services.moleculer.ServiceBroker: Creates a new ServiceBroker without Transporter.
ServiceBroker(String) - Constructor for class services.moleculer.ServiceBroker: Creates a new ServiceBroker without Transporter and with the specified ServiceBroker.nodeID.
ServiceBroker(String, Cacher, Transporter) - Constructor for class services.moleculer.ServiceBroker: Creates a new ServiceBroker with the specified ServiceBroker.nodeID, Cacher, and Transporter.
ServiceBrokerBuilder - Class in services.moleculer.config: Builder-style ServiceBroker factory.
ServiceBrokerBuilder() - Constructor for class services.moleculer.config.ServiceBrokerBuilder
ServiceBrokerConfig - Class in services.moleculer.config
ServiceBrokerConfig() - Constructor for class services.moleculer.config.ServiceBrokerConfig
ServiceBrokerConfig(String, Cacher, Transporter) - Constructor for class services.moleculer.config.ServiceBrokerConfig
serviceInvoker - Variable in class services.moleculer.config.ServiceBrokerConfig
serviceInvoker - Variable in class services.moleculer.context.Context
serviceInvoker - Variable in class services.moleculer.context.DefaultContextFactory
ServiceInvoker - Class in services.moleculer.service: Base superclass of all Service Invoker implementations.
ServiceInvoker() - Constructor for class services.moleculer.service.ServiceInvoker
serviceInvoker - Variable in class services.moleculer.ServiceBroker: Service invoker.
ServiceListener - Class in services.moleculer.service: Promise container of a "waitingForServices" calls.
serviceListeners - Variable in class services.moleculer.service.DefaultServiceRegistry: Promises of the "waitingForServices" calls
serviceName - Variable in class services.moleculer.eventbus.ListenerEndpoint
serviceRegistry - Variable in class services.moleculer.breaker.CircuitBreaker
serviceRegistry - Variable in class services.moleculer.config.ServiceBrokerConfig
serviceRegistry - Variable in class services.moleculer.service.DefaultServiceInvoker
ServiceRegistry - Class in services.moleculer.service: Base superclass of all Service Registry implementations.
ServiceRegistry() - Constructor for class services.moleculer.service.ServiceRegistry
serviceRegistry - Variable in class services.moleculer.ServiceBroker: Implementation of the service registry of the current node.
services - Variable in class services.moleculer.internal.NodeService: Implementation of the "$node.services" action
services - Variable in class services.moleculer.service.DefaultServiceRegistry
services - Variable in class services.moleculer.service.ServiceListener
services - Variable in class services.moleculer.ServiceBroker: Services which defined and added to the Broker before the boot process.
services.moleculer - package services.moleculer
services.moleculer.breaker - package services.moleculer.breaker
services.moleculer.cacher - package services.moleculer.cacher
services.moleculer.config - package services.moleculer.config
services.moleculer.context - package services.moleculer.context
services.moleculer.eventbus - package services.moleculer.eventbus
services.moleculer.internal - package services.moleculer.internal
services.moleculer.logger - package services.moleculer.logger
services.moleculer.monitor - package services.moleculer.monitor
services.moleculer.serializer - package services.moleculer.serializer
services.moleculer.service - package services.moleculer.service
services.moleculer.strategy - package services.moleculer.strategy
services.moleculer.transporter - package services.moleculer.transporter
services.moleculer.transporter.tcp - package services.moleculer.transporter.tcp
services.moleculer.uid - package services.moleculer.uid
services.moleculer.util - package services.moleculer.util
services.moleculer.util.redis - package services.moleculer.util.redis
servicesOnlineTimer - Variable in class services.moleculer.service.DefaultServiceRegistry: Cancelable timer for handling "wait for service" calls
session - Variable in class services.moleculer.transporter.JmsTransporter
set(String, Tree, int) - Method in class services.moleculer.cacher.Cacher: Sets a content by key into the cache.
set(String, Tree, int) - Method in class services.moleculer.cacher.JCacheCacher
set(String, Tree, int) - Method in class services.moleculer.cacher.MemoryCacher.MemoryPartition
set(String, Tree, int) - Method in class services.moleculer.cacher.MemoryCacher
set(String, Tree, int) - Method in class services.moleculer.cacher.OHCacher
set(String, Tree, int) - Method in class services.moleculer.cacher.RedisCacher
set(String, byte[], SetArgs) - Method in class services.moleculer.util.redis.RedisGetSetClient: Sets a content by key.
setAckDeadlineSeconds(int) - Method in class services.moleculer.transporter.GoogleTransporter
setAcknowledgeMode(int) - Method in class services.moleculer.transporter.JmsTransporter
setApplicationContext(ApplicationContext) - Method in class services.moleculer.config.SpringRegistrator
setAsyncLocalInvocation(boolean) - Method in class services.moleculer.eventbus.DefaultEventbus
setAsyncLocalInvocation(boolean) - Method in class services.moleculer.service.DefaultServiceRegistry
setAverageSamples(int) - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
setBatchingSettings(BatchingSettings) - Method in class services.moleculer.transporter.GoogleTransporter
setBlockingTimeoutSeconds(int) - Method in class services.moleculer.transporter.MqttTransporter
setCacheConfigurations(Map<String, Configuration<String, byte[]>>) - Method in class services.moleculer.cacher.JCacheCacher
setCacheManager(CacheManager) - Method in class services.moleculer.cacher.JCacheCacher
setCacher(Cacher) - Method in class services.moleculer.config.ServiceBrokerConfig
setCapacity(int) - Method in class services.moleculer.cacher.MemoryCacher
setCapacity(long) - Method in class services.moleculer.cacher.OHCacher
setChannelProvider(TransportChannelProvider) - Method in class services.moleculer.transporter.GoogleTransporter
setCheckVersion(boolean) - Method in class services.moleculer.eventbus.DefaultEventbus
setCheckVersion(boolean) - Method in class services.moleculer.service.DefaultServiceRegistry
setCleanSession(boolean) - Method in class services.moleculer.transporter.MqttTransporter
setCleanup(int) - Method in class services.moleculer.breaker.CircuitBreaker
setCleanup(int) - Method in class services.moleculer.cacher.MemoryCacher
setClock(ApiClock) - Method in class services.moleculer.transporter.GoogleTransporter
setCloseEmptyPartitions(boolean) - Method in class services.moleculer.cacher.JCacheCacher
setCommand(String) - Method in class services.moleculer.monitor.CommandMonitor
setCompressAbove(int) - Method in class services.moleculer.cacher.OHCacher
setCompressionLevel(int) - Method in class services.moleculer.cacher.OHCacher
setConnectionFactoryJndiName(String) - Method in class services.moleculer.transporter.JmsTransporter
setConnectTimeoutSeconds(int) - Method in class services.moleculer.transporter.MqttTransporter
setConsumerProperties(Properties) - Method in class services.moleculer.transporter.KafkaTransporter
setConsumerProperty(String, String) - Method in class services.moleculer.transporter.KafkaTransporter
setContextFactory(ContextFactory) - Method in class services.moleculer.config.ServiceBrokerConfig
setCredentialsProvider(CredentialsProvider) - Method in class services.moleculer.transporter.GoogleTransporter
setDebug(boolean) - Method in class services.moleculer.transporter.Transporter
setDefaultConfiguration(Configuration<String, byte[]>) - Method in class services.moleculer.cacher.JCacheCacher
setDeliveryMode(int) - Method in class services.moleculer.transporter.JmsTransporter
setDontRandomize(boolean) - Method in class services.moleculer.transporter.NatsTransporter
setEventbus(Eventbus) - Method in class services.moleculer.config.ServiceBrokerConfig
setExchangeProperties(Map<String, Object>) - Method in class services.moleculer.transporter.AmqpTransporter
setExchangeType(String) - Method in class services.moleculer.transporter.AmqpTransporter
setExclusive(boolean) - Method in class services.moleculer.transporter.AmqpTransporter
setExecutor(ExecutorService) - Method in class services.moleculer.config.ServiceBrokerConfig
setExecutorProvider(ExecutorProvider) - Method in class services.moleculer.transporter.GoogleTransporter
setFactory(ConnectionFactory) - Method in class services.moleculer.transporter.AmqpTransporter
setFlowControlSettings(FlowControlSettings) - Method in class services.moleculer.transporter.GoogleTransporter
setGossipPeriod(int) - Method in class services.moleculer.transporter.TcpTransporter
setHashTableSize(int) - Method in class services.moleculer.cacher.OHCacher
setHeaderProvider(HeaderProvider) - Method in class services.moleculer.transporter.GoogleTransporter
setHeartbeatInterval(int) - Method in class services.moleculer.transporter.TcpTransporter
setHeartbeatInterval(int) - Method in class services.moleculer.transporter.Transporter
setHeartbeatTimeout(int) - Method in class services.moleculer.transporter.TcpTransporter
setHeartbeatTimeout(int) - Method in class services.moleculer.transporter.Transporter
setIgnoredTypes(Set<Class<? extends Throwable>>) - Method in class services.moleculer.breaker.CircuitBreaker
setImmediate(boolean) - Method in class services.moleculer.transporter.AmqpTransporter
setInternal(boolean) - Method in class services.moleculer.transporter.AmqpTransporter
setInternalServices(boolean) - Method in class services.moleculer.config.ServiceBrokerConfig
setJsonReader(String) - Method in class services.moleculer.config.ServiceBrokerConfig
setJsonWriter(String) - Method in class services.moleculer.config.ServiceBrokerConfig
setKeepAliveSeconds(short) - Method in class services.moleculer.transporter.MqttTransporter
setLowCpuUsage(int) - Method in class services.moleculer.strategy.CpuUsageStrategyFactory
setMandatory(boolean) - Method in class services.moleculer.transporter.AmqpTransporter
setMaxAckExtensionPeriod(Duration) - Method in class services.moleculer.transporter.GoogleTransporter
setMaxCallLevel(int) - Method in class services.moleculer.context.DefaultContextFactory
setMaxConnections(int) - Method in class services.moleculer.transporter.TcpTransporter
setMaxErrors(int) - Method in class services.moleculer.breaker.CircuitBreaker
setMaxInFlightMessages(int) - Method in class services.moleculer.transporter.MqttTransporter
setMaxPacketSize(int) - Method in class services.moleculer.transporter.TcpTransporter
setMaxParamsLength(int) - Method in class services.moleculer.cacher.DistributedCacher
setMaxPingsOut(int) - Method in class services.moleculer.transporter.NatsTransporter
setMaxSameNodes(int) - Method in class services.moleculer.breaker.CircuitBreaker
setMaxTries(int) - Method in class services.moleculer.breaker.CircuitBreaker
setMaxTries(int) - Method in class services.moleculer.strategy.CpuUsageStrategyFactory
setMaxTries(int) - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
setMessageProperties(AMQP.BasicProperties) - Method in class services.moleculer.transporter.AmqpTransporter
setMessageResendIntervalSeconds(int) - Method in class services.moleculer.transporter.MqttTransporter
setMonitor(Monitor) - Method in class services.moleculer.config.ServiceBrokerConfig
setNamespace(String) - Method in class services.moleculer.config.ServiceBrokerConfig
setNamespace(String) - Method in class services.moleculer.transporter.Transporter
setNodeID(String) - Method in class services.moleculer.config.ServiceBrokerConfig
setOfflineTimeout(int) - Method in class services.moleculer.transporter.Transporter
setParallelPullCount(int) - Method in class services.moleculer.transporter.GoogleTransporter
setPassword(String) - Method in class services.moleculer.cacher.RedisCacher
setPassword(String) - Method in class services.moleculer.transporter.AmqpTransporter
setPassword(String) - Method in class services.moleculer.transporter.JmsTransporter
setPassword(String) - Method in class services.moleculer.transporter.MqttTransporter
setPassword(String) - Method in class services.moleculer.transporter.NatsTransporter
setPassword(String) - Method in class services.moleculer.transporter.RedisTransporter
setPingInterval(long) - Method in class services.moleculer.transporter.NatsTransporter
setPingPeriod(int) - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
setPingTimeout(long) - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
setPort(int) - Method in class services.moleculer.transporter.TcpTransporter
setPreferHostname(boolean) - Method in class services.moleculer.transporter.Transporter
setPreferLocal(boolean) - Method in class services.moleculer.strategy.ArrayBasedStrategyFactory
setPrefix(String) - Method in class services.moleculer.transporter.Transporter
setPrefix(String) - Method in class services.moleculer.uid.IncrementalUidGenerator
setPriority(int) - Method in class services.moleculer.transporter.JmsTransporter
setProducerProperties(Properties) - Method in class services.moleculer.transporter.KafkaTransporter
setProducerProperty(String, String) - Method in class services.moleculer.transporter.KafkaTransporter
setProjectID(String) - Method in class services.moleculer.transporter.GoogleTransporter
setQos(QoS) - Method in class services.moleculer.transporter.MqttTransporter
setQueueProperties(Map<String, Object>) - Method in class services.moleculer.transporter.AmqpTransporter
setRetrySettings(RetrySettings) - Method in class services.moleculer.transporter.GoogleTransporter
setScheduler(ScheduledExecutorService) - Method in class services.moleculer.config.ServiceBrokerConfig
setSecure(boolean) - Method in class services.moleculer.cacher.RedisCacher
setSecure(boolean) - Method in class services.moleculer.transporter.NatsTransporter
setSecure(boolean) - Method in class services.moleculer.transporter.RedisTransporter
setSegmentCount(int) - Method in class services.moleculer.cacher.OHCacher
setSerializer(Serializer) - Method in class services.moleculer.cacher.OHCacher
setSerializer(Serializer) - Method in class services.moleculer.cacher.RedisCacher
setSerializer(Serializer) - Method in class services.moleculer.transporter.Transporter
setServiceInvoker(ServiceInvoker) - Method in class services.moleculer.config.ServiceBrokerConfig
setServiceRegistry(ServiceRegistry) - Method in class services.moleculer.config.ServiceBrokerConfig
setShutDownThreadPools(boolean) - Method in class services.moleculer.config.ServiceBrokerConfig
setSslContext(SSLContext) - Method in class services.moleculer.transporter.NatsTransporter
setSslContextFactory(SslContextFactory) - Method in class services.moleculer.transporter.AmqpTransporter
setStrategyFactory(StrategyFactory) - Method in class services.moleculer.config.ServiceBrokerConfig
setSubscriptionTimeout(int) - Method in class services.moleculer.transporter.Transporter
setTimeout(int) - Method in class services.moleculer.transporter.NatsTransporter
setTlsDebug(boolean) - Method in class services.moleculer.transporter.NatsTransporter
setTopicConnectionFactory(TopicConnectionFactory) - Method in class services.moleculer.transporter.JmsTransporter
setTotalCpuPercent(int) - Method in class services.moleculer.monitor.ConstantMonitor
setTransacted(boolean) - Method in class services.moleculer.transporter.JmsTransporter
setTransportChannelProvider(TransportChannelProvider) - Method in class services.moleculer.transporter.GoogleTransporter
setTransporter(Transporter) - Method in class services.moleculer.config.ServiceBrokerConfig
setTtl(int) - Method in class services.moleculer.cacher.MemoryCacher
setTtl(int) - Method in class services.moleculer.cacher.OHCacher
setTtl(int) - Method in class services.moleculer.cacher.RedisCacher
setTtl(int) - Method in class services.moleculer.transporter.JmsTransporter
setUdpBindAddress(String) - Method in class services.moleculer.transporter.TcpTransporter
setUdpBroadcast(boolean) - Method in class services.moleculer.transporter.TcpTransporter
setUdpMaxDiscovery(int) - Method in class services.moleculer.transporter.TcpTransporter
setUdpMulticast(String) - Method in class services.moleculer.transporter.TcpTransporter
setUdpMulticastTTL(int) - Method in class services.moleculer.transporter.TcpTransporter
setUdpPeriod(int) - Method in class services.moleculer.transporter.TcpTransporter
setUdpPort(int) - Method in class services.moleculer.transporter.TcpTransporter
setUdpReuseAddr(boolean) - Method in class services.moleculer.transporter.TcpTransporter
setUidGenerator(UidGenerator) - Method in class services.moleculer.config.ServiceBrokerConfig
setUrl(String) - Method in class services.moleculer.transporter.AmqpTransporter
setUrl(String) - Method in class services.moleculer.transporter.MqttTransporter
setUrls(String[]) - Method in class services.moleculer.cacher.RedisCacher
setUrls(String[]) - Method in class services.moleculer.transporter.KafkaTransporter
setUrls(String[]) - Method in class services.moleculer.transporter.NatsTransporter
setUrls(String[]) - Method in class services.moleculer.transporter.RedisTransporter
setUrls(String...) - Method in class services.moleculer.transporter.TcpTransporter
setUseHostname(boolean) - Method in class services.moleculer.transporter.TcpTransporter
setUsername(String) - Method in class services.moleculer.transporter.AmqpTransporter
setUsername(String) - Method in class services.moleculer.transporter.JmsTransporter
setUsername(String) - Method in class services.moleculer.transporter.MqttTransporter
setUsername(String) - Method in class services.moleculer.transporter.NatsTransporter
setVerbose(boolean) - Method in class services.moleculer.transporter.NatsTransporter
setWindowLength(long) - Method in class services.moleculer.breaker.CircuitBreaker
SEVERE - Static variable in class services.moleculer.logger.ColoredConsoleLogger
SEVERE - Static variable in class services.moleculer.logger.FastLogFormatter
SEVERE - Static variable in class services.moleculer.logger.SimpleConsoleLogger
shutDownThreadPools - Variable in class services.moleculer.config.ServiceBrokerConfig
sigar - Static variable in class services.moleculer.monitor.SigarMonitor
SigarMonitor - Class in services.moleculer.monitor: Sigar API-based System Monitor.
SigarMonitor() - Constructor for class services.moleculer.monitor.SigarMonitor
SimpleConsoleLogger - Class in services.moleculer.logger: Simple, System.out-based logger.
SimpleConsoleLogger() - Constructor for class services.moleculer.logger.SimpleConsoleLogger
size() - Method in class services.moleculer.util.FastBuildMap.FastBuildEntrySet
size - Variable in class services.moleculer.util.FastBuildMap
size() - Method in class services.moleculer.util.FastBuildMap
SmileSerializer - Class in services.moleculer.serializer: Smile Serializer

Smile is a computer data interchange format based on JSON.
SmileSerializer() - Constructor for class services.moleculer.serializer.SmileSerializer
SOFTWARE_VERSION - Static variable in class services.moleculer.ServiceBroker: Version of the Java ServiceBroker API.
SpringRegistrator - Class in services.moleculer.config: Register Spring Components as Moleculer Services in ServiceBroker.
SpringRegistrator() - Constructor for class services.moleculer.config.SpringRegistrator
sslContext - Variable in class services.moleculer.transporter.NatsTransporter
sslContextFactory - Variable in class services.moleculer.transporter.AmqpTransporter
StandardUidGenerator - Class in services.moleculer.uid: Slower UidGenerator (but it produces standard UUID's).
StandardUidGenerator() - Constructor for class services.moleculer.uid.StandardUidGenerator
start() - Method in class services.moleculer.ServiceBroker: Start broker.
start(TYPE) - Method in class services.moleculer.ServiceBroker: Starts the specified MoleculerComponent.
started(ServiceBroker) - Method in class services.moleculer.breaker.CircuitBreaker
started(ServiceBroker) - Method in class services.moleculer.cacher.JCacheCacher: Initializes cacher instance.
started(ServiceBroker) - Method in class services.moleculer.cacher.MemoryCacher: Initializes cacher instance.
started(ServiceBroker) - Method in class services.moleculer.cacher.OHCacher: Initializes cacher instance.
started(ServiceBroker) - Method in class services.moleculer.cacher.RedisCacher: Initializes cacher instance.
started(ServiceBroker) - Method in class services.moleculer.context.DefaultContextFactory: Initializes Default Context Factory instance.
started(ServiceBroker) - Method in class services.moleculer.eventbus.DefaultEventbus: Initializes default EventBus instance.
started(ServiceBroker) - Method in class services.moleculer.internal.NodeService
started(ServiceBroker) - Method in class services.moleculer.service.DefaultServiceInvoker
started(ServiceBroker) - Method in class services.moleculer.service.DefaultServiceRegistry: Initializes ServiceRegistry instance.
started(ServiceBroker) - Method in class services.moleculer.service.MoleculerComponent
started(ServiceBroker) - Method in class services.moleculer.strategy.CpuUsageStrategyFactory: Initializes strategy instance.
started(ServiceBroker) - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory: Initializes strategy instance.
started - Variable in class services.moleculer.transporter.AmqpTransporter
started(ServiceBroker) - Method in class services.moleculer.transporter.GoogleTransporter
started - Variable in class services.moleculer.transporter.NatsTransporter
started(ServiceBroker) - Method in class services.moleculer.transporter.Transporter: Initializes transporter instance.
started(ServiceBroker) - Method in class services.moleculer.uid.IncrementalUidGenerator: Initializes UID generator instance.
startedAt - Static variable in class services.moleculer.internal.NodeService
startReceivers(NetworkInterface, String, boolean) - Method in class services.moleculer.transporter.tcp.UDPLocator
startTime - Variable in class services.moleculer.context.Context: Context creation time
status - Variable in class services.moleculer.cacher.RedisCacher
status - Variable in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
status - Variable in class services.moleculer.transporter.RedisTransporter
STATUS_CONNECTED - Static variable in class services.moleculer.cacher.RedisCacher
STATUS_CONNECTED - Static variable in class services.moleculer.transporter.RedisTransporter
STATUS_CONNECTING - Static variable in class services.moleculer.cacher.RedisCacher
STATUS_CONNECTING_1 - Static variable in class services.moleculer.transporter.RedisTransporter
STATUS_CONNECTING_2 - Static variable in class services.moleculer.transporter.RedisTransporter
STATUS_DISCONNECTED - Static variable in class services.moleculer.cacher.RedisCacher
STATUS_DISCONNECTED - Static variable in class services.moleculer.transporter.RedisTransporter
STATUS_DISCONNECTING - Static variable in class services.moleculer.cacher.RedisCacher
STATUS_DISCONNECTING - Static variable in class services.moleculer.transporter.RedisTransporter
STATUS_STOPPED - Static variable in class services.moleculer.cacher.RedisCacher
stop() - Method in class services.moleculer.ServiceBroker: Stop broker and all internal components (event bus, context factory, etc.).
stop(MoleculerComponent) - Method in class services.moleculer.ServiceBroker: Stops the specified MoleculerComponent.
stop() - Method in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
stopAllLocalServices() - Method in class services.moleculer.service.DefaultServiceRegistry
stopped() - Method in class services.moleculer.breaker.CircuitBreaker
stopped() - Method in class services.moleculer.cacher.JCacheCacher
stopped() - Method in class services.moleculer.cacher.MemoryCacher
stopped() - Method in class services.moleculer.cacher.OHCacher
stopped() - Method in class services.moleculer.cacher.RedisCacher
stopped() - Method in class services.moleculer.eventbus.DefaultEventbus
stopped() - Method in class services.moleculer.service.DefaultServiceRegistry
stopped() - Method in class services.moleculer.service.MoleculerComponent
stopped() - Method in class services.moleculer.strategy.NetworkLatencyStrategyFactory
stopped() - Method in class services.moleculer.transporter.AmqpTransporter: Closes transporter.
stopped() - Method in class services.moleculer.transporter.GoogleTransporter: Closes transporter.
stopped() - Method in class services.moleculer.transporter.JmsTransporter: Closes transporter.
stopped() - Method in class services.moleculer.transporter.KafkaTransporter: Closes transporter.
stopped() - Method in class services.moleculer.transporter.MqttTransporter: Closes transporter.
stopped() - Method in class services.moleculer.transporter.NatsTransporter: Closes transporter.
stopped() - Method in class services.moleculer.transporter.RedisTransporter: Closes transporter.
stopped() - Method in class services.moleculer.transporter.TcpTransporter: Closes transporter.
stopped() - Method in class services.moleculer.transporter.Transporter: Closes transporter.
STOPPING - Static variable in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
strategies - Variable in class services.moleculer.service.DefaultServiceRegistry
strategy(StrategyFactory) - Method in class services.moleculer.config.ServiceBrokerBuilder
strategy - Variable in class services.moleculer.eventbus.DefaultEventbus
Strategy<T extends Endpoint> - Class in services.moleculer.strategy: Base superclass of all Strategy implementations.
Strategy() - Constructor for class services.moleculer.strategy.Strategy
strategyFactory - Variable in class services.moleculer.config.ServiceBrokerConfig
strategyFactory - Variable in class services.moleculer.service.DefaultServiceRegistry
strategyFactory - Variable in class services.moleculer.ServiceBroker: Default (round-robin) service invocation factory.
StrategyFactory - Class in services.moleculer.strategy: Base class of Invocation Strategies.
StrategyFactory() - Constructor for class services.moleculer.strategy.StrategyFactory
subscribe - Variable in class services.moleculer.eventbus.ListenerEndpoint
Subscribe - Annotation Type in services.moleculer.eventbus: Mask of the subscribed event (eg.
subscribe(String) - Method in class services.moleculer.transporter.AmqpTransporter
subscribe(String) - Method in class services.moleculer.transporter.GoogleTransporter
subscribe(String) - Method in class services.moleculer.transporter.JmsTransporter
subscribe(String) - Method in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
subscribe(String) - Method in class services.moleculer.transporter.KafkaTransporter
subscribe(String) - Method in class services.moleculer.transporter.MqttTransporter
subscribe(String) - Method in class services.moleculer.transporter.NatsTransporter
subscribe(String) - Method in class services.moleculer.transporter.NullTransporter
subscribe(String) - Method in class services.moleculer.transporter.RedisTransporter
subscribe(String) - Method in class services.moleculer.transporter.TcpTransporter
subscribe(String, String) - Method in class services.moleculer.transporter.Transporter
subscribe(String) - Method in class services.moleculer.transporter.Transporter
subscribe(String) - Method in class services.moleculer.util.redis.RedisPubSubClient
SUBSCRIBED - Static variable in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
subscribed(MqttClient, Subscription[], Subscription[], boolean) - Method in class services.moleculer.transporter.MqttTransporter
subscribed(byte[], long) - Method in class services.moleculer.transporter.RedisTransporter
subscribers - Variable in class services.moleculer.transporter.GoogleTransporter
subscribers - Variable in class services.moleculer.transporter.JmsTransporter
subscriptionAdmin - Variable in class services.moleculer.transporter.GoogleTransporter
subscriptions - Variable in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
subscriptions - Variable in class services.moleculer.transporter.MqttTransporter
subscriptionTimeout - Variable in class services.moleculer.transporter.Transporter: Timeout of channel subscriptions (SECONDS).
suggestDependency(String, String, String) - Static method in class services.moleculer.util.CommonUtils

T

TcpReader - Class in services.moleculer.transporter.tcp: Packet receiver Thread of the TCP Transporter.
TcpReader(TcpTransporter) - Constructor for class services.moleculer.transporter.tcp.TcpReader
TcpTransporter - Class in services.moleculer.transporter: TCP Transporter with optional UDP discovery ("zero configuration") module.
TcpTransporter() - Constructor for class services.moleculer.transporter.TcpTransporter: Start TCP Transporter in "zero config" mode, with automatic UDP service discovery.
TcpTransporter(String...) - Constructor for class services.moleculer.transporter.TcpTransporter: Start TCP Transporter in full TCP mode, without UDP discovery.
TcpTransporter(URL) - Constructor for class services.moleculer.transporter.TcpTransporter: Start TCP Transporter in full TCP mode, without UDP discovery.
TcpWriter - Class in services.moleculer.transporter.tcp: Packet sender Thread of the TCP Transporter.
TcpWriter(TcpTransporter) - Constructor for class services.moleculer.transporter.tcp.TcpWriter
tested - Variable in class services.moleculer.breaker.ErrorCounter
throwableToTree(String, Throwable) - Method in class services.moleculer.service.DefaultServiceRegistry
timeout - Variable in class services.moleculer.context.CallOptions.Options: Timeout of the method invocation (in milliseconds, 0 = no timeout)
timeout(long) - Method in class services.moleculer.context.CallOptions.Options
timeout(long) - Static method in class services.moleculer.context.CallOptions
timeout - Variable in class services.moleculer.transporter.NatsTransporter
timeoutAt - Variable in class services.moleculer.service.PendingPromise
timeoutAt - Variable in class services.moleculer.service.ServiceListener
timer - Variable in class services.moleculer.cacher.MemoryCacher: Cancelable timer
timer - Variable in class services.moleculer.transporter.tcp.UDPLocator: Cancelable timer of sender
timestamp - Variable in class services.moleculer.transporter.TcpTransporter: Current node descriptor
timestamps - Variable in class services.moleculer.breaker.ErrorCounter
tlsDebug - Variable in class services.moleculer.transporter.NatsTransporter
topicAdmin - Variable in class services.moleculer.transporter.GoogleTransporter
totalCpuPercent - Variable in class services.moleculer.monitor.ConstantMonitor
transacted - Variable in class services.moleculer.transporter.JmsTransporter
transportChannelProvider - Variable in class services.moleculer.transporter.GoogleTransporter
transporter(Transporter) - Method in class services.moleculer.config.ServiceBrokerBuilder
transporter - Variable in class services.moleculer.config.ServiceBrokerConfig
transporter - Variable in class services.moleculer.eventbus.DefaultEventbus
transporter - Variable in class services.moleculer.eventbus.RemoteListenerEndpoint
transporter - Variable in class services.moleculer.internal.NodeService
transporter - Variable in class services.moleculer.service.DefaultServiceRegistry
transporter - Variable in class services.moleculer.ServiceBroker: Implementation of the Transporter.
transporter - Variable in class services.moleculer.strategy.CpuUsageStrategy
transporter - Variable in class services.moleculer.strategy.CpuUsageStrategyFactory
transporter - Variable in class services.moleculer.strategy.NetworkLatencyStrategyFactory
transporter - Variable in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
transporter - Variable in class services.moleculer.transporter.tcp.TcpReader: Parent transporter
transporter - Variable in class services.moleculer.transporter.tcp.TcpWriter
transporter - Variable in class services.moleculer.transporter.tcp.UDPLocator: Parent transporter
transporter - Variable in class services.moleculer.transporter.tcp.UDPReceiver: Parent transporter
Transporter - Class in services.moleculer.transporter: Base superclass of all Transporter implementations.
Transporter() - Constructor for class services.moleculer.transporter.Transporter
Transporter(Serializer) - Constructor for class services.moleculer.transporter.Transporter
tryToClose() - Method in class services.moleculer.transporter.tcp.SendBuffer: Tries to close this buffer.
ttl - Variable in class services.moleculer.cacher.MemoryCacher: Expire time, in SECONDS (0 = never expires)
ttl - Variable in class services.moleculer.cacher.OHCacher: Expire time, in seconds (0 = never expires)
ttl - Variable in class services.moleculer.cacher.RedisCacher
ttl - Variable in class services.moleculer.transporter.JmsTransporter

U

udpAddress - Variable in class services.moleculer.transporter.tcp.UDPReceiver: IP address
udpBindAddress - Variable in class services.moleculer.transporter.TcpTransporter: UDP bind address (null = autodetect)
udpBroadcast - Variable in class services.moleculer.transporter.TcpTransporter: Use UDP broadcast WITH UDP multicast (false = use UDP multicast only)
UDPBroadcastReceiver - Class in services.moleculer.transporter.tcp
UDPBroadcastReceiver(String, String, TcpTransporter) - Constructor for class services.moleculer.transporter.tcp.UDPBroadcastReceiver
UDPLocator - Class in services.moleculer.transporter.tcp: UDP multicast / broadcast discovery service of the TCP Transporter.
UDPLocator(String, TcpTransporter, ScheduledExecutorService) - Constructor for class services.moleculer.transporter.tcp.UDPLocator
udpMaxDiscovery - Variable in class services.moleculer.transporter.TcpTransporter: Maximum number of outgoing multicast packets (0 = runs forever)
udpMulticast - Variable in class services.moleculer.transporter.TcpTransporter: UDP multicast address of automatic discovery service.
UDPMulticastReceiver - Class in services.moleculer.transporter.tcp
UDPMulticastReceiver(String, String, TcpTransporter) - Constructor for class services.moleculer.transporter.tcp.UDPMulticastReceiver
UDPMulticastReceiver(String, String, TcpTransporter, NetworkInterface) - Constructor for class services.moleculer.transporter.tcp.UDPMulticastReceiver
udpMulticastTTL - Variable in class services.moleculer.transporter.tcp.UDPReceiver: UDP multicast TTL
udpMulticastTTL - Variable in class services.moleculer.transporter.TcpTransporter: TTL of UDP multicast packets
udpPacketReceived(String, String, int) - Method in class services.moleculer.transporter.TcpTransporter
udpPeriod - Variable in class services.moleculer.transporter.TcpTransporter: UDP broadcast/multicast period in SECONDS
udpPort - Variable in class services.moleculer.transporter.tcp.UDPReceiver: UDP broadcast/multicast port
udpPort - Variable in class services.moleculer.transporter.TcpTransporter: UDP broadcast/multicast port
UDPReceiver - Class in services.moleculer.transporter.tcp
UDPReceiver(String, String, TcpTransporter) - Constructor for class services.moleculer.transporter.tcp.UDPReceiver
udpReuseAddr - Variable in class services.moleculer.transporter.tcp.UDPReceiver: Resuse addresses
udpReuseAddr - Variable in class services.moleculer.transporter.TcpTransporter: Resuse addresses
uid(UidGenerator) - Method in class services.moleculer.config.ServiceBrokerBuilder
uid - Variable in class services.moleculer.context.DefaultContextFactory
uid - Variable in class services.moleculer.service.DefaultServiceRegistry
uid - Variable in class services.moleculer.transporter.Transporter
uidGenerator - Variable in class services.moleculer.config.ServiceBrokerConfig
uidGenerator - Variable in class services.moleculer.ServiceBroker: UID generator (each Context instance has its own identifier).
UidGenerator - Class in services.moleculer.uid: Base superclass of all UID Generator implementations.
UidGenerator() - Constructor for class services.moleculer.uid.UidGenerator
unableToConnect(Exception) - Method in class services.moleculer.transporter.RedisTransporter
unableToSend(String, LinkedList<byte[]>, Throwable) - Method in class services.moleculer.transporter.TcpTransporter
UNSUBSCRIBED - Static variable in class services.moleculer.transporter.KafkaTransporter.KafkaPoller
unsubscribed(MqttClient, String[]) - Method in class services.moleculer.transporter.MqttTransporter
unsubscribed(byte[], long) - Method in class services.moleculer.transporter.RedisTransporter
updateCpu(int) - Method in class services.moleculer.transporter.tcp.NodeDescriptor
updateCpu(long, int) - Method in class services.moleculer.transporter.tcp.NodeDescriptor
updateNodeInfo(String, Tree) - Method in class services.moleculer.transporter.Transporter
url - Variable in class services.moleculer.transporter.AmqpTransporter
url - Variable in class services.moleculer.transporter.MqttTransporter
urls - Variable in class services.moleculer.cacher.RedisCacher
urls - Variable in class services.moleculer.transporter.KafkaTransporter
urls - Variable in class services.moleculer.transporter.NatsTransporter
urls - Variable in class services.moleculer.transporter.RedisTransporter
urls - Variable in class services.moleculer.transporter.TcpTransporter: List of URLs ("tcp://host:port/nodeID" or "host:port/nodeID" or "host/nodeID"), when UDP discovery is disabled.
use(Middleware) - Method in class services.moleculer.service.ActionEndpoint
use(Collection<Middleware>) - Method in class services.moleculer.service.DefaultServiceRegistry
use(Collection<Middleware>) - Method in class services.moleculer.service.ServiceRegistry
use(Collection<Middleware>) - Method in class services.moleculer.ServiceBroker: Installs a collection of middlewares.
use(Middleware...) - Method in class services.moleculer.ServiceBroker: Installs one or an array of middleware(s).
useHostname - Variable in class services.moleculer.transporter.tcp.UDPReceiver: Use hostnames instead of IP addresses As the DHCP environment is dynamic, any later attempt to use IPs instead hostnames would most likely yield false results.
useHostname - Variable in class services.moleculer.transporter.TcpTransporter: Use hostnames instead of IP addresses As the DHCP environment is dynamic, any later attempt to use IPs instead hostnames would most likely yield false results.
username - Variable in class services.moleculer.transporter.AmqpTransporter
username - Variable in class services.moleculer.transporter.JmsTransporter
username - Variable in class services.moleculer.transporter.MqttTransporter
username - Variable in class services.moleculer.transporter.NatsTransporter

V

value - Variable in class services.moleculer.cacher.MemoryCacher.PartitionEntry
values - Variable in class services.moleculer.util.FastBuildMap
values() - Method in class services.moleculer.util.FastBuildMap
valueToBytes(Tree) - Method in class services.moleculer.cacher.OHCacher
verbose - Variable in class services.moleculer.transporter.NatsTransporter
Version - Annotation Type in services.moleculer.service: Optional version of a Moleculer Service.

W

waitForServices(long, Collection<String>) - Method in class services.moleculer.service.DefaultServiceRegistry
waitForServices(long, Collection<String>) - Method in class services.moleculer.service.ServiceRegistry
waitForServices(String...) - Method in class services.moleculer.ServiceBroker: Waits for one or more services.
waitForServices(long, String...) - Method in class services.moleculer.ServiceBroker: Waits for one (or an array of) service(s).
waitForServices(long, Collection<String>) - Method in class services.moleculer.ServiceBroker: Waits for a collection of services.
WARNING - Static variable in class services.moleculer.logger.ColoredConsoleLogger
WARNING - Static variable in class services.moleculer.logger.FastLogFormatter
WARNING - Static variable in class services.moleculer.logger.SimpleConsoleLogger
windowLength - Variable in class services.moleculer.breaker.CircuitBreaker: Length of time-window in MILLISECONDS
windowLength - Variable in class services.moleculer.breaker.ErrorCounter
write(Tree) - Method in class services.moleculer.serializer.Serializer
write() - Method in class services.moleculer.transporter.tcp.SendBuffer: Writes N bytes to the target channel.
writeLines(LinkedList<LogRecord>, StringBuilder, Formatter) - Method in class services.moleculer.logger.AsyncFileLogger
writeLock - Variable in class services.moleculer.breaker.ErrorCounter
writeLock - Variable in class services.moleculer.cacher.JCacheCacher
writeLock - Variable in class services.moleculer.cacher.MemoryCacher
writeLock - Variable in class services.moleculer.eventbus.DefaultEventbus: Writer lock of the Event Bus
writeLock - Variable in class services.moleculer.service.DefaultServiceRegistry: Writer lock of configuration
writeLock - Variable in class services.moleculer.transporter.tcp.NodeDescriptor
writer(String) - Method in class services.moleculer.config.ServiceBrokerBuilder
writer - Variable in class services.moleculer.serializer.Serializer
writer - Variable in class services.moleculer.transporter.TcpTransporter: Socket writer
writerLock - Variable in class services.moleculer.cacher.MemoryCacher.MemoryPartition

X

XorShiftRandomStrategy<T extends Endpoint> - Class in services.moleculer.strategy: Fast XORSHIFT-based pseudorandom invocation strategy.
XorShiftRandomStrategy(ServiceBroker, boolean) - Constructor for class services.moleculer.strategy.XorShiftRandomStrategy
XorShiftRandomStrategyFactory - Class in services.moleculer.strategy: Factory of XORSHIFT-based pseudorandom invocation strategy.
XorShiftRandomStrategyFactory() - Constructor for class services.moleculer.strategy.XorShiftRandomStrategyFactory
XorShiftRandomStrategyFactory(boolean) - Constructor for class services.moleculer.strategy.XorShiftRandomStrategyFactory

A B C D E F G H I J K L M N O P Q R S T U V W X