Package org.jumpmind.symmetric.service

Interface INodeService

All Known Implementing Classes:
MockNodeService, NodeService
public interface INodeService
This service provides an API to access Nodes and Node related information.

  • Method Details

    • findNode

      Node findNode(String nodeId)

    • findNode

      Node findNode(String id, boolean useCache)

    • findNodeInCacheOnly

      Node findNodeInCacheOnly(String id)

    • getExternalId

      String getExternalId(String nodeId)

    • findNodeHosts

      List<NodeHost> findNodeHosts(String nodeId)

    • isRegistrationServer

      boolean isRegistrationServer()

    • findNodeByExternalId

      Node findNodeByExternalId(String nodeGroupId, String externalId)

    • findNodesThatOriginatedFromNodeId

      Set<Node> findNodesThatOriginatedFromNodeId(String originalNodeId)
      Find a list of Nodes that were create at the passed in node or were created at a node that was created by the passed in node (recursively).

    • findNodesThatOriginatedFromNodeId

      Set<Node> findNodesThatOriginatedFromNodeId(String originalNodeId, boolean recursive)

    • findEnabledNodesFromNodeGroup

      Collection<Node> findEnabledNodesFromNodeGroup(String nodeGroupId)

    • getEnabledNodesFromDatabase

      Collection<Node> getEnabledNodesFromDatabase()

    • findNodesWithOpenRegistration

      Collection<Node> findNodesWithOpenRegistration()

    • findAllNodeSecurity

      Map<String,NodeSecurity> findAllNodeSecurity(boolean useCache)

    • findNodeSecurityWithLoadEnabled

      List<NodeSecurity> findNodeSecurityWithLoadEnabled()

    • findAllExternalIds

      List<String> findAllExternalIds()

    • findNodeSecurity

      NodeSecurity findNodeSecurity(String nodeId)

    • findNodeSecurity

      NodeSecurity findNodeSecurity(String nodeId, boolean useCache)

    • findOrCreateNodeSecurity

      NodeSecurity findOrCreateNodeSecurity(String nodeId)

    • deleteNodeHost

      void deleteNodeHost(String nodeId)

    • deleteNodeHostInstance

      void deleteNodeHostInstance(String nodeId, String instanceId)

    • deleteNodeSecurity

      void deleteNodeSecurity(String nodeId)

    • deleteNode

      void deleteNode(String nodeId, boolean syncChange)

    • deleteNode

      void deleteNode(String myNodeId, String targetNodeIId, boolean syncChange)

    • findSymmetricVersion

      String findSymmetricVersion()

    • findIdentityNodeId

      String findIdentityNodeId()

    • ignoreNodeChannelForExternalId

      void ignoreNodeChannelForExternalId(boolean ignore, String channelId, String nodeGroupId, String externalId)

    • isNodeAuthorized

      boolean isNodeAuthorized(String nodeId, String password)

    • flushNodeCache

      void flushNodeCache()

    • flushNodeAuthorizedCache

      void flushNodeAuthorizedCache()

    • flushNodeGroupCache

      void flushNodeGroupCache()

    • isRegistrationEnabled

      boolean isRegistrationEnabled(String nodeId)

    • findIdentity

      Node findIdentity()

    • findIdentity

      Node findIdentity(boolean useCache)

    • findIdentity

      Node findIdentity(boolean useCache, boolean logSqlError)

    • getCachedIdentity

      Node getCachedIdentity()

    • deleteIdentity

      boolean deleteIdentity()

    • findAllNodes

      List<Node> findAllNodes()

    • findAllNodes

      List<Node> findAllNodes(boolean useCache)

    • findAllNodesAsMap

      Map<String,Node> findAllNodesAsMap()

    • findFilteredNodesWithLimit

      List<Node> findFilteredNodesWithLimit(int offset, int limit, List<FilterCriterion> filter, String orderColumn, String orderDirection)

    • countFilteredNodes

      int countFilteredNodes(List<FilterCriterion> filter)

    • findNodesToPull

      List<Node> findNodesToPull()

    • findNodesToPushTo

      List<Node> findNodesToPushTo()

    • findNodesWhoPushToMe

      List<Node> findNodesWhoPushToMe()

    • findNodesWhoPullFromMe

      List<Node> findNodesWhoPullFromMe()

    • findSourceNodesFor

      List<Node> findSourceNodesFor(NodeGroupLinkAction eventAction)

    • findTargetNodesFor

      List<Node> findTargetNodesFor(NodeGroupLinkAction eventAction)

    • getSourceNodesFromDatabase

      List<Node> getSourceNodesFromDatabase(NodeGroupLinkAction eventAction, Node node)

    • getTargetNodesFromDatabase

      List<Node> getTargetNodesFromDatabase(NodeGroupLinkAction eventAction, Node node)

    • isExternalIdRegistered

      boolean isExternalIdRegistered(String nodeGroupId, String externalId)

    • save

      void save(Node node)

    • updateNodeHost

      void updateNodeHost(NodeHost nodeHost)

    • updateNodeHostForCurrentNode

      void updateNodeHostForCurrentNode()

    • insertNodeIdentity

      void insertNodeIdentity(String nodeId)

    • insertNodeGroup

      void insertNodeGroup(String groupId, String description)

    • updateNodeSecurity

      boolean updateNodeSecurity(NodeSecurity security)

    • updateNodeSecurity

      boolean updateNodeSecurity(ISqlTransaction transaction, NodeSecurity security)

    • setInitialLoadEnabled

      boolean setInitialLoadEnabled(String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, String createBy)

    • setInitialLoadEnabled

      boolean setInitialLoadEnabled(ISqlTransaction transaction, String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, String createBy)

    • setInitialLoadEnded

      boolean setInitialLoadEnded(ISqlTransaction transaction, String nodeId)

    • setPartialLoadStarted

      boolean setPartialLoadStarted(ISqlTransaction transaction, String nodeId, long loadId, String createBy)

    • setPartialLoadEnded

      boolean setPartialLoadEnded(ISqlTransaction transaction, String nodeId)

    • setReverseInitialLoadEnabled

      boolean setReverseInitialLoadEnabled(ISqlTransaction transaction, String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, String createBy)

    • setReverseInitialLoadEnabled

      boolean setReverseInitialLoadEnabled(String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, String createBy)

    • isDataLoadCompleted

      boolean isDataLoadCompleted()
      Returns:
      true if a data load has occurred and has been completed.

    • isDataLoadCompleted

      boolean isDataLoadCompleted(String nodeId)

    • isDataLoadStarted

      boolean isDataLoadStarted()
      Returns:
      true if a data load has started but not yet completed.

    • isDataLoadStarted

      boolean isDataLoadStarted(String nodeId)

    • getNodeStatus

      NodeStatus getNodeStatus()
      Get the current status of this node.
      Returns:
      NodeStatus

    • getNodeStatus

      NodeStatus getNodeStatus(String nodeId)

    • checkForOfflineNodes

      void checkForOfflineNodes()
      Check to see if any nodes are offline and process any nodes found using the configured IOfflineNodeHandler.

    • findOfflineNodes

      List<Node> findOfflineNodes()
      Find nodes that have been offline for the configured timeframe before IOfflineClientListener and IOfflineServerListener will be called
      Returns:
      list of offline nodes

    • findOfflineNodes

      List<Node> findOfflineNodes(long minutesOffline)
      Find nodes that have been offline for a number of minutes
      Parameters:
      minutesOffline - the number of minutes that have passed that a node has not checked in for until it is considered offline
      Returns:
      list of offline nodes

    • findLastHeartbeats

      Map<String,Date> findLastHeartbeats()

    • findOfflineNodeIds

      List<String> findOfflineNodeIds(long minutesOffline)

    • getRootNetworkedNode

      NetworkedNode getRootNetworkedNode()

    • findRootNode

      Node findRootNode()

    • getAuthenticationStatus

      INodeService.AuthenticationStatus getAuthenticationStatus(String nodeId, String securityToken)

    • resetNodeFailedLogins

      void resetNodeFailedLogins(String nodeId)

    • incrementNodeFailedLogins

      void incrementNodeFailedLogins(String nodeId)