Package com.snowflake.connectors.taskreactor.worker.queue

Class InMemoryWorkerQueueManager

java.lang.Object

com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueueManager

All Implemented Interfaces:

com.snowflake.connectors.taskreactor.worker.queue.WorkerQueueManager

public class InMemoryWorkerQueueManager
extends Object
implements com.snowflake.connectors.taskreactor.worker.queue.WorkerQueueManager

In memory implementation of WorkerQueueManager.

Constructor Summary

Constructors

Constructor	Description
InMemoryWorkerQueueManager()

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears the set of queues in this manager.
void	createWorkerQueueIfNotExist(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)
void	dropWorkerQueue(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)
Set<com.snowflake.connectors.taskreactor.worker.WorkerId>	workerQueues()	Returns the set backing this manager.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryWorkerQueueManager

public InMemoryWorkerQueueManager()

Method Detail

createWorkerQueueIfNotExist

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

Specified by:

createWorkerQueueIfNotExist in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueueManager

dropWorkerQueue

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

Specified by:

dropWorkerQueue in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueueManager

workerQueues

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

Returns the set backing this manager.

Returns:

set backing this manager

clear

public void clear()

Clears the set of queues in this manager.