Package com.linkedin.venice.controller

Class DeferredVersionSwapService

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.venice.controller.DeferredVersionSwapService

All Implemented Interfaces:

Closeable, AutoCloseable

public class DeferredVersionSwapService
extends AbstractVeniceService

This service is in charge of swapping to a new version after a specified wait time in the remaining regions of a target region push if enabled. The wait time is specified through a store/version level config (target_swap_region_wait_time) and the default wait time is 60m. This service also updates the parent version status of a store w/ a terminal push status after performing the swap or deeming it ineligible for a version swap and the statuses mean: 1. ONLINE - all regions are serving the target version 2. PARTIALLY_ONLINE - 1+ regions are serving the target version, but 1+ regions' pushes failed & are serving the old version 3. ERROR - all regions are serving the old version. the push failed in target regions

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.service.AbstractVeniceService

AbstractVeniceService.ServiceState

Field Summary

Fields inherited from class com.linkedin.venice.service.AbstractVeniceService

logger, serviceState

Constructor Summary

Constructors

Constructor	Description
DeferredVersionSwapService(VeniceParentHelixAdmin admin, VeniceControllerMultiClusterConfig multiClusterConfig, DeferredVersionSwapStats deferredVersionSwapStats)

Method Summary

Modifier and Type	Method	Description
boolean	startInner()
void	stopInner()

Methods inherited from class com.linkedin.venice.service.AbstractVeniceService

close, getName, isRunning, start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

DeferredVersionSwapService

public DeferredVersionSwapService(VeniceParentHelixAdmin admin,
 VeniceControllerMultiClusterConfig multiClusterConfig,
 DeferredVersionSwapStats deferredVersionSwapStats)

Method Details

startInner

public boolean startInner()
                   throws Exception

Specified by:

startInner in class AbstractVeniceService

Returns:

true if the service is completely started, false if it is still starting asynchronously (in this case, it is the implementer's responsibility to set AbstractVeniceService.serviceState to AbstractVeniceService.ServiceState.STARTED upon completion of the async work).

Throws:

Exception

stopInner

public void stopInner()
               throws Exception

Specified by:

stopInner in class AbstractVeniceService

Throws:

Exception