Package io.split.engine.common

Class SynchronizerImp

java.lang.Object

io.split.engine.common.SynchronizerImp

All Implemented Interfaces:

Synchronizer

public class SynchronizerImp
extends Object
implements Synchronizer

Constructor Summary

Constructors

Constructor	Description
SynchronizerImp(SplitTasks splitTasks, SplitFetcher splitFetcher, SplitCacheProducer splitCacheProducer, SegmentCacheProducer segmentCacheProducer, RuleBasedSegmentCacheProducer ruleBasedSegmentCacheProducer, int onDemandFetchRetryDelayMs, int onDemandFetchMaxRetries, int failedAttemptsBeforeLogging, HashSet<String> sets)

Method Summary

Modifier and Type	Method	Description
io.split.engine.common.SynchronizerImp.SyncResult	attemptSegmentSync(String segmentName, long targetChangeNumber, FetchOptions opts, Function<Void,Long> nextWaitMs, int maxRetries)
void	forceRefreshSegment(String segmentName)
void	localKillSplit(SplitKillNotification splitKillNotification)
void	refreshSegment(String segmentName, Long targetChangeNumber)
void	refreshSplits(Long targetChangeNumber, Long ruleBasedSegmentChangeNumber)
void	startPeriodicDataRecording()
void	startPeriodicFetching()
void	stopPeriodicDataRecording()
void	stopPeriodicFetching()
boolean	syncAll()

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronizerImp

public SynchronizerImp(SplitTasks splitTasks,
                       SplitFetcher splitFetcher,
                       SplitCacheProducer splitCacheProducer,
                       SegmentCacheProducer segmentCacheProducer,
                       RuleBasedSegmentCacheProducer ruleBasedSegmentCacheProducer,
                       int onDemandFetchRetryDelayMs,
                       int onDemandFetchMaxRetries,
                       int failedAttemptsBeforeLogging,
                       HashSet<String> sets)

Method Detail

syncAll

public boolean syncAll()

Specified by:

syncAll in interface Synchronizer

startPeriodicFetching

public void startPeriodicFetching()

Specified by:

startPeriodicFetching in interface Synchronizer

stopPeriodicFetching

public void stopPeriodicFetching()

Specified by:

stopPeriodicFetching in interface Synchronizer

refreshSplits

public void refreshSplits(Long targetChangeNumber,
                          Long ruleBasedSegmentChangeNumber)

Specified by:

refreshSplits in interface Synchronizer

localKillSplit

public void localKillSplit(SplitKillNotification splitKillNotification)

Specified by:

localKillSplit in interface Synchronizer

attemptSegmentSync

public io.split.engine.common.SynchronizerImp.SyncResult attemptSegmentSync(String segmentName,
                                                                            long targetChangeNumber,
                                                                            FetchOptions opts,
                                                                            Function<Void,Long> nextWaitMs,
                                                                            int maxRetries)

refreshSegment

public void refreshSegment(String segmentName,
                           Long targetChangeNumber)

Specified by:

refreshSegment in interface Synchronizer

startPeriodicDataRecording

public void startPeriodicDataRecording()

Specified by:

startPeriodicDataRecording in interface Synchronizer

stopPeriodicDataRecording

public void stopPeriodicDataRecording()

Specified by:

stopPeriodicDataRecording in interface Synchronizer

forceRefreshSegment

public void forceRefreshSegment(String segmentName)

Specified by:

forceRefreshSegment in interface Synchronizer