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()
InMemoryTaskReactorInstanceComponentProvider(Map<com.snowflake.connectors.common.object.Identifier,InMemoryCommandsQueueRepository> commandsQueueRepositories, com.snowflake.connectors.common.task.TaskRepository taskRepository)

Method Summary

Modifier and Type	Method	Description
Map<com.snowflake.connectors.common.object.Identifier,InMemoryCommandsQueueRepository>	commandsQueueRepositories()	Returns the commands queue repositories.
com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository	commandsQueueRepository(com.snowflake.connectors.common.object.Identifier instanceSchema)
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()

InMemoryTaskReactorInstanceComponentProvider

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

Method Detail

commandsQueueRepository

public com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository commandsQueueRepository(com.snowflake.connectors.common.object.Identifier instanceSchema)

Specified by:

commandsQueueRepository 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

commandsQueueRepositories

public Map<com.snowflake.connectors.common.object.Identifier,InMemoryCommandsQueueRepository> commandsQueueRepositories()

Returns the commands queue repositories.

Returns:

commands queue repositories