Package com.snowflake.connectors.taskreactor.registry

Interface InstanceRegistryRepository

  • public interface InstanceRegistryRepository
    Repository for managing TASK_REACTOR.INSTANCE_REGISTRY table

    • Method Detail

      • fetchAll

        List<TaskReactorInstance> fetchAll()
        Fetches all Task Reactor instances registered in the connector
        Returns:
        list of instances

      • fetchAllInitialized

        List<TaskReactorInstance> fetchAllInitialized()
        Fetches all initialized Task Reactor instances registered in the connector
        Returns:
        list of instances

      • fetch

        TaskReactorInstance fetch​(Identifier instanceId)
        Fetches a Task Reactor instance with given identifier
        Parameters:
        instanceId - id of an instance
        Returns:
        instance object when an instance with given id exists, otherwise null

      • setInactive

        void setInactive​(Identifier instanceId)
        Changes isActive flag to false for given instance
        Parameters:
        instanceId - id of an instance

      • setActive

        void setActive​(Identifier instanceId)
        Changes isActive flag to true for given instance
        Parameters:
        instanceId - id of an instance