Package com.snowflake.connectors.taskreactor

Class TaskReactorInstanceActionExecutor

java.lang.Object

com.snowflake.connectors.taskreactor.TaskReactorInstanceActionExecutor

public class TaskReactorInstanceActionExecutor
extends Object

Utility class for executing actions on all Task Reactor instances.

Constructor Summary

Constructors

Constructor	Description
TaskReactorInstanceActionExecutor(TaskReactorExistenceVerifier existenceVerifier, InstanceRegistryRepository instanceRegistryRepository)	Creates a new TaskReactorInstanceActionExecutor.

Method Summary

Modifier and Type	Method	Description
void	applyToAllInitializedTaskReactorInstances(Consumer<Identifier> action)	Executes the specified actions for all initialized Task Reactor instances.
static TaskReactorInstanceActionExecutor	getInstance(Session session)	Returns a new instance of the default executor implementation.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskReactorInstanceActionExecutor

public TaskReactorInstanceActionExecutor(TaskReactorExistenceVerifier existenceVerifier,
                                         InstanceRegistryRepository instanceRegistryRepository)

Creates a new TaskReactorInstanceActionExecutor.

Parameters:

existenceVerifier - Task Reactor existence verifier

instanceRegistryRepository - Task Reactor instance registry repository

Method Detail

getInstance

public static TaskReactorInstanceActionExecutor getInstance(Session session)

Returns a new instance of the default executor implementation.

Parameters:

session - Snowpark session object

Returns:

a new executor instance

applyToAllInitializedTaskReactorInstances

public void applyToAllInitializedTaskReactorInstances(Consumer<Identifier> action)

Executes the specified actions for all initialized Task Reactor instances.

Parameters:

action - action to be executed