org.apache.shardingsphere.elasticjob.lite.internal.failover

Class FailoverService

java.lang.Object

org.apache.shardingsphere.elasticjob.lite.internal.failover.FailoverService

public final class FailoverService
extends Object

Failover service.

Constructor Summary

Constructors

Constructor and Description
FailoverService(CoordinatorRegistryCenter regCenter, String jobName)

Method Summary

Modifier and Type	Method and Description
void	failoverIfNecessary() Failover if necessary.
List<Integer>	getFailoveringItems(String jobInstanceId) Get failovering items.
List<Integer>	getFailoverItems(String jobInstanceId) Get failover items.
List<Integer>	getLocalFailoverItems() Get failover items which execute on localhost.
List<Integer>	getLocalTakeOffItems() Get failover items which crashed on localhost.
void	removeFailoverInfo() Remove failover info.
void	setCrashedFailoverFlag(int item) set crashed failover flag.
void	setCrashedFailoverFlagDirectly(int item) set crashed failover flag directly.
void	updateFailoverComplete(Collection<Integer> items) Update sharding items status when failover execution complete.

Methods inherited from class java.lang.Object

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

Constructor Detail

FailoverService

public FailoverService(CoordinatorRegistryCenter regCenter,
                       String jobName)

Method Detail

setCrashedFailoverFlag

public void setCrashedFailoverFlag(int item)

set crashed failover flag.

Parameters:

item - crashed job item

setCrashedFailoverFlagDirectly

public void setCrashedFailoverFlagDirectly(int item)

set crashed failover flag directly.

Parameters:

item - crashed item

failoverIfNecessary

public void failoverIfNecessary()

Failover if necessary.

updateFailoverComplete

public void updateFailoverComplete(Collection<Integer> items)

Update sharding items status when failover execution complete.

Parameters:

items - sharding items of failover execution completed

getFailoverItems

public List<Integer> getFailoverItems(String jobInstanceId)

Get failover items.

Parameters:

jobInstanceId - job instance ID

Returns:

failover items

getFailoveringItems

public List<Integer> getFailoveringItems(String jobInstanceId)

Get failovering items.

Parameters:

jobInstanceId - job instance ID

Returns:

failovering items

getLocalFailoverItems

public List<Integer> getLocalFailoverItems()

Get failover items which execute on localhost.

Returns:

failover items which execute on localhost

getLocalTakeOffItems

public List<Integer> getLocalTakeOffItems()

Get failover items which crashed on localhost.

Returns:

failover items which crashed on localhost

removeFailoverInfo

public void removeFailoverInfo()

Remove failover info.