de.hybris.platform.task.impl.gateways

Class DefaultWorkerStateGateway

java.lang.Object

de.hybris.platform.task.impl.gateways.DefaultBaseGateway

de.hybris.platform.task.impl.gateways.DefaultWorkerStateGateway

All Implemented Interfaces:

BaseGateway, WorkerStateGateway

Direct Known Subclasses:

MsSqlWorkerStateGateway, OracleWorkerStateGateway, PostgresWorkerStateGateway

public class DefaultWorkerStateGateway
extends DefaultBaseGateway
implements WorkerStateGateway

Nested Class Summary

Nested classes/interfaces inherited from interface de.hybris.platform.task.impl.gateways.WorkerStateGateway

WorkerStateGateway.WorkerRange, WorkerStateGateway.WorkerState

Field Summary

Fields inherited from class de.hybris.platform.task.impl.gateways.DefaultBaseGateway

jdbcTemplate

Constructor Summary

Constructors

Constructor and Description
DefaultWorkerStateGateway(JdbcTemplate jdbcTemplate)

Method Summary

Modifier and Type	Method and Description
void	deactivateWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)
void	deleteWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)
protected java.lang.String	getActiveWorkerRangeByIdQuery()
protected java.lang.String	getCreateTableStatement()
protected java.lang.String	getInsertWorkerRowStatement()
protected java.lang.String	getSelectWorkersQuery()
java.lang.String	getTableName()
protected java.lang.String	getUpdateWorkerHealthCheckStatement()
java.util.Optional<java.util.List<WorkerStateGateway.WorkerRange>>	getWorkerRangeById(int nodeID)
java.util.List<WorkerStateGateway.WorkerState>	getWorkers()
java.util.Map<java.lang.Integer,java.time.Duration>	getWorkersHealthChecks()
protected java.lang.String	getWorkersHealthChecksQuery()
void	registerAsWorker(WorkerStateGateway.WorkerState workerState)
void	updateWorkersRanges(java.util.Map<java.lang.Integer,WorkerStateGateway.WorkerRange> ranges)

Methods inherited from class de.hybris.platform.task.impl.gateways.DefaultBaseGateway

createTable, doesTableExist, dropTable, getJdbcTemplate, tryCreatingTableAndLogException

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.hybris.platform.task.impl.gateways.BaseGateway

createTable, doesTableExist, dropTable

Constructor Detail

DefaultWorkerStateGateway

public DefaultWorkerStateGateway(JdbcTemplate jdbcTemplate)

Method Detail

registerAsWorker

public void registerAsWorker(WorkerStateGateway.WorkerState workerState)

Specified by:

registerAsWorker in interface WorkerStateGateway

getCreateTableStatement

protected java.lang.String getCreateTableStatement()

Specified by:

getCreateTableStatement in class DefaultBaseGateway

getInsertWorkerRowStatement

protected java.lang.String getInsertWorkerRowStatement()

getUpdateWorkerHealthCheckStatement

protected java.lang.String getUpdateWorkerHealthCheckStatement()

getTableName

public java.lang.String getTableName()

Specified by:

getTableName in interface BaseGateway

getWorkersHealthChecks

public java.util.Map<java.lang.Integer,java.time.Duration> getWorkersHealthChecks()

Specified by:

getWorkersHealthChecks in interface WorkerStateGateway

getWorkersHealthChecksQuery

protected java.lang.String getWorkersHealthChecksQuery()

getWorkerRangeById

public java.util.Optional<java.util.List<WorkerStateGateway.WorkerRange>> getWorkerRangeById(int nodeID)

Specified by:

getWorkerRangeById in interface WorkerStateGateway

getActiveWorkerRangeByIdQuery

protected java.lang.String getActiveWorkerRangeByIdQuery()

getWorkers

public java.util.List<WorkerStateGateway.WorkerState> getWorkers()

Specified by:

getWorkers in interface WorkerStateGateway

getSelectWorkersQuery

protected java.lang.String getSelectWorkersQuery()

updateWorkersRanges

public void updateWorkersRanges(java.util.Map<java.lang.Integer,WorkerStateGateway.WorkerRange> ranges)

Specified by:

updateWorkersRanges in interface WorkerStateGateway

deleteWorkers

public void deleteWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)

Specified by:

deleteWorkers in interface WorkerStateGateway

deactivateWorkers

public void deactivateWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)

Specified by:

deactivateWorkers in interface WorkerStateGateway