com.alipay.sofa.registry.server.session.push

类 TriggerPushContext

java.lang.Object

com.alipay.sofa.registry.server.session.push.TriggerPushContext

public final class TriggerPushContext
extends Object

字段概要

字段

限定符和类型	字段和说明
String	dataNode

构造器概要

构造器

构造器和说明
TriggerPushContext(Map<String,Long> expectDatumVersion, String dataNode, long triggerSessionTimestamp)
TriggerPushContext(Map<String,Long> expectDatumVersion, String dataNode, long triggerSessionTimestamp, TraceTimes traceTimes)
TriggerPushContext(String dataCenter, long expectDatumVersion, String dataNode, long triggerSessionTimestamp)
TriggerPushContext(String dataCenter, long expectDatumVersion, String dataNode, long triggerSessionTimestamp, TraceTimes traceTimes)

方法概要

限定符和类型	方法和说明
void	addTraceTime(TraceTimes times)
Set<String>	dataCenters()
String	formatTraceTimes(long pushFinishTimestamp)
Map<String,Long>	getExpectDatumVersion()
TraceTimes	getFirstTimes()
TraceTimes	getLastTimes()
int	mergeVersion(TriggerPushContext existCtx)
void	setExpectDatumVersion(Map<String,Long> expectDatumVersion)
boolean	smallerThan(TriggerPushContext existCtx) return true when this all datacenter version are smaller than changeCtx
String	toString()

从类继承的方法 java.lang.Object

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

字段详细资料

dataNode

public final String dataNode

构造器详细资料

TriggerPushContext

public TriggerPushContext(String dataCenter,
                          long expectDatumVersion,
                          String dataNode,
                          long triggerSessionTimestamp)

TriggerPushContext

public TriggerPushContext(String dataCenter,
                          long expectDatumVersion,
                          String dataNode,
                          long triggerSessionTimestamp,
                          TraceTimes traceTimes)

TriggerPushContext

public TriggerPushContext(Map<String,Long> expectDatumVersion,
                          String dataNode,
                          long triggerSessionTimestamp)

TriggerPushContext

public TriggerPushContext(Map<String,Long> expectDatumVersion,
                          String dataNode,
                          long triggerSessionTimestamp,
                          TraceTimes traceTimes)

方法详细资料

dataCenters

public Set<String> dataCenters()

getFirstTimes

public TraceTimes getFirstTimes()

getLastTimes

public TraceTimes getLastTimes()

addTraceTime

public void addTraceTime(TraceTimes times)

getExpectDatumVersion

public Map<String,Long> getExpectDatumVersion()

setExpectDatumVersion

public void setExpectDatumVersion(Map<String,Long> expectDatumVersion)

formatTraceTimes

public String formatTraceTimes(long pushFinishTimestamp)

toString

public String toString()

覆盖:

toString 在类中 Object

smallerThan

public boolean smallerThan(TriggerPushContext existCtx)

return true when this all datacenter version are smaller than changeCtx

参数:

existCtx - existCtx

返回:

boolean

mergeVersion

public int mergeVersion(TriggerPushContext existCtx)