org.apache.shardingsphere.elasticjob.lite.internal.guarantee

Class GuaranteeService

java.lang.Object

org.apache.shardingsphere.elasticjob.lite.internal.guarantee.GuaranteeService

public final class GuaranteeService
extends Object

Guarantee service.

Constructor Summary

Constructors

Constructor and Description
GuaranteeService(CoordinatorRegistryCenter regCenter, String jobName)

Method Summary

Modifier and Type	Method and Description
void	clearAllCompletedInfo() Clear all completed job's info.
void	clearAllStartedInfo() Clear all started job's info.
boolean	isAllCompleted() Judge whether job's sharding items are all completed.
boolean	isAllStarted() Judge whether job's sharding items are all started.
boolean	isRegisterCompleteSuccess(Collection<Integer> shardingItems) Judge whether sharding items are register complete success.
boolean	isRegisterStartSuccess(Collection<Integer> shardingItems) Judge whether current sharding items are all register start success.
void	registerComplete(Collection<Integer> shardingItems) Register complete.
void	registerStart(Collection<Integer> shardingItems) Register start.

Methods inherited from class java.lang.Object

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

Constructor Detail

GuaranteeService

public GuaranteeService(CoordinatorRegistryCenter regCenter,
                        String jobName)

Method Detail

registerStart

public void registerStart(Collection<Integer> shardingItems)

Register start.

Parameters:

shardingItems - to be registered sharding items

isRegisterStartSuccess

public boolean isRegisterStartSuccess(Collection<Integer> shardingItems)

Judge whether current sharding items are all register start success.

Parameters:

shardingItems - current sharding items

Returns:

current sharding items are all start success or not

isAllStarted

public boolean isAllStarted()

Judge whether job's sharding items are all started.

Returns:

job's sharding items are all started or not

clearAllStartedInfo

public void clearAllStartedInfo()

Clear all started job's info.

registerComplete

public void registerComplete(Collection<Integer> shardingItems)

Register complete.

Parameters:

shardingItems - to be registered sharding items

isRegisterCompleteSuccess

public boolean isRegisterCompleteSuccess(Collection<Integer> shardingItems)

Judge whether sharding items are register complete success.

Parameters:

shardingItems - current sharding items

Returns:

current sharding items are all complete success or not

isAllCompleted

public boolean isAllCompleted()

Judge whether job's sharding items are all completed.

Returns:

job's sharding items are all completed or not

clearAllCompletedInfo

public void clearAllCompletedInfo()

Clear all completed job's info.