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 <dan@infinispan.org>, 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​(java.lang.Object key)
        Checks if an inbound state transfer is in progress for a given key.
        Parameters:
        key -
        Returns:
      • start

        void start()
            throws java.lang.Exception
        Throws:
        java.lang.Exception
      • waitForInitialStateTransferToComplete

        void waitForInitialStateTransferToComplete()
      • stop

        void stop()
      • forwardCommandIfNeeded

        java.util.Map<Address,​Response> forwardCommandIfNeeded​(org.infinispan.commands.TopologyAffectedCommand command,
                                                                     java.util.Set<java.lang.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

        @Deprecated
        boolean ownsData()
        Deprecated.
        Since 9.4, will be removed.
        Returns:
        true if this node has already received the first rebalance start
      • getFirstTopologyAsMember

        @Deprecated
        int getFirstTopologyAsMember()
        Deprecated.
        Since 9.4, will be removed.
        Returns:
        The id of the first cache topology in which the local node was a member (even if it didn't own any data).
      • getRebalancingStatus

        java.lang.String getRebalancingStatus()
                                       throws java.lang.Exception
        Throws:
        java.lang.Exception