Package com.snowflake.connectors.application.scheduler

Class InMemoryDefaultSchedulerManager

java.lang.Object

com.snowflake.connectors.application.scheduler.InMemoryDefaultSchedulerManager

All Implemented Interfaces:

com.snowflake.connectors.application.scheduler.SchedulerManager

public class InMemoryDefaultSchedulerManager
extends Object

InMemory implementation of SchedulerManager.

Constructor Summary

Constructors

Constructor	Description
InMemoryDefaultSchedulerManager(com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationService connectorConfigurationService, com.snowflake.connectors.common.task.TaskRepository taskRepository, com.snowflake.connectors.common.task.TaskLister taskLister)	Creates a new InMemoryDefaultSchedulerManager.

Method Summary

Modifier and Type	Method	Description
void	alterSchedulerSchedule(String arg0)
com.snowflake.connectors.common.response.ConnectorResponse	createScheduler()
com.snowflake.connectors.common.response.ConnectorResponse	pauseScheduler()
com.snowflake.connectors.common.response.ConnectorResponse	resumeScheduler()
boolean	schedulerExists()

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryDefaultSchedulerManager

public InMemoryDefaultSchedulerManager(com.snowflake.connectors.application.configuration.connector.ConnectorConfigurationService connectorConfigurationService,
                                       com.snowflake.connectors.common.task.TaskRepository taskRepository,
                                       com.snowflake.connectors.common.task.TaskLister taskLister)

Creates a new InMemoryDefaultSchedulerManager.

Parameters:

connectorConfigurationService - connector configuration service

taskRepository - task repository

taskLister - task lister

Method Detail

createScheduler

public com.snowflake.connectors.common.response.ConnectorResponse createScheduler()

Specified by:

createScheduler in interface com.snowflake.connectors.application.scheduler.SchedulerManager

resumeScheduler

public com.snowflake.connectors.common.response.ConnectorResponse resumeScheduler()

Specified by:

resumeScheduler in interface com.snowflake.connectors.application.scheduler.SchedulerManager

pauseScheduler

public com.snowflake.connectors.common.response.ConnectorResponse pauseScheduler()

Specified by:

pauseScheduler in interface com.snowflake.connectors.application.scheduler.SchedulerManager

schedulerExists

public boolean schedulerExists()

Specified by:

schedulerExists in interface com.snowflake.connectors.application.scheduler.SchedulerManager

alterSchedulerSchedule

public void alterSchedulerSchedule(String arg0)

Specified by:

alterSchedulerSchedule in interface com.snowflake.connectors.application.scheduler.SchedulerManager