Package com.snowflake.connectors.taskreactor

Class InMemoryTaskReactorInstanceComponentProvider

java.lang.Object

com.snowflake.connectors.taskreactor.InMemoryTaskReactorInstanceComponentProvider

All Implemented Interfaces:

com.snowflake.connectors.taskreactor.TaskReactorInstanceComponentProvider

public class InMemoryTaskReactorInstanceComponentProvider
extends Object
implements com.snowflake.connectors.taskreactor.TaskReactorInstanceComponentProvider

In memory implementation of TaskReactorInstanceComponentProvider.

Constructor Summary

Constructors

Constructor	Description
InMemoryTaskReactorInstanceComponentProvider()	Creates a new InMemoryTaskReactorInstanceComponentProvider.
InMemoryTaskReactorInstanceComponentProvider(Map<com.snowflake.connectors.common.object.Identifier,InMemoryCommandsQueue> commandsQueueRepositories, com.snowflake.connectors.common.task.TaskRepository taskRepository)	Creates a new InMemoryTaskReactorInstanceComponentProvider.

Method Summary

Modifier and Type	Method	Description
com.snowflake.connectors.taskreactor.commands.queue.CommandsQueue	commandsQueue(com.snowflake.connectors.common.object.Identifier instanceSchema)
Map<com.snowflake.connectors.common.object.Identifier,InMemoryCommandsQueue>	commandsQueues()	Returns the commands queue repositories.
com.snowflake.connectors.taskreactor.dispatcher.DispatcherTaskManager	dispatcherTaskManager(com.snowflake.connectors.common.object.Identifier instanceSchema)
com.snowflake.connectors.common.task.TaskRepository	taskRepository()	Returns the task repository.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryTaskReactorInstanceComponentProvider

public InMemoryTaskReactorInstanceComponentProvider()

Creates a new InMemoryTaskReactorInstanceComponentProvider.

InMemoryTaskReactorInstanceComponentProvider

public InMemoryTaskReactorInstanceComponentProvider(Map<com.snowflake.connectors.common.object.Identifier,InMemoryCommandsQueue> commandsQueueRepositories,
                                                    com.snowflake.connectors.common.task.TaskRepository taskRepository)

Creates a new InMemoryTaskReactorInstanceComponentProvider.

Parameters:

commandsQueueRepositories - map of command queue repositories for specified Task Reactor instance identifiers

taskRepository - task repository

Method Detail

commandsQueue

public com.snowflake.connectors.taskreactor.commands.queue.CommandsQueue commandsQueue(com.snowflake.connectors.common.object.Identifier instanceSchema)

Specified by:

commandsQueue in interface com.snowflake.connectors.taskreactor.TaskReactorInstanceComponentProvider

dispatcherTaskManager

public com.snowflake.connectors.taskreactor.dispatcher.DispatcherTaskManager dispatcherTaskManager(com.snowflake.connectors.common.object.Identifier instanceSchema)

Specified by:

dispatcherTaskManager in interface com.snowflake.connectors.taskreactor.TaskReactorInstanceComponentProvider

taskRepository

public com.snowflake.connectors.common.task.TaskRepository taskRepository()

Returns the task repository.

Returns:

task repository

commandsQueues

public Map<com.snowflake.connectors.common.object.Identifier,InMemoryCommandsQueue> commandsQueues()

Returns the commands queue repositories.

Returns:

commands queue repositories