Package com.snowflake.connectors.taskreactor.registry

Class InMemoryInstanceRegistryRepository

java.lang.Object

com.snowflake.connectors.taskreactor.registry.InMemoryInstanceRegistryRepository

All Implemented Interfaces:

com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository

public class InMemoryInstanceRegistryRepository
extends Object
implements com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository

In memory implementation of InstanceRegistryRepository.

Constructor Summary

Constructors

Constructor	Description
InMemoryInstanceRegistryRepository()

Method Summary

Modifier and Type	Method	Description
void	addInstance(com.snowflake.connectors.common.object.Identifier instanceName, boolean isActive)	Adds a new Task Reactor instance.
void	addInstance(com.snowflake.connectors.common.object.Identifier instanceName, boolean isInitialized, boolean isActive)	Adds a new Task Reactor instance.
void	clear()	Clears this repository.
com.snowflake.connectors.taskreactor.registry.TaskReactorInstance	fetch(com.snowflake.connectors.common.object.Identifier instance)
List<com.snowflake.connectors.taskreactor.registry.TaskReactorInstance>	fetchAll()
List<com.snowflake.connectors.taskreactor.registry.TaskReactorInstance>	fetchAllInitialized()
void	setActive(com.snowflake.connectors.common.object.Identifier instance)
void	setInactive(com.snowflake.connectors.common.object.Identifier instance)

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryInstanceRegistryRepository

public InMemoryInstanceRegistryRepository()

Method Detail

fetchAll

public List<com.snowflake.connectors.taskreactor.registry.TaskReactorInstance> fetchAll()

Specified by:

fetchAll in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository

fetchAllInitialized

public List<com.snowflake.connectors.taskreactor.registry.TaskReactorInstance> fetchAllInitialized()

Specified by:

fetchAllInitialized in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository

fetch

public com.snowflake.connectors.taskreactor.registry.TaskReactorInstance fetch(com.snowflake.connectors.common.object.Identifier instance)

Specified by:

fetch in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository

setInactive

public void setInactive(com.snowflake.connectors.common.object.Identifier instance)

Specified by:

setInactive in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository

setActive

public void setActive(com.snowflake.connectors.common.object.Identifier instance)

Specified by:

setActive in interface com.snowflake.connectors.taskreactor.registry.InstanceRegistryRepository

addInstance

public void addInstance(com.snowflake.connectors.common.object.Identifier instanceName,
                        boolean isActive)

Adds a new Task Reactor instance.

Parameters:

instanceName - instance name

isActive - is the instance active

addInstance

public void addInstance(com.snowflake.connectors.common.object.Identifier instanceName,
                        boolean isInitialized,
                        boolean isActive)

Adds a new Task Reactor instance.

Parameters:

instanceName - instance name

isActive - is the instance active

isInitialized - is the instance initialized

clear

public void clear()

Clears this repository.