Package com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile

Interface IReplicationParticipantsMediator

All Known Implementing Classes:
ReplicationParticipantsMediator
public interface IReplicationParticipantsMediator
Responsible for synchronizing replication process logs multiple participants operations in a reliable async target.
Since:
8.0.4
Author:
idan

  • Method Details

    • getAllParticipantsData

      IReplicationPacketData<?>[] getAllParticipantsData(MultiSourceProcessLogPacket packet)
      Gets all data for a multiple participants replication operation. If not all data arrived the return value is null.
      Parameters:
      packet - The packet to be added to the context in case not all packets arrived.
      Returns:
      All data if all data arrived, otherwise null.

    • isConsumed

      boolean isConsumed(Object contextId)
      Returns:
      true if the provided contextId associated operation has been consumed.

    • setConsumed

      void setConsumed(IReplicationParticipantsMetadata participantsMetadata)
      Sets the provided contextId as consumed.

    • remove

      void remove(IReplicationParticipantsMetadata participantsMetadata)
      Removes multiple participant context from mediator according to the provided meta data.

    • abortConsolidation

      boolean abortConsolidation(IReplicationParticipantsMetadata participantsMetadata)
      Attempts to abort consolidation for the provided meta data.
      Returns:
      true if aborted successfully, false if already consolidated.