Interface ClusterStore

    • Method Detail

      • getLocalNode

        ControllerNode getLocalNode()
        Returns the local controller node.
        Returns:
        local controller instance
      • getStorageNodes

        java.util.Set<Node> getStorageNodes()
        Returns the set of storage nodes.
        Returns:
        set of storage nodes
      • getNodes

        java.util.Set<ControllerNode> getNodes()
        Returns the set of current cluster members.
        Returns:
        set of cluster members
      • getNode

        ControllerNode getNode​(NodeId nodeId)
        Returns the specified controller node.
        Parameters:
        nodeId - controller instance identifier
        Returns:
        controller instance
      • getState

        ControllerNode.State getState​(NodeId nodeId)
        Returns the availability state of the specified controller node.
        Parameters:
        nodeId - controller instance identifier
        Returns:
        availability state
      • getVersion

        Version getVersion​(NodeId nodeId)
        Returns the version of the specified controller node.
        Parameters:
        nodeId - controller instance identifier
        Returns:
        controller version
      • markFullyStarted

        void markFullyStarted​(boolean started)
        Marks the current node as fully started.
        Parameters:
        started - true indicates all components have been started
      • getLastUpdatedInstant

        java.time.Instant getLastUpdatedInstant​(NodeId nodeId)
        Returns the system when the availability state was last updated.
        Parameters:
        nodeId - controller node identifier
        Returns:
        system time when the availability state was last updated.
      • addNode

        ControllerNode addNode​(NodeId nodeId,
                               IpAddress ip,
                               int tcpPort)
        Adds a new controller node to the cluster.
        Parameters:
        nodeId - controller node identifier
        ip - node IP listen address
        tcpPort - tcp listen port
        Returns:
        newly added node
      • removeNode

        void removeNode​(NodeId nodeId)
        Removes the specified node from the inventory of cluster nodes.
        Parameters:
        nodeId - controller instance identifier