Package | Description |
---|---|
org.openhubframework.openhub.admin.web.cluster.node.rpc | |
org.openhubframework.openhub.api.entity |
Main (business) entities.
|
org.openhubframework.openhub.core.common.dao |
DAO classes.
|
org.openhubframework.openhub.core.node |
Classes for cluster operation functionality.
|
org.openhubframework.openhub.spi.node |
Classes for cluster operation functionality.
|
Modifier and Type | Method and Description |
---|---|
NodeRpc |
NodeRpc.NodeRpcConverter.convert(Node expr) |
void |
NodeRpc.preSaveValidation(org.springframework.validation.BindingResult errors,
Node updateEntity)
Validates RPC (mandatory attributes, correct object state etc.).
|
protected void |
NodeRpc.updateAttributes(Node param,
boolean created) |
protected void |
NodeRpc.validate(org.springframework.validation.BindingResult errors,
Node updateEntity) |
Constructor and Description |
---|
NodeRpc(Node entity)
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractNode
Abstract node with base methods for get
NodeState information. |
class |
MutableNode
Contains information about one node in cluster.
|
Modifier and Type | Method and Description |
---|---|
Node |
NodeDaoJpaImpl.findNodeByCode(String code) |
Node |
NodeDao.findNodeByCode(String code)
Find node by
MutableNode.getCode() . |
Node |
NodeDaoJpaImpl.findNodeById(Long nodeId) |
Node |
NodeDao.findNodeById(Long nodeId)
Finds node by identifier.
|
Node |
NodeDaoJpaImpl.getNodeById(Long nodeId) |
Node |
NodeDao.getNodeById(Long nodeId)
Gets node by identifier.
|
Node |
NodeDaoJpaImpl.insert(Node node) |
Node |
NodeDao.insert(Node node)
Insert new
MutableNode . |
Node |
NodeDaoJpaImpl.update(Node node,
ChangeNodeCallback changeNodeCallback) |
Node |
NodeDao.update(Node node,
ChangeNodeCallback changeNodeCallback)
Update existing
MutableNode . |
Modifier and Type | Method and Description |
---|---|
List<Node> |
NodeDaoJpaImpl.getAllNodes() |
List<Node> |
NodeDao.getAllNodes()
Get all
MutableNode s. |
Modifier and Type | Method and Description |
---|---|
void |
NodeDaoJpaImpl.delete(Node node) |
void |
NodeDao.delete(Node node)
Delete existing
MutableNode . |
Node |
NodeDaoJpaImpl.insert(Node node) |
Node |
NodeDao.insert(Node node)
Insert new
MutableNode . |
Node |
NodeDaoJpaImpl.update(Node node,
ChangeNodeCallback changeNodeCallback) |
Node |
NodeDao.update(Node node,
ChangeNodeCallback changeNodeCallback)
Update existing
MutableNode . |
boolean |
MessageDaoJpaImpl.updateMessageInQueueUnderLock(Message msg,
Node processingNode) |
boolean |
MessageDao.updateMessageInQueueUnderLock(Message msg,
Node processingNode)
Updates
Message into state MsgStateEnum.IN_QUEUE (set start timestamp in queue)
- gets lock for message. |
boolean |
MessageDaoJpaImpl.updateMessageProcessingUnderLock(Message msg,
Node processingNode) |
boolean |
MessageDao.updateMessageProcessingUnderLock(Message msg,
Node processingNode)
Updates
Message into state MsgStateEnum.PROCESSING (set start timestamp of processing)
- gets lock for message. |
Modifier and Type | Method and Description |
---|---|
Node |
NodeServiceImpl.getActualNode() |
Node |
NodeServiceImpl.getNodeById(Long nodeId) |
Node |
NodeServiceImpl.insert(Node node) |
Node |
NodeServiceImpl.update(Node node,
ChangeNodeCallback changeNodeCallback) |
Modifier and Type | Method and Description |
---|---|
List<Node> |
NodeServiceImpl.getAllNodes() |
Modifier and Type | Method and Description |
---|---|
void |
NodeServiceImpl.delete(Node node) |
Node |
NodeServiceImpl.insert(Node node) |
Node |
NodeServiceImpl.update(Node node,
ChangeNodeCallback changeNodeCallback) |
Modifier and Type | Method and Description |
---|---|
Node |
NodeService.getActualNode()
Get actual node for this application server instance.
|
Node |
NodeService.getNodeById(Long nodeId)
Gets node by identifier.
|
Node |
NodeService.insert(Node node)
Insert new
Node . |
Node |
NodeService.update(Node node,
ChangeNodeCallback changeNodeCallback)
Update existing
Node . |
Modifier and Type | Method and Description |
---|---|
List<Node> |
NodeService.getAllNodes()
Get all
Node s. |
Modifier and Type | Method and Description |
---|---|
void |
NodeService.delete(Node node)
Delete existing
Node . |
Node |
NodeService.insert(Node node)
Insert new
Node . |
Node |
NodeService.update(Node node,
ChangeNodeCallback changeNodeCallback)
Update existing
Node . |
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.