Modifier and Type | Field and Description |
---|---|
static Node |
Node.NOT_CLUSTERED
Special node that is used when JIRA is not configured for clustering.
|
Modifier and Type | Method and Description |
---|---|
Node |
OfBizClusterNodeStore.createNode(String nodeId,
Node.NodeState state,
String ip,
Long cacheListenerPort,
Long nodeBuildNumber,
String nodeVersion)
Creates the node in the underlying database.
|
Node |
ClusterNodes.current()
Returns the current cluster node in JIRA.
|
Node |
DefaultClusterNodes.current() |
Node |
NodeChangedEvent.getNewState() |
Node |
NodeStateManager.getNode()
Deprecated.
since 7.0.6 Use
ClusterNodes.current() instead. |
Node |
NodeJoinedClusterEvent.getNode() |
Node |
DefaultNodeStateManager.getNode() |
Node |
NodeRemovedFromClusterEvent.getNode() |
Node |
OfBizClusterNodeStore.getNode(String nodeId) |
Node |
NodeStateManager.getNodeWithRefresh()
Deprecated.
since 7.0.6 Use
ClusterNodes.reset() followed by ClusterNodes.current() instead. |
Node |
DefaultNodeStateManager.getNodeWithRefresh() |
Node |
NodeChangedEvent.getOldState() |
Node |
ClusterNodes.node(String nodeId) |
Node |
DefaultClusterNodes.node(String nodeId) |
Node |
OfBizClusterNodeStore.updateNode(String nodeId,
Node.NodeState state,
String ip,
Long cacheListenerPort,
Long nodeBuildNumber,
String nodeVersion)
Stores the node in the underlying database.
|
Modifier and Type | Method and Description |
---|---|
Set<Node> |
ClusterNodes.all()
Returns all the known nodes in a JIRA cluster.
|
Set<Node> |
DefaultClusterNodes.all() |
Collection<Node> |
ClusterManager.findLiveNodes()
Returns a snapshot of the live nodes.
|
Collection<Node> |
DefaultClusterManager.findLiveNodes() |
List<Node> |
OfBizClusterNodeStore.findNodes(org.ofbiz.core.entity.EntityCondition condition,
List<String> orderBy) |
Set<Node> |
NodeStateManager.getAllNodes()
Deprecated.
since 7.0.6 Use
ClusterNodes.all() instead. |
Set<Node> |
ClusterManager.getAllNodes()
Returns all the nodes in the cluster.
|
Set<Node> |
DefaultClusterManager.getAllNodes() |
Set<Node> |
DefaultNodeStateManager.getAllNodes() |
List<Node> |
OfBizClusterNodeStore.getAllNodes() |
Modifier and Type | Method and Description |
---|---|
int |
OfBizClusterNodeStore.deleteNode(Node node)
Deletes the node from the underlying database.
|
List<ClusterMessage> |
OfBizClusterMessageStore.getMessages(Node sourceNode,
Node destinationNode,
Long afterMessageId)
Retrieves the messages destined for the given node, from a source node.
|
protected boolean |
DefaultClusterNodes.stateHasChanged(Node node)
We validate if the state of the node has changed.
|
protected boolean |
DefaultNodeStateManager.stateHasChanged(Node node)
We validate if the state of the node has changed.
|
Constructor and Description |
---|
CuttingOffExecutorImpl(java.time.Clock clock,
Node node,
com.atlassian.event.api.EventPublisher eventPublisher,
ClusterManager clusterManager) |
NodeChangedEvent(Node oldState,
Node newState) |
NodeJoinedClusterEvent(Node node) |
NodeRemovedFromClusterEvent(Node node) |
Modifier and Type | Method and Description |
---|---|
CuttingOffExecutor |
NodeCutOffManager.getCutOffExecutorForNode(Node node)
Gets cutting off executor for node
|
Modifier and Type | Method and Description |
---|---|
void |
NodeCutOffManager.removeStaleCutOffExecutors(Collection<Node> liveNodes)
It should be called each time the list of live nodes changes.
|
Modifier and Type | Method and Description |
---|---|
protected net.sf.ehcache.distribution.CachePeer |
JiraCacheManagerPeerProvider.lookupRemoteCachePeer(Node node,
String cacheName) |
Modifier and Type | Method and Description |
---|---|
LocalQCacheOpQueue |
LocalQCacheOpQueueFactory.create(Node node,
int nodeQueueNumber) |
void |
LocalQCacheOpSender.send(Node node,
LocalQCacheOp localQCacheOp)
If any
RuntimeException or LocalQCacheOpSender.UnrecoverableFailure is thrown LocalQCacheOp may never be send. |
Modifier and Type | Method and Description |
---|---|
net.sf.ehcache.distribution.CachePeer |
BasicRMICachePeerProvider.create(Node node,
String cacheName) |
net.sf.ehcache.distribution.CachePeer |
RMICachePeerProvider.create(Node node,
String cacheName)
Creates
CachePeer for given Node and cacheName. |
void |
LocalQCacheOpRMISender.send(Node node,
LocalQCacheOp localQCacheOp) |
void |
RMICachePeerManager.withCachePeer(Node node,
String cacheName,
RMICachePeerManager.CachePeerCallable cachePeerCallable)
Provides access to a
CachePeer inside RMICachePeerManager.CachePeerCallable for a given Node and cacheName. |
void |
CachingRMICachePeerManager.withCachePeer(Node node,
String cacheName,
RMICachePeerManager.CachePeerCallable cachePeerCallable) |
Modifier and Type | Method and Description |
---|---|
static TapeLocalQCacheOpQueue |
TapeLocalQCacheOpQueue.create(File localDirectoryForQueues,
Node node,
int nodeQueueNumber) |
Modifier and Type | Method and Description |
---|---|
NodeBuildInfo |
DefaultNodeBuildInfoFactory.create(Node node) |
NodeBuildInfo |
NodeBuildInfoFactory.create(Node node) |
Modifier and Type | Method and Description |
---|---|
Map<Node,Boolean> |
ExtendedSystemInfoUtils.getClusterNodeInformation() |
Map<Node,Boolean> |
ExtendedSystemInfoUtilsImpl.getClusterNodeInformation() |
Modifier and Type | Method and Description |
---|---|
Collection<Node> |
IndexAdminImpl.getNodeList() |
Copyright © 2002-2021 Atlassian. All Rights Reserved.