Class PauseTaskReactorService
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.lifecycle.PauseTaskReactorService
-
public class PauseTaskReactorService extends Object
Service which is used to start the process of pausing the Task Reactor. It inserts PAUSE_INSTANCE command into command queue. Then the Task Reactor instances are actually paused by dispatcher which handles the command.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static PauseTaskReactorService
getInstance(Session session)
Creates a new instance of the PauseTaskReactorService.void
pauseAllInstances()
Pauses all Task Reactor instances defined in Instance Registryvoid
pauseInstance(Identifier instanceSchema)
Pauses a given Task Reactor instance
-
-
-
Method Detail
-
getInstance
public static PauseTaskReactorService getInstance(Session session)
Creates a new instance of the PauseTaskReactorService.- Parameters:
session
- Snowpark session object- Returns:
- a new PauseTaskReactorService instance
-
pauseInstance
public void pauseInstance(Identifier instanceSchema)
Pauses a given Task Reactor instance- Parameters:
instanceSchema
- name of the Task Reactor instance to be paused
-
pauseAllInstances
public void pauseAllInstances()
Pauses all Task Reactor instances defined in Instance Registry
-
-