com.bigdata.ha

Class HAPipelineResetRequest

java.lang.Object

com.bigdata.ha.HAPipelineResetRequest

All Implemented Interfaces:

IHAPipelineResetRequest, IHAMessage, Serializable

public class HAPipelineResetRequest
extends Object
implements IHAPipelineResetRequest

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HAPipelineResetRequest(long token, UUID problemServiceId, long timeoutNanos)

Method Summary

Methods

Modifier and Type	Method and Description
UUID	getProblemServiceId() The UUID of the service that the leader has forced from the pipeline
long	getTimeoutNanos() How long to await the state where the problem service is no longer part of the write pipeline for a service that is upstream or downstream of the problem service.
long	token() The quorum token in effect on the leader when this request was generated.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

HAPipelineResetRequest

public HAPipelineResetRequest(long token,
                      UUID problemServiceId,
                      long timeoutNanos)

Method Detail

token

public long token()

Description copied from interface: IHAPipelineResetRequest

The quorum token in effect on the leader when this request was generated.

Specified by:

token in interface IHAPipelineResetRequest

toString

public String toString()

Overrides:

toString in class Object

getProblemServiceId

public UUID getProblemServiceId()

Description copied from interface: IHAPipelineResetRequest

The UUID of the service that the leader has forced from the pipeline

Specified by:

getProblemServiceId in interface IHAPipelineResetRequest

Returns:

The UUID of the problem service -or- null if the leader did not identify a problem service.

getTimeoutNanos

public long getTimeoutNanos()

Description copied from interface: IHAPipelineResetRequest

How long to await the state where the problem service is no longer part of the write pipeline for a service that is upstream or downstream of the problem service.

Specified by:

getTimeoutNanos in interface IHAPipelineResetRequest