Package de.hybris.platform.task.impl.gateways

Interface WorkerStateGateway

All Superinterfaces:

BaseGateway

All Known Implementing Classes:

DefaultWorkerStateGateway, MsSqlWorkerStateGateway, OracleWorkerStateGateway, PostgresWorkerStateGateway

public interface WorkerStateGateway
extends BaseGateway

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	WorkerStateGateway.WorkerRange
static class	WorkerStateGateway.WorkerState

Method Summary

Modifier and Type	Method	Description
void	deactivateWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)
void	deleteWorkers(java.util.List<java.lang.Integer> invalidWorkerIds)
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()
void	registerAsWorker(WorkerStateGateway.WorkerState taskEngineParameters)
void	updateWorkersRanges(java.util.Map<java.lang.Integer,WorkerStateGateway.WorkerRange> ranges)

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

createTable, doesTableExist, dropTable, getTableName

Method Detail

registerAsWorker

void registerAsWorker(WorkerStateGateway.WorkerState taskEngineParameters)

getWorkersHealthChecks

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

getWorkerRangeById

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

getWorkers

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

updateWorkersRanges

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

deleteWorkers

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

deactivateWorkers

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