edu.iu.dsc.tws.api.checkpointing

Interface CheckpointingClient

All Known Implementing Classes:

CheckpointingClientImpl

public interface CheckpointingClient

todo This class was added as an temp solution to resolve a cyclic dependency issue. This should be moved to fault tolerance package once code is refactored

Method Summary

Modifier and Type	Method and Description
Checkpoint.FamilyInitializeResponse	initFamily(int containerIndex, int containersCount, java.lang.String family, java.util.Set<java.lang.Integer> members)
Checkpoint.ComponentDiscoveryResponse	sendDiscoveryMessage(java.lang.String family, int index)
void	sendVersionUpdate(java.lang.String family, int index, long version, MessageHandler messageHandler)

Method Detail

sendVersionUpdate

void sendVersionUpdate(java.lang.String family,
                       int index,
                       long version,
                       MessageHandler messageHandler)

sendDiscoveryMessage

Checkpoint.ComponentDiscoveryResponse sendDiscoveryMessage(java.lang.String family,
                                                           int index)
                                                    throws BlockingSendException

Throws:

BlockingSendException

initFamily

Checkpoint.FamilyInitializeResponse initFamily(int containerIndex,
                                               int containersCount,
                                               java.lang.String family,
                                               java.util.Set<java.lang.Integer> members)
                                        throws BlockingSendException

Throws:

BlockingSendException