Package com.snowflake.connectors.taskreactor.worker.status

Class InMemoryWorkerStatusRepository

java.lang.Object

com.snowflake.connectors.taskreactor.worker.status.InMemoryWorkerStatusRepository

All Implemented Interfaces:

com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository

public class InMemoryWorkerStatusRepository
extends Object
implements com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository

In memory implementation of WorkerStatusRepository.

Nested Class Summary

Nested classes/interfaces inherited from interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository

com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository.ColumnNames

Constructor Summary

Constructors

Constructor	Description
InMemoryWorkerStatusRepository()

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears this repository.
Set<com.snowflake.connectors.taskreactor.worker.WorkerId>	getAvailableWorkers()
Optional<Instant>	getLastAvailable(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)
com.snowflake.connectors.taskreactor.worker.status.WorkerStatus	getStatusFor(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)
void	removeStatusFor(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)
Map<com.snowflake.connectors.taskreactor.worker.WorkerId,com.snowflake.connectors.taskreactor.worker.status.WorkerStatus>	store()
void	updateStatusesFor(com.snowflake.connectors.taskreactor.worker.status.WorkerStatus status, List<com.snowflake.connectors.taskreactor.worker.WorkerId> workerIds)
void	updateStatusFor(com.snowflake.connectors.taskreactor.worker.WorkerId workerId, com.snowflake.connectors.taskreactor.worker.status.WorkerStatus status)

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryWorkerStatusRepository

public InMemoryWorkerStatusRepository()

Method Detail

getAvailableWorkers

public Set<com.snowflake.connectors.taskreactor.worker.WorkerId> getAvailableWorkers()

Specified by:

getAvailableWorkers in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository

getStatusFor

public com.snowflake.connectors.taskreactor.worker.status.WorkerStatus getStatusFor(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)

Specified by:

getStatusFor in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository

updateStatusFor

public void updateStatusFor(com.snowflake.connectors.taskreactor.worker.WorkerId workerId,
                            com.snowflake.connectors.taskreactor.worker.status.WorkerStatus status)

Specified by:

updateStatusFor in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository

updateStatusesFor

public void updateStatusesFor(com.snowflake.connectors.taskreactor.worker.status.WorkerStatus status,
                              List<com.snowflake.connectors.taskreactor.worker.WorkerId> workerIds)

Specified by:

updateStatusesFor in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository

removeStatusFor

public void removeStatusFor(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)

Specified by:

removeStatusFor in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository

getLastAvailable

public Optional<Instant> getLastAvailable(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)

Specified by:

getLastAvailable in interface com.snowflake.connectors.taskreactor.worker.status.WorkerStatusRepository

store

public Map<com.snowflake.connectors.taskreactor.worker.WorkerId,com.snowflake.connectors.taskreactor.worker.status.WorkerStatus> store()

clear

public void clear()

Clears this repository.