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

Class InMemoryWorkerQueue

  • All Implemented Interfaces:
    com.snowflake.connectors.taskreactor.worker.queue.WorkerQueue
    public class InMemoryWorkerQueue
extends Object
implements com.snowflake.connectors.taskreactor.worker.queue.WorkerQueue
    In memory implementation of WorkerQueue.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void clear()
      Clears this queue.
      void delete​(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)  
      com.snowflake.connectors.taskreactor.worker.queue.WorkItem fetch​(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)  
      void push​(com.snowflake.connectors.taskreactor.queue.QueueItem queueItem, com.snowflake.connectors.taskreactor.worker.WorkerId workerId)  
      Map<com.snowflake.connectors.taskreactor.worker.WorkerId,​com.snowflake.connectors.taskreactor.worker.queue.WorkItem> store()
      Returns the map backing this queue.

    • Constructor Detail

      • InMemoryWorkerQueue

        public InMemoryWorkerQueue()

    • Method Detail

      • push

        public void push​(com.snowflake.connectors.taskreactor.queue.QueueItem queueItem,
                 com.snowflake.connectors.taskreactor.worker.WorkerId workerId)
        Specified by:
        push in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueue

      • fetch

        public com.snowflake.connectors.taskreactor.worker.queue.WorkItem fetch​(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)
        Specified by:
        fetch in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueue

      • delete

        public void delete​(com.snowflake.connectors.taskreactor.worker.WorkerId workerId)
        Specified by:
        delete in interface com.snowflake.connectors.taskreactor.worker.queue.WorkerQueue

      • store

        public Map<com.snowflake.connectors.taskreactor.worker.WorkerId,​com.snowflake.connectors.taskreactor.worker.queue.WorkItem> store()
        Returns the map backing this queue.
        Returns:
        map backing this queue

      • clear

        public void clear()
        Clears this queue.