edu.iu.dsc.tws.checkpointing.client

Class CheckpointingClientImpl

java.lang.Object

edu.iu.dsc.tws.checkpointing.client.CheckpointingClientImpl

All Implemented Interfaces:

CheckpointingClient, MessageHandler

public final class CheckpointingClientImpl
extends java.lang.Object
implements MessageHandler, CheckpointingClient

This client can be used to communicate with CheckpointManager

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONFIG_WAIT_TIME

Constructor Summary

Constructors

Constructor and Description
CheckpointingClientImpl(RRClient rrClient, long waitTime)

Method Summary

Modifier and Type	Method and Description
void	init()
Checkpoint.FamilyInitializeResponse	initFamily(int containerIndex, int containersCount, java.lang.String family, java.util.Set<java.lang.Integer> members)
void	onMessage(RequestID id, int workerId, Message message) Handles a specific message type
Checkpoint.ComponentDiscoveryResponse	sendDiscoveryMessage(java.lang.String family, int index)
void	sendVersionUpdate(java.lang.String family, int index, long version, MessageHandler messageHandler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CONFIG_WAIT_TIME

public static final java.lang.String CONFIG_WAIT_TIME

See Also:

Constant Field Values

Constructor Detail

CheckpointingClientImpl

public CheckpointingClientImpl(RRClient rrClient,
                               long waitTime)

Method Detail

init

public void init()

sendDiscoveryMessage

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

Specified by:

sendDiscoveryMessage in interface CheckpointingClient

Throws:

BlockingSendException

initFamily

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

Specified by:

initFamily in interface CheckpointingClient

Throws:

BlockingSendException

sendVersionUpdate

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

Specified by:

sendVersionUpdate in interface CheckpointingClient

onMessage

public void onMessage(RequestID id,
                      int workerId,
                      Message message)

Description copied from interface: MessageHandler

Handles a specific message type

Specified by:

onMessage in interface MessageHandler

Parameters:

id - request id

workerId - worker id

message - protbuf message