@Test public void assertClearAllStartedInfo() { guaranteeService.clearAllStartedInfo(); verify(jobNodeStorage).removeJobNodeIfExisted("guarantee/started"); }
public void clearAllStartedInfo() { jobNodeStorage.removeJobNodeIfExisted(GuaranteeNode.STARTED_ROOT); }
GuaranteeService { public void clearAllStartedInfo() { jobNodeStorage.removeJobNodeIfExisted(GuaranteeNode.STARTED_ROOT); } }
GuaranteeService { public void clearAllStartedInfo() { jobNodeStorage.removeJobNodeIfExisted(GuaranteeNode.STARTED_ROOT); } GuaranteeService(final CoordinatorRegistryCenter regCenter, final String jobName); }
GuaranteeService { public void clearAllStartedInfo() { jobNodeStorage.removeJobNodeIfExisted(GuaranteeNode.STARTED_ROOT); } GuaranteeService(final CoordinatorRegistryCenter regCenter, final String jobName); void registerStart(final Collection<Integer> shardingItems); boolean isRegisterStartSuccess(final Collection<Integer> shardingItems); boolean isAllStarted(); void clearAllStartedInfo(); void registerComplete(final Collection<Integer> shardingItems); boolean isRegisterCompleteSuccess(final Collection<Integer> shardingItems); boolean isAllCompleted(); void clearAllCompletedInfo(); }
GuaranteeService { public void clearAllStartedInfo() { jobNodeStorage.removeJobNodeIfExisted(GuaranteeNode.STARTED_ROOT); } GuaranteeService(final CoordinatorRegistryCenter regCenter, final String jobName); void registerStart(final Collection<Integer> shardingItems); boolean isRegisterStartSuccess(final Collection<Integer> shardingItems); boolean isAllStarted(); void clearAllStartedInfo(); void registerComplete(final Collection<Integer> shardingItems); boolean isRegisterCompleteSuccess(final Collection<Integer> shardingItems); boolean isAllCompleted(); void clearAllCompletedInfo();  }