Interface StateTransferManager

  • All Known Implementing Classes:
    StateTransferManagerImpl

    public interface StateTransferManager
    A component that manages the state transfer when the topology of the cluster changes.
    Since:
    5.1
    Author:
    Dan Berindei , Mircea Markus, anistor@redhat.com
    • Method Detail

      • isJoinComplete

        boolean isJoinComplete()
      • isStateTransferInProgress

        boolean isStateTransferInProgress()
        Checks if an inbound state transfer is in progress.
      • isStateTransferInProgressForKey

        boolean isStateTransferInProgressForKey​(Object key)
        Checks if an inbound state transfer is in progress for a given key.
        Parameters:
        key -
        Returns:
      • stop

        void stop()
      • forwardCommandIfNeeded

        Map<Address,​Response> forwardCommandIfNeeded​(TopologyAffectedCommand command,
                                                           Set<Object> affectedKeys,
                                                           Address origin)
        If there is an state transfer happening at the moment, this method forwards the supplied command to the nodes that are new owners of the data, in order to assure consistency.
      • ownsData

        boolean ownsData()
        Returns:
        true if this node has already received the first rebalance start
      • getFirstTopologyAsMember

        int getFirstTopologyAsMember()
        Returns:
        The id of the first cache topology in which the local node was a member (even if it didn't own any data).