Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.cs |
This package contains all client-server related interfaces and classes
|
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.protocols.relay | |
org.jgroups.protocols.rules | |
org.jgroups.protocols.tom | |
org.jgroups.stack |
Support for managing protocol stacks.
|
Modifier and Type | Method and Description |
---|---|
void |
JChannel.close() |
void |
JChannel.connect(java.lang.String cluster_name) |
protected void |
JChannel.connect(java.lang.String cluster_name,
boolean useFlushIfPresent)
Connects the channel to a group.
|
void |
JChannel.disconnect() |
java.util.Map<java.lang.String,java.lang.Object> |
JChannel.dumpStats() |
java.util.Map<java.lang.String,java.lang.Object> |
JChannel.dumpStats(java.lang.String protocol_name) |
java.lang.String |
JChannel.dumpTimerQueue() |
java.lang.String |
JChannel.printProtocolSpec(boolean include_properties)
Returns a pretty-printed form of all the protocols.
|
void |
JChannel.resetStats() |
java.lang.String |
JChannel.toString(boolean details) |
Modifier and Type | Method and Description |
---|---|
void |
ReplCache.clear()
Removes all keys and values in the L2 and L1 caches
|
void |
Cache.disableReaping() |
java.lang.String |
ReplCache.dump() |
java.lang.String |
PartitionedHashMap.dump() |
void |
Cache.enableReaping(long interval)
Runs the reaper every interval ms, evicts expired items
|
V |
ReplCache.get(K key)
Returns the value associated with key
|
V |
Cache.get(K key) |
V |
PartitionedHashMap.get(K key) |
void |
ReplCache.put(K key,
V val) |
void |
PartitionedHashMap.put(K key,
V val) |
V |
Cache.put(K key,
V val,
long caching_time) |
void |
PartitionedHashMap.put(K key,
V val,
long caching_time)
Adds a key/value to the cache, replacing a previous item if there was one
|
void |
ReplCache.put(K key,
V val,
short repl_count,
long timeout)
Places a key/value pair into one or several nodes in the cluster.
|
void |
ReplCache.put(K key,
V val,
short repl_count,
long timeout,
boolean synchronous)
Places a key/value pair into one or several nodes in the cluster.
|
void |
ReplCache.remove(K key)
Removes key in all nodes in the cluster, both from their local hashmaps and L1 caches
|
void |
PartitionedHashMap.remove(K key) |
void |
ReplCache.remove(K key,
boolean synchronous)
Removes key in all nodes in the cluster, both from their local hashmaps and L1 caches
|
void |
MemcachedConnector.start() |
void |
ReplCache.start() |
void |
Cache.start() |
void |
PartitionedHashMap.start() |
void |
MemcachedConnector.stop() |
void |
ReplCache.stop() |
void |
Cache.stop() |
void |
PartitionedHashMap.stop() |
java.lang.String |
Cache.toString() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
NioBaseServer.printBuffers()
Prints send and receive buffers for all connections
|
java.lang.String |
BaseServer.printConnections() |
void |
NioServer.start() |
void |
NioServer.stop() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
JmxDemo.sayName() |
Modifier and Type | Method and Description |
---|---|
void |
TCPGOSSIP.addInitialHost(java.lang.String hostname,
int port) |
void |
Discovery.addToCache(java.lang.String filename) |
void |
TP.bundler(java.lang.String type) |
void |
MERGE3.checkInconsistencies() |
void |
FRAG2.clearAllFragments() |
void |
TCP_NIO2.clearConnections() |
void |
TCP.clearConnections() |
void |
TP.clearDifferentClusterCache() |
void |
TP.clearDifferentVersionCache() |
void |
UDP.clearDroppedMessagesCache() |
void |
TCPPING.clearDynamicHostList() |
void |
FRAG2.clearFragmentsFor(Address mbr) |
void |
TP.clearLogicalAddressCache()
Clears the cache.
|
void |
MERGE3.clearViews() |
void |
UNICAST3.closeIdleConnections() |
void |
TP.disableDiagnostics() |
void |
Discovery.dumpCache(java.lang.String output_filename) |
java.lang.String |
COUNTER.dumpPendingRequests() |
static java.lang.String |
SHARED_LOOPBACK.dumpRoutingTable() |
java.lang.String |
SCOPE.dumpScopes()
Deprecated.
|
java.util.Map<java.lang.String,java.lang.Object> |
SEQUENCER2.dumpStats() |
java.util.Map<java.lang.String,java.lang.Object> |
SEQUENCER.dumpStats() |
java.lang.String |
TP.dumpTimerTasks() |
java.lang.String |
MERGE3.dumpViews() |
void |
TP.enableDiagnostics() |
void |
TP.evictLogicalAddressCache() |
void |
SCOPE.expire(short scope)
Deprecated.
Multicasts an EXPIRE message to all members, and - on reception - each member removes the scope locally
|
java.lang.String |
MERGE2.fetchAllViews()
Deprecated.
|
java.lang.String |
Discovery.findInitialMembersAsString() |
boolean |
FD_HOST.isAlive(java.lang.String host) |
void |
BARRIER.openBarrier() |
java.lang.String |
TUNNEL.print() |
java.lang.String |
TCPGOSSIP.print() |
java.lang.String |
UNICAST.printAgeOutCache()
Deprecated.
|
java.lang.String |
UNICAST3.printAgeOutCache() |
java.lang.String |
UNICAST2.printAgeOutCache()
Deprecated.
|
java.lang.String |
TCP_NIO2.printBuffers() |
java.lang.String |
PDC.printCache() |
java.lang.String |
FD_SOCK.printCache() |
java.lang.String |
UNICAST.printConnections()
Deprecated.
|
java.lang.String |
TCP_NIO2.printConnections() |
java.lang.String |
UNICAST3.printConnections() |
java.lang.String |
UNICAST2.printConnections()
Deprecated.
|
java.lang.String |
TCP.printConnections() |
java.lang.String |
COUNTER.printCounters() |
java.lang.String |
FC.printCreditors()
Deprecated.
|
java.lang.String |
MFC.printCredits() |
java.lang.String |
FC.printCredits()
Deprecated.
|
java.lang.String |
UFC.printCredits() |
java.lang.String |
FD_HOST.printHosts() |
protected java.lang.String |
BARRIER.printInFlightThreads() |
java.lang.String |
Locking.printLocks() |
java.lang.String |
TP.printLogicalAddressCache() |
java.lang.String |
FC.printReceiverCredits()
Deprecated.
|
java.lang.String |
FlowControl.printReceiverCredits() |
java.lang.String |
UNICAST.printReceiveWindowMessages()
Deprecated.
|
java.lang.String |
UNICAST3.printReceiveWindowMessages() |
java.lang.String |
UNICAST2.printReceiveWindowMessages()
Deprecated.
|
java.lang.String |
TUNNEL.printReconnectList() |
java.lang.String |
TCPGOSSIP.printReconnectList() |
java.lang.String |
MFC.printSenderCredits() |
java.lang.String |
FC.printSenderCredits()
Deprecated.
|
java.lang.String |
UFC.printSenderCredits() |
java.lang.String |
UNICAST.printSendWindowMessages()
Deprecated.
|
java.lang.String |
UNICAST3.printSendWindowMessages() |
java.lang.String |
UNICAST2.printSendWindowMessages()
Deprecated.
|
java.lang.String |
Locking.printServerLocks() |
java.lang.String |
SEQUENCER2.printStats() |
java.lang.String |
SEQUENCER.printStats() |
java.lang.String |
TUNNEL.printStubs() |
java.lang.String |
TCPGOSSIP.printStubs() |
java.lang.String |
FD_SOCK.printSuspectHistory() |
java.lang.String |
FD.printSuspectHistory() |
java.lang.String |
FD_ALL.printSuspectHistory() |
java.lang.String |
FD_ALL2.printSuspectHistory() |
java.lang.String |
FD_HOST.printSuspectHistory() |
java.lang.String |
FD_ALL.printTimestamps() |
java.lang.String |
FD_ALL2.printTimestamps() |
java.lang.String |
FD_HOST.printTimestamps() |
java.lang.String |
TP.printWhoHasCache() |
void |
UNICAST.reapIdleConnections()
Deprecated.
|
void |
UNICAST2.reapIdleConnections()
Deprecated.
|
void |
UNICAST.removeAllConnections()
Deprecated.
This method is public only so it can be invoked by unit testing, but should not otherwise be used !
|
void |
UNICAST3.removeAllConnections()
This method is public only so it can be invoked by unit testing, but should not otherwise be used !
|
void |
UNICAST2.removeAllConnections()
Deprecated.
This method is public only so it can be invoked by unit testing, but should not otherwise be used !
|
void |
SCOPE.removeAllQueues()
Deprecated.
|
int |
UNICAST3.removeExpiredConnections() |
boolean |
TCPGOSSIP.removeInitialHost(java.lang.String hostname,
int port) |
void |
SEQUENCER2.resetStats() |
void |
SEQUENCER.resetStats() |
void |
Discovery.sendCacheInformation() |
void |
MERGE3.sendInfo() |
void |
ASYM_ENCRYPT.sendKeyRequest() |
void |
MERGE2.sendMergeSolicitation()
Deprecated.
Discovers members and detects whether we have multiple coordinator.
|
void |
UNICAST3.sendPendingAcks() |
void |
UNICAST2.sendStableMessages()
Deprecated.
|
void |
Discovery.setForceSendingDiscoveryRsps(boolean flag) |
void |
RELAY.setRelay(boolean relay) |
java.lang.String |
FC.showLastBlockingTimes()
Deprecated.
|
void |
FD.startFailureDetection() |
void |
FD_ALL.startFailureDetection() |
void |
FD_ALL2.startFailureDetection() |
void |
DISCARD.startGui() |
void |
MERGE2.startMergeTask()
Deprecated.
|
boolean |
FD_SOCK.startNodeCrashMonitor() |
void |
FD.stopFailureDetection() |
void |
FD_ALL.stopFailureDetection() |
void |
FD_ALL2.stopFailureDetection() |
void |
DISCARD.stopGui() |
void |
MERGE2.stopMergeTask()
Deprecated.
|
void |
UNICAST3.triggerXmit() |
void |
UNICAST2.triggerXmit()
Deprecated.
|
void |
MFC.unblock()
Allows to unblock a blocked sender from an external program, e.g.
|
void |
FC.unblock()
Deprecated.
Allows to unblock a blocked sender from an external program, e.g.
|
void |
FlowControl.unblock()
Allows to unblock all blocked senders from an external program, e.g.
|
void |
Locking.unlockAll() |
void |
Discovery.weedOutCompletedDiscoveryResponses()
Removes responses which are done or whose timeout has expired (in the latter case, an expired response is marked as done)
|
void |
JDBC_PING.writeInfo() |
void |
FILE_PING.writeInfo() |
Modifier and Type | Method and Description |
---|---|
void |
GMS.cancelMerge() |
void |
NAKACK.clearNonMemberCache()
Deprecated.
|
void |
NAKACK2.clearNonMemberCache() |
void |
StreamingStateTransfer.closeBarrierAndSuspendStable() |
void |
STATE_TRANSFER.closeBarrierAndSuspendStable() |
void |
NAKACK.compact()
Deprecated.
|
void |
NAKACK2.compact() |
java.lang.String |
GMS.dumpViewHandlerHistory() |
java.lang.String |
GMS.dumpViewHandlerQueue() |
java.lang.String |
NAKACK2.dumpXmitTablesNumCurrentRows() |
void |
GMS.fixDigests() |
void |
STABLE.gc() |
void |
StreamingStateTransfer.openBarrierAndResumeStable() |
void |
STATE_TRANSFER.openBarrierAndResumeStable() |
java.lang.String |
NAKACK.printDigestHistory()
Deprecated.
|
java.lang.String |
NAKACK2.printDigestHistory() |
java.lang.String |
NAKACK.printLossRates()
Deprecated.
|
java.lang.String |
GMS.printMergeIdHistory() |
java.lang.String |
NAKACK.printMessages()
Deprecated.
|
java.lang.String |
NAKACK2.printMessages() |
java.lang.String |
GMS.printPreviousMembers() |
java.lang.String |
GMS.printPreviousViews() |
java.lang.String |
NAKACK.printRetransmitStats()
Deprecated.
|
java.lang.String |
NAKACK.printRetransmitTableSizes()
Deprecated.
|
java.lang.String |
NAKACK.printStabilityMessages()
Deprecated.
|
java.lang.String |
NAKACK2.printStabilityMessages() |
void |
NAKACK2.resetStats() |
void |
GMS.resumeViewHandler() |
boolean |
FLUSH.setBypass(boolean flag) |
void |
FLUSH.startFlush() |
void |
FLUSH.stopFlush() |
void |
GMS.suspect(java.lang.String suspected_member) |
void |
GMS.suspendViewHandler() |
void |
NAKACK2.triggerXmit() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
RELAY2.printRoutes() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
SUPERVISOR.dumpRules() |
java.lang.String |
SUPERVISOR.executions() |
void |
SUPERVISOR.installRule(long interval,
java.lang.String classname) |
void |
SUPERVISOR.installRule(java.lang.String name,
long interval,
java.lang.String classname) |
void |
SUPERVISOR.uninstallRule(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
TOA.getMessageList() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
GossipRouter.dumpAddresssMappings() |
java.lang.String |
GossipRouter.dumpRoutingTable() |
void |
Protocol.resetStatistics() |
void |
GossipRouter.start()
Lifecycle operation.
|
void |
GossipRouter.stop()
Always called before destroy().
|
Copyright © 1998-2020 Red Hat. All Rights Reserved.