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 Description DefaultWorkerStateGateway(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddeactivateWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)voiddeleteWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)protected java.lang.StringgetActiveWorkerRangeByIdQuery()protected java.lang.StringgetCreateTableStatement()protected java.lang.StringgetInsertWorkerRowStatement()protected java.lang.StringgetSelectWorkersQuery()java.lang.StringgetTableName()protected java.lang.StringgetUpdateWorkerHealthCheckStatement()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.StringgetWorkersHealthChecksQuery()voidregisterAsWorker(WorkerStateGateway.WorkerState workerState)voidupdateWorkersRanges(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
-
-
-
-
Method Detail
-
registerAsWorker
public void registerAsWorker(WorkerStateGateway.WorkerState workerState)
- Specified by:
registerAsWorkerin interfaceWorkerStateGateway
-
getCreateTableStatement
protected java.lang.String getCreateTableStatement()
- Specified by:
getCreateTableStatementin classDefaultBaseGateway
-
getInsertWorkerRowStatement
protected java.lang.String getInsertWorkerRowStatement()
-
getUpdateWorkerHealthCheckStatement
protected java.lang.String getUpdateWorkerHealthCheckStatement()
-
getTableName
public java.lang.String getTableName()
- Specified by:
getTableNamein interfaceBaseGateway
-
getWorkersHealthChecks
public java.util.Map<java.lang.Integer,java.time.Duration> getWorkersHealthChecks()
- Specified by:
getWorkersHealthChecksin interfaceWorkerStateGateway
-
getWorkersHealthChecksQuery
protected java.lang.String getWorkersHealthChecksQuery()
-
getWorkerRangeById
public java.util.Optional<java.util.List<WorkerStateGateway.WorkerRange>> getWorkerRangeById(int nodeID)
- Specified by:
getWorkerRangeByIdin interfaceWorkerStateGateway
-
getActiveWorkerRangeByIdQuery
protected java.lang.String getActiveWorkerRangeByIdQuery()
-
getWorkers
public java.util.List<WorkerStateGateway.WorkerState> getWorkers()
- Specified by:
getWorkersin interfaceWorkerStateGateway
-
getSelectWorkersQuery
protected java.lang.String getSelectWorkersQuery()
-
updateWorkersRanges
public void updateWorkersRanges(java.util.Map<java.lang.Integer,WorkerStateGateway.WorkerRange> ranges)
- Specified by:
updateWorkersRangesin interfaceWorkerStateGateway
-
deleteWorkers
public void deleteWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)
- Specified by:
deleteWorkersin interfaceWorkerStateGateway
-
deactivateWorkers
public void deactivateWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)
- Specified by:
deactivateWorkersin interfaceWorkerStateGateway
-
-