Index (Test utilities for Snowflake Native SDK for Connectors

A B C D E F G H I N O P R S T U V W
All Classes All Packages

A

add(Command.CommandType, Variant) - Method in class com.snowflake.connectors.taskreactor.commands.queue.InMemoryCommandsQueueRepository
addDatabases(String...) - Method in class com.snowflake.connectors.util.snowflake.InMemoryAccessTools: Adds databases to local store.
addExecutingWorkers(List<WorkerId>) - Method in class com.snowflake.connectors.taskreactor.worker.InMemoryWorkerCombinedView: Adds new executing workers.
addIdentifiers(List<String>) - Method in class com.snowflake.connectors.taskreactor.queue.cleaner.InMemoryExpiredWorkSelector: Adds new queue item ids for selection.
addInstance(Identifier, boolean) - Method in class com.snowflake.connectors.taskreactor.registry.InMemoryInstanceRegistryRepository: Adds a new Task Reactor instance.
addInstance(Identifier, boolean, boolean) - Method in class com.snowflake.connectors.taskreactor.registry.InMemoryInstanceRegistryRepository: Adds a new Task Reactor instance.
addItems(List<QueueItem>) - Method in class com.snowflake.connectors.taskreactor.queue.selector.InMemoryWorkSelector: Adds new queue items for selection.
addSchemasInDatabase(String, String...) - Method in class com.snowflake.connectors.util.snowflake.InMemoryAccessTools: Adds schemas to in memory store.
addSecrets(String...) - Method in class com.snowflake.connectors.util.snowflake.InMemoryAccessTools: Adds secrets to in memory store.
addWarehouses(String...) - Method in class com.snowflake.connectors.util.snowflake.InMemoryAccessTools: Adds warehouse to local store.
alterSchedule(String) - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
alterScheduleIfExists(String) - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
alterWarehouse(String) - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
alterWarehouseIfExists(String) - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
assertThat(ResourceIngestionDefinition<?, ?, ?, ?>) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified ResourceIngestionDefinition.
assertThat(IngestionProcess) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified IngestionProcess.
assertThat(IngestionRun) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified IngestionRun.
assertThat(FullConnectorStatus) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified FullConnectorStatus.
assertThat(TestState) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified TestState.
assertThat(TestConfig) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified TestConfig.
assertThat(Identifier) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified Identifier.
assertThat(ObjectName) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified ObjectName.
assertThat(Reference) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified Reference.
assertThat(SchemaName) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified SchemaName.
assertThat(ConnectorResponse) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified ConnectorResponse.
assertThat(TaskProperties) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified TaskProperties.
assertThat(Command) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified Command.
assertThat(Variant) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified Variant.
assertThatResponseMap(Map<String, Variant>) - Static method in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Creates a new assertion for the specified map representing a variant response.

B

build() - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerTestBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerTestBuilder
build() - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerTestBuilder: Builds a new handler instance.
build() - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Builds a new handler instance.

C

cancelOngoingExecutions(List<String>) - Method in class com.snowflake.connectors.taskreactor.queue.InMemoryWorkItemQueue
checkIfExists() - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
clear() - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository: Clears the repository.
clear() - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository: Clears the repository.
clear() - Method in class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
clear() - Method in class com.snowflake.connectors.taskreactor.config.InMemoryConfigRepository: Clears this repository.
clear() - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskManagement
clear() - Method in class com.snowflake.connectors.taskreactor.queue.cleaner.InMemoryExpiredWorkSelector: Clears this selector.
clear() - Method in class com.snowflake.connectors.taskreactor.queue.InMemoryWorkItemQueue: Clears this queue.
clear() - Method in class com.snowflake.connectors.taskreactor.queue.selector.InMemoryWorkSelector: Clears this selector.
clear() - Method in class com.snowflake.connectors.taskreactor.registry.InMemoryInstanceRegistryRepository: Clears this repository.
clear() - Method in class com.snowflake.connectors.taskreactor.worker.InMemoryWorkerCombinedView: Clears the list of executing workers.
clear() - Method in class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueue: Clears this queue.
clear() - Method in class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueueManager: Clears the set of queues in this manager.
clear() - Method in class com.snowflake.connectors.taskreactor.worker.registry.InMemoryWorkerRegistry: Clears this registry.
clear() - Method in class com.snowflake.connectors.taskreactor.worker.status.InMemoryWorkerStatusRepository: Clears this repository.
com.snowflake.connectors - package com.snowflake.connectors
com.snowflake.connectors.application.configuration.connection - package com.snowflake.connectors.application.configuration.connection
com.snowflake.connectors.application.configuration.connector - package com.snowflake.connectors.application.configuration.connector
com.snowflake.connectors.application.configuration.finalization - package com.snowflake.connectors.application.configuration.finalization
com.snowflake.connectors.application.configuration.warehouse - package com.snowflake.connectors.application.configuration.warehouse
com.snowflake.connectors.application.ingestion.create - package com.snowflake.connectors.application.ingestion.create
com.snowflake.connectors.application.ingestion.definition - package com.snowflake.connectors.application.ingestion.definition
com.snowflake.connectors.application.ingestion.disable - package com.snowflake.connectors.application.ingestion.disable
com.snowflake.connectors.application.ingestion.enable - package com.snowflake.connectors.application.ingestion.enable
com.snowflake.connectors.application.ingestion.process - package com.snowflake.connectors.application.ingestion.process
com.snowflake.connectors.application.ingestion.update - package com.snowflake.connectors.application.ingestion.update
com.snowflake.connectors.application.lifecycle.pause - package com.snowflake.connectors.application.lifecycle.pause
com.snowflake.connectors.application.lifecycle.resume - package com.snowflake.connectors.application.lifecycle.resume
com.snowflake.connectors.application.scheduler - package com.snowflake.connectors.application.scheduler
com.snowflake.connectors.application.status - package com.snowflake.connectors.application.status
com.snowflake.connectors.common - package com.snowflake.connectors.common
com.snowflake.connectors.common.application.operations.configuration - package com.snowflake.connectors.common.application.operations.configuration
com.snowflake.connectors.common.assertions - package com.snowflake.connectors.common.assertions
com.snowflake.connectors.common.assertions.application.status - package com.snowflake.connectors.common.assertions.application.status
com.snowflake.connectors.common.assertions.common - package com.snowflake.connectors.common.assertions.common
com.snowflake.connectors.common.assertions.common.object - package com.snowflake.connectors.common.assertions.common.object
com.snowflake.connectors.common.assertions.common.response - package com.snowflake.connectors.common.assertions.common.response
com.snowflake.connectors.common.assertions.common.state - package com.snowflake.connectors.common.assertions.common.state
com.snowflake.connectors.common.assertions.configurationRepository - package com.snowflake.connectors.common.assertions.configurationRepository
com.snowflake.connectors.common.assertions.ingestion - package com.snowflake.connectors.common.assertions.ingestion
com.snowflake.connectors.common.assertions.ingestion.definition - package com.snowflake.connectors.common.assertions.ingestion.definition
com.snowflake.connectors.common.assertions.task - package com.snowflake.connectors.common.assertions.task
com.snowflake.connectors.common.exception - package com.snowflake.connectors.common.exception
com.snowflake.connectors.common.snowflake - package com.snowflake.connectors.common.snowflake
com.snowflake.connectors.common.table - package com.snowflake.connectors.common.table
com.snowflake.connectors.common.task - package com.snowflake.connectors.common.task
com.snowflake.connectors.taskreactor - package com.snowflake.connectors.taskreactor
com.snowflake.connectors.taskreactor.commands.queue - package com.snowflake.connectors.taskreactor.commands.queue
com.snowflake.connectors.taskreactor.config - package com.snowflake.connectors.taskreactor.config
com.snowflake.connectors.taskreactor.dispatcher - package com.snowflake.connectors.taskreactor.dispatcher
com.snowflake.connectors.taskreactor.queue - package com.snowflake.connectors.taskreactor.queue
com.snowflake.connectors.taskreactor.queue.cleaner - package com.snowflake.connectors.taskreactor.queue.cleaner
com.snowflake.connectors.taskreactor.queue.selector - package com.snowflake.connectors.taskreactor.queue.selector
com.snowflake.connectors.taskreactor.registry - package com.snowflake.connectors.taskreactor.registry
com.snowflake.connectors.taskreactor.worker - package com.snowflake.connectors.taskreactor.worker
com.snowflake.connectors.taskreactor.worker.queue - package com.snowflake.connectors.taskreactor.worker.queue
com.snowflake.connectors.taskreactor.worker.registry - package com.snowflake.connectors.taskreactor.worker.registry
com.snowflake.connectors.taskreactor.worker.status - package com.snowflake.connectors.taskreactor.worker.status
com.snowflake.connectors.util.snowflake - package com.snowflake.connectors.util.snowflake
COMMAND - Static variable in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Definition of InstanceOfAssertFactory for Command assertion classes.
CommandAssert - Class in com.snowflake.connectors.common.assertions.task: AssertJ based assertions for Command.
CommandAssert(Command, Class<?>) - Constructor for class com.snowflake.connectors.common.assertions.task.CommandAssert
commandsQueueRepositories() - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskReactorInstanceComponentProvider: Returns the commands queue repositories.
commandsQueueRepository(Identifier) - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskReactorInstanceComponentProvider
compare(FakeKeyValue, FakeKeyValue) - Method in class com.snowflake.connectors.common.table.FakeKeyValue.FakeKeyValueComparator
ConfigureConnectorHandlerTestBuilder - Class in com.snowflake.connectors.application.configuration.connector: Test builder for the ConfigureConnectorHandler.
ConfigureConnectorHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerTestBuilder: Creates a new, empty ConfigureConnectorHandlerTestBuilder.
ConfigureConnectorHandlerTestBuilder(Session) - Constructor for class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerTestBuilder: Creates a new ConfigureConnectorHandlerTestBuilder.
configureSnowsqlInDocker() - Static method in class com.snowflake.connectors.SnowsqlConfigurer
ConnectionConfigurationHandlerTestBuilder - Class in com.snowflake.connectors.application.configuration.connection: Test builder for the ConnectionConfigurationHandler.
ConnectionConfigurationHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerTestBuilder: Creates a new, empty ConnectionConfigurationHandlerTestBuilder.
ConnectorConfiguration - Class in com.snowflake.connectors.common.application.operations.configuration: A base class for performing operations on connector configuration view.
ConnectorConfiguration() - Constructor for class com.snowflake.connectors.common.application.operations.configuration.ConnectorConfiguration
ConnectorResponseAssert - Class in com.snowflake.connectors.common.assertions.common.response: AssertJ based assertions for ConnectorResponse.
ConnectorResponseAssert(ConnectorResponse, Class<ConnectorResponseAssert>) - Constructor for class com.snowflake.connectors.common.assertions.common.response.ConnectorResponseAssert
countEnabled() - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository
create(TaskDefinition, boolean, boolean) - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskManagement
createProcess(String, String, String, String, Variant) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
CreateResourceHandlerTestBuilder - Class in com.snowflake.connectors.application.ingestion.create: Test builder for the CreateResourceHandler.
CreateResourceHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerTestBuilder: Creates a new, empty CreateResourceHandlerTestBuilder.
CreateResourceHandlerTestBuilder(Session) - Constructor for class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerTestBuilder: Creates a new CreateResourceHandlerTestBuilder.
CreateSchedulerHandlerTestBuilder - Class in com.snowflake.connectors.application.scheduler: Test builder for the CreateResourceHandler.
CreateSchedulerHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerTestBuilder: Creates a new, empty CreateSchedulerHandlerTestBuilder.
CreateSchedulerHandlerTestBuilder(Session) - Constructor for class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerTestBuilder: Creates a new CreateSchedulerHandlerTestBuilder.
createWorkerQueueIfNotExist(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueueManager

D

delete(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueue
delete(String) - Method in class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
delete(String) - Method in class com.snowflake.connectors.common.table.InMemoryReadOnlyKeyValueTable
delete(List<String>) - Method in class com.snowflake.connectors.taskreactor.queue.InMemoryWorkItemQueue
deleteBefore(String, Timestamp) - Method in class com.snowflake.connectors.taskreactor.queue.InMemoryWorkItemQueue
deleteById(String) - Method in class com.snowflake.connectors.taskreactor.commands.queue.InMemoryCommandsQueueRepository
deleteUnsupportedCommands() - Method in class com.snowflake.connectors.taskreactor.commands.queue.InMemoryCommandsQueueRepository
DisableResourceHandlerTestBuilder - Class in com.snowflake.connectors.application.ingestion.disable: Test builder for the DisableResourceHandler.
DisableResourceHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerTestBuilder: Creates a new, empty DisableResourceHandlerTestBuilder.
DisableResourceHandlerTestBuilder(Session) - Constructor for class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerTestBuilder: Creates a new DisableResourceHandlerTestBuilder.
dispatcherTaskManager(Identifier) - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskReactorInstanceComponentProvider
drop() - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
dropIfExists() - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
dropWorkerQueue(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueueManager

E

EnableResourceHandlerTestBuilder - Class in com.snowflake.connectors.application.ingestion.enable: Test builder for the EnableResourceHandler.
EnableResourceHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerTestBuilder: Creates a new, empty EnableResourceHandlerTestBuilder.
EnableResourceHandlerTestBuilder(Session) - Constructor for class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerTestBuilder: Creates a new EnableResourceHandlerTestBuilder.
endProcess(String) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
endProcess(String, String, String) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
execute() - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef

F

FakeKeyValue - Class in com.snowflake.connectors.common.table: Fake, testing implementation of a KeyValueTable entry.
FakeKeyValue(Variant, Instant) - Constructor for class com.snowflake.connectors.common.table.FakeKeyValue
FakeKeyValue.FakeKeyValueComparator - Class in com.snowflake.connectors.common.table
FakeKeyValueComparator() - Constructor for class com.snowflake.connectors.common.table.FakeKeyValue.FakeKeyValueComparator
fetch() - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
fetch(Identifier) - Method in class com.snowflake.connectors.taskreactor.registry.InMemoryInstanceRegistryRepository
fetch(ObjectName) - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskManagement
fetch(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueue
fetch(String) - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository
fetch(String) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
fetch(String) - Method in class com.snowflake.connectors.common.table.InMemoryAppendOnlyKeyValueTable
fetch(String) - Method in class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
fetch(String) - Method in class com.snowflake.connectors.common.table.InMemoryReadOnlyKeyValueTable
fetchAll() - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository
fetchAll() - Method in class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
fetchAll() - Method in class com.snowflake.connectors.common.table.InMemoryReadOnlyKeyValueTable
fetchAll() - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskManagement
fetchAll() - Method in class com.snowflake.connectors.taskreactor.registry.InMemoryInstanceRegistryRepository
fetchAll(String) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
fetchAll(String, String, String) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
fetchAll(List<String>) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
fetchAllActive(String) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
fetchAllById(List<String>) - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository
fetchAllEnabled() - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository
fetchAllInitialized() - Method in class com.snowflake.connectors.taskreactor.registry.InMemoryInstanceRegistryRepository
fetchAllSupportedOrderedBySeqNo() - Method in class com.snowflake.connectors.taskreactor.commands.queue.InMemoryCommandsQueueRepository
fetchAllWhere(Column) - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository
fetchByResourceId(Object) - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository
fetchLastFinished(String, String, String) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
fetchNotProcessedAndCancelingItems() - Method in class com.snowflake.connectors.taskreactor.queue.InMemoryWorkItemQueue
FinalizeConnectorHandlerTestBuilder - Class in com.snowflake.connectors.application.configuration.finalization: Test builder for the FinalizeConnectorHandler.
FinalizeConnectorHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerTestBuilder: Creates a new, empty FinalizeConnectorHandlerTestBuilder.
FinalizeConnectorHandlerTestBuilder(Session) - Constructor for class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerTestBuilder: Creates a new FinalizeConnectorHandlerTestBuilder.
FullConnectorStatusAssert - Class in com.snowflake.connectors.common.assertions.application.status: AssertJ based assertions for FullConnectorStatus.
FullConnectorStatusAssert(FullConnectorStatus, Class<FullConnectorStatusAssert>) - Constructor for class com.snowflake.connectors.common.assertions.application.status.FullConnectorStatusAssert

G

getAlertsConfiguration(Session) - Static method in class com.snowflake.connectors.common.application.operations.configuration.ConnectorConfiguration: Get the set values for the alerts configurations group.
getAllWhere(Column) - Method in class com.snowflake.connectors.common.table.InMemoryAppendOnlyKeyValueTable
getAllWhere(Column) - Method in class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
getAllWhere(Column) - Method in class com.snowflake.connectors.common.table.InMemoryReadOnlyKeyValueTable
getAvailableWorkers() - Method in class com.snowflake.connectors.taskreactor.worker.status.InMemoryWorkerStatusRepository
getConfig() - Method in class com.snowflake.connectors.taskreactor.config.InMemoryConfigRepository
getExpired(String) - Method in class com.snowflake.connectors.taskreactor.queue.cleaner.InMemoryExpiredWorkSelector
getFlag() - Method in class com.snowflake.connectors.common.assertions.common.state.TestState
getFlag() - Method in class com.snowflake.connectors.common.assertions.configurationRepository.TestConfig
getInstance(Identifier, TaskRepository) - Static method in class com.snowflake.connectors.taskreactor.dispatcher.InMemoryDispatcherTaskProvider: Creates a new DispatcherTaskManager.
getInstance(Identifier, TaskRepository) - Static method in class com.snowflake.connectors.taskreactor.worker.InMemoryWorkerTaskManagerProvider: Creates a new in memory instance of WorkerTaskManager.
getIntConfig() - Method in class com.snowflake.connectors.common.assertions.configurationRepository.TestConfig
getIntState() - Method in class com.snowflake.connectors.common.assertions.common.state.TestState
getLastAvailable(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.status.InMemoryWorkerStatusRepository
getRepository() - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository: Returns repository.
getRepository() - Method in class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
getStatusFor(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.status.InMemoryWorkerStatusRepository
getStringConfig() - Method in class com.snowflake.connectors.common.assertions.configurationRepository.TestConfig
getStringState() - Method in class com.snowflake.connectors.common.assertions.common.state.TestState
getTimestamp() - Method in class com.snowflake.connectors.common.table.FakeKeyValue
getUpdatedAt() - Method in class com.snowflake.connectors.common.table.FakeKeyValue
getValue() - Method in class com.snowflake.connectors.common.table.FakeKeyValue
getWorkerCountWithStatuses(WorkerLifecycleStatus...) - Method in class com.snowflake.connectors.taskreactor.worker.registry.InMemoryWorkerRegistry
getWorkerIds(WorkerLifecycleStatus...) - Method in class com.snowflake.connectors.taskreactor.worker.registry.InMemoryWorkerRegistry
getWorkersExecuting(String) - Method in class com.snowflake.connectors.taskreactor.worker.InMemoryWorkerCombinedView
getWorkersExecuting(List<String>) - Method in class com.snowflake.connectors.taskreactor.worker.InMemoryWorkerCombinedView
grantMonitorPrivilegeToRole(String) - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef

H

hasAdditionalPayload(String, String) - Method in class com.snowflake.connectors.common.assertions.common.response.ConnectorResponseAssert: Asserts that this connector response contains additional payload with name.
hasAllowOverlappingExecution(boolean) - Method in class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert: Asserts that these task properties have an overlapping execution allowance equal to the specified value.
hasCommandType(Command.CommandType) - Method in class com.snowflake.connectors.common.assertions.task.CommandAssert: Asserts that this command have a commandType equal to the specified value.
hasCompletedAt(Instant) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has a completedAt timestamp equal to the specified value.
hasCompletedAtBetween(Instant, Instant) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has a completedAt timestamp between to the specified values.
hasCondition(String) - Method in class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert: Asserts that these task properties have a condition equal to the specified value.
hasCreatedAt(Instant) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionProcessAssert: Asserts that this ingestion process has a createdAt timestamp equal to the specified value.
hasDatabaseAccess(Identifier) - Method in class com.snowflake.connectors.util.snowflake.InMemoryAccessTools
hasDatabaseValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.ObjectNameAssert: Asserts that this object name has a database value equal to the specified value.
hasDatabaseValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.SchemaNameAssert: Asserts that this schema name has a database value equal to the specified value.
hasDefinition(String) - Method in class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert: Asserts that these task properties have a definition equal to the specified value.
hasField(String, String) - Method in class com.snowflake.connectors.common.assertions.common.response.ResponseMapAssert: Asserts that this response has a json field with the specified value
hasFinishedAt(Instant) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionProcessAssert: Asserts that this ingestion process has a finishedAt timestamp equal to the specified value.
hasFinishedAtNull(boolean) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionProcessAssert: Asserts that null-check result for finishedAt timestamp of this ingestion process is equal to the specified value.
hasFlag(boolean) - Method in class com.snowflake.connectors.common.assertions.common.state.TestStateAssert: Asserts that this state has a flag equal to the specified value.
hasFlag(boolean) - Method in class com.snowflake.connectors.common.assertions.configurationRepository.TestConfigAssert: Asserts that this config has a flag equal to the specified value.
hashCode() - Method in class com.snowflake.connectors.common.assertions.configurationRepository.TestConfig
hasId(String) - Method in class com.snowflake.connectors.common.assertions.common.response.ResponseMapAssert: Asserts that this response has a value of id field equal to the specified value.
hasId(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.definition.ResourceIngestionDefinitionAssert: Asserts that this resource ingestion definition has an id equal to the specified value.
hasId(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionProcessAssert: Asserts that this ingestion process has an id equal to the specified value.
hasId(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has an id equal to the specified value.
hasId(String) - Method in class com.snowflake.connectors.common.assertions.task.CommandAssert: Asserts that this command have an id equal to the specified value.
hasIngestedRows(long) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has a number of ingested rows equal to the specified value.
hasIngestionConfigurationId(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionProcessAssert: Asserts that this ingestion process has an ingestion configuration id equal to the specified value.
hasIngestionConfigurationId(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has an ingestion configuration id equal to the specified value.
hasIngestionConfigurations(List<IngestionConfiguration<Variant, Variant>>) - Method in class com.snowflake.connectors.common.assertions.ingestion.definition.ResourceIngestionDefinitionAssert: Asserts that this resource ingestion definition has ingestion configurations equal to the specified value.
hasIngestionDefinitionId(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has a resource ingestion definition id equal to the specified value.
hasIngestionProcessId(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has an ingestion process id equal to the specified value.
hasIntConfig(int) - Method in class com.snowflake.connectors.common.assertions.configurationRepository.TestConfigAssert: Asserts that this config has an int config equal to the specified value.
hasIntState(int) - Method in class com.snowflake.connectors.common.assertions.common.state.TestStateAssert: Asserts that this state has an int state equal to the specified value.
hasMessage(String) - Method in class com.snowflake.connectors.common.assertions.common.response.ConnectorResponseAssert: Asserts that this connector response has a message equal to the specified value.
hasMessage(String) - Method in class com.snowflake.connectors.common.assertions.common.response.ResponseMapAssert: Asserts that this response has a value of message field equal to the specified value.
hasMessageContaining(String) - Method in class com.snowflake.connectors.common.assertions.common.response.ResponseMapAssert: Asserts that this response has a value of message field containing the specified value.
hasMetadata(Variant) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionProcessAssert: Asserts that this ingestion process has a metadata equal to the specified value.
hasMetadata(Variant) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has a metadata equal to the specified value.
hasName(String) - Method in class com.snowflake.connectors.common.assertions.common.object.ReferenceAssert: Asserts that this reference has a name equal to the specified value.
hasName(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.definition.ResourceIngestionDefinitionAssert: Asserts that this resource ingestion definition has a name equal to the specified value.
hasNameValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.ObjectNameAssert: Asserts that this object name has a name value equal to the specified value.
hasObjectName(ObjectName) - Method in class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert: Asserts that these task properties have a task name equal to the specified value.
hasOKResponseCode() - Method in class com.snowflake.connectors.common.assertions.common.response.ConnectorResponseAssert: Asserts that this connector response has a response code equal to OK.
hasOKResponseCode() - Method in class com.snowflake.connectors.common.assertions.common.response.ResponseMapAssert: Asserts that this response has a value of responseCode field equal to OK.
hasPayload(Variant) - Method in class com.snowflake.connectors.common.assertions.task.CommandAssert: Asserts that this command have a payload equal to the specified value.
hasQuotedValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.IdentifierAssert: Asserts that this identifier has a quoted value equal to the specified value.
hasResourceId(Variant) - Method in class com.snowflake.connectors.common.assertions.ingestion.definition.ResourceIngestionDefinitionAssert: Asserts that this resource ingestion definition has a resource id equal to the specified value.
hasResourceIngestionDefinitionId(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionProcessAssert: Asserts that this ingestion process has a resource ingestion definition id equal to the specified value.
hasResourceMetadata(Variant) - Method in class com.snowflake.connectors.common.assertions.ingestion.definition.ResourceIngestionDefinitionAssert: Asserts that this resource ingestion definition has a resource metadata equal to the specified value.
hasResponseCode(String) - Method in class com.snowflake.connectors.common.assertions.common.response.ConnectorResponseAssert: Asserts that this connector response has a response code equal to the specified value.
hasResponseCode(String) - Method in class com.snowflake.connectors.common.assertions.common.response.ResponseMapAssert
hasSchedule(String) - Method in class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert: Asserts that these task properties have a schedule equal to the specified value.
hasSchemaAccess(SchemaName) - Method in class com.snowflake.connectors.util.snowflake.InMemoryAccessTools
hasSchemaNameValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.ObjectNameAssert: Asserts that this object name has a schema name value equal to the specified value.
hasSchemaValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.ObjectNameAssert: Asserts that this object name has a schema value equal to the specified value.
hasSchemaValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.SchemaNameAssert: Asserts that this schema name has a schema value equal to the specified value.
hasSecretAccess(ObjectName) - Method in class com.snowflake.connectors.util.snowflake.InMemoryAccessTools
hasSeqNo(long) - Method in class com.snowflake.connectors.common.assertions.task.CommandAssert: Asserts that this command have an seqNo equal to the specified value.
hasStartedAt(Instant) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has a startedAt timestamp equal to the specified value.
hasStartedAtBetween(Instant, Instant) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has a StartedAt timestamp between to the specified values.
hasState(String) - Method in class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert: Asserts that these task properties have a state equal to the specified value.
hasStatus(IngestionRun.IngestionStatus) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has an ingestion status equal to the specified value.
hasStatus(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionProcessAssert: Asserts that this ingestion process has a status equal to the specified value.
hasStringConfig(String) - Method in class com.snowflake.connectors.common.assertions.configurationRepository.TestConfigAssert: Asserts that this config has a string config equal to the specified value.
hasStringState(String) - Method in class com.snowflake.connectors.common.assertions.common.state.TestStateAssert: Asserts that this state has a string state equal to the specified value.
hasSuspendTaskAfterNumFailures(Integer) - Method in class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert: Asserts that these task properties have a suspension after failures num equal to the specified value.
hasType(String) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionProcessAssert: Asserts that this ingestion process has a type equal to the specified value.
hasUnquotedValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.IdentifierAssert: Asserts that this identifier has an unquoted value equal to the specified value.
hasUpdatedAt(Instant) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has an updatedAt timestamp equal to the specified value.
hasUpdatedAtBetween(Instant, Instant) - Method in class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert: Asserts that this ingestion run has a updatedAt timestamp between to the specified values.
hasValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.IdentifierAssert: Asserts that this identifier has a value equal to the specified value.
hasValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.ObjectNameAssert: Asserts that this object name has a value equal to the specified value.
hasValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.ReferenceAssert: Asserts that this reference has a value equal to the specified value.
hasValue(String) - Method in class com.snowflake.connectors.common.assertions.common.object.SchemaNameAssert: Asserts that this schema name has a value equal to the specified value.
hasWarehouse(String) - Method in class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert: Asserts that these task properties have a warehouse equal to the specified value.
hasWarehouseAccess(Identifier) - Method in class com.snowflake.connectors.util.snowflake.InMemoryAccessTools

I

IDENTIFIER - Static variable in class com.snowflake.connectors.common.assertions.NativeSdkAssertions
IdentifierAssert - Class in com.snowflake.connectors.common.assertions.common.object: AssertJ based assertions for Identifier.
IdentifierAssert(Identifier, Class<IdentifierAssert>) - Constructor for class com.snowflake.connectors.common.assertions.common.object.IdentifierAssert
IdGenerator - Class in com.snowflake.connectors.common: Random UUID generator.
IdGenerator() - Constructor for class com.snowflake.connectors.common.IdGenerator
INGESTION_PROCESS - Static variable in class com.snowflake.connectors.common.assertions.NativeSdkAssertions
IngestionProcessAssert - Class in com.snowflake.connectors.common.assertions.ingestion: AssertJ based assertions for IngestionProcess.
IngestionProcessAssert(IngestionProcess, Class<IngestionProcessAssert>) - Constructor for class com.snowflake.connectors.common.assertions.ingestion.IngestionProcessAssert
IngestionRunAssert - Class in com.snowflake.connectors.common.assertions.ingestion: AssertJ based assertions for IngestionRun.
IngestionRunAssert(IngestionRun, Class<IngestionRunAssert>) - Constructor for class com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert
InMemoryAccessTools - Class in com.snowflake.connectors.util.snowflake: In memory implementation of AccessTools.
InMemoryAccessTools() - Constructor for class com.snowflake.connectors.util.snowflake.InMemoryAccessTools
InMemoryAppendOnlyKeyValueTable - Class in com.snowflake.connectors.common.table: In memory implementation of AppendOnlyTable.
InMemoryAppendOnlyKeyValueTable() - Constructor for class com.snowflake.connectors.common.table.InMemoryAppendOnlyKeyValueTable
InMemoryCommandsQueueRepository - Class in com.snowflake.connectors.taskreactor.commands.queue: In memory implementation of CommandsQueueRepository.
InMemoryCommandsQueueRepository() - Constructor for class com.snowflake.connectors.taskreactor.commands.queue.InMemoryCommandsQueueRepository
InMemoryConfigRepository - Class in com.snowflake.connectors.taskreactor.config: In memory implementation of ConfigRepository.
InMemoryConfigRepository() - Constructor for class com.snowflake.connectors.taskreactor.config.InMemoryConfigRepository
InMemoryConnectorConfigurationService - Class in com.snowflake.connectors.application.configuration.connector: InMemory implementation of ConnectorConfigurationService.
InMemoryConnectorConfigurationService(ConfigurationRepository) - Constructor for class com.snowflake.connectors.application.configuration.connector.InMemoryConnectorConfigurationService
InMemoryConnectorErrorHelper - Class in com.snowflake.connectors.common.exception: In memory implementation of ConnectorErrorHelper.
InMemoryConnectorErrorHelper() - Constructor for class com.snowflake.connectors.common.exception.InMemoryConnectorErrorHelper
InMemoryConnectorStatusRepository - Class in com.snowflake.connectors.application.status: InMemory implementation of ConnectorStatusRepository.
InMemoryConnectorStatusRepository(KeyValueStateRepository<FullConnectorStatus>) - Constructor for class com.snowflake.connectors.application.status.InMemoryConnectorStatusRepository
InMemoryDefaultKeyValueTable - Class in com.snowflake.connectors.common.table: In memory implementation of KeyValueTable.
InMemoryDefaultKeyValueTable() - Constructor for class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
InMemoryDefaultSchedulerCreator - Class in com.snowflake.connectors.application.scheduler: InMemory implementation of SchedulerCreator.
InMemoryDefaultSchedulerCreator(ConnectorConfigurationService, TaskRepository, TaskLister) - Constructor for class com.snowflake.connectors.application.scheduler.InMemoryDefaultSchedulerCreator
InMemoryDispatcherTaskProvider - Class in com.snowflake.connectors.taskreactor.dispatcher: In memory provider of DispatcherTaskManager instances.
InMemoryDispatcherTaskProvider() - Constructor for class com.snowflake.connectors.taskreactor.dispatcher.InMemoryDispatcherTaskProvider
InMemoryExpiredWorkSelector - Class in com.snowflake.connectors.taskreactor.queue.cleaner: In memory implementation of ExpiredWorkSelector.
InMemoryExpiredWorkSelector() - Constructor for class com.snowflake.connectors.taskreactor.queue.cleaner.InMemoryExpiredWorkSelector
InMemoryIngestionProcessRepository - Class in com.snowflake.connectors.application.ingestion.process: In memory implementation of IngestionProcessRepository and CrudIngestionProcessRepository
InMemoryIngestionProcessRepository() - Constructor for class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
InMemoryInstanceRegistryRepository - Class in com.snowflake.connectors.taskreactor.registry: In memory implementation of InstanceRegistryRepository.
InMemoryInstanceRegistryRepository() - Constructor for class com.snowflake.connectors.taskreactor.registry.InMemoryInstanceRegistryRepository
InMemoryReadOnlyKeyValueTable - Class in com.snowflake.connectors.common.table: In memory, read-only implementation of KeyValueTable.
InMemoryReadOnlyKeyValueTable(Map<String, Variant>) - Constructor for class com.snowflake.connectors.common.table.InMemoryReadOnlyKeyValueTable
InMemoryResourceIngestionDefinitionRepository<R extends com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinition<?,?,?,?>> - Class in com.snowflake.connectors.application.ingestion.definition: In memory implementation of ResourceIngestionDefinitionRepository
InMemoryResourceIngestionDefinitionRepository() - Constructor for class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository: Creates a new InMemoryResourceIngestionDefinitionRepository, backed by a hashmap.
InMemoryTaskManagement - Class in com.snowflake.connectors.taskreactor: In memory implementation of TaskRepository and TaskLister.
InMemoryTaskManagement() - Constructor for class com.snowflake.connectors.taskreactor.InMemoryTaskManagement
InMemoryTaskReactorInstanceComponentProvider - Class in com.snowflake.connectors.taskreactor: In memory implementation of TaskReactorInstanceComponentProvider.
InMemoryTaskReactorInstanceComponentProvider() - Constructor for class com.snowflake.connectors.taskreactor.InMemoryTaskReactorInstanceComponentProvider
InMemoryTaskReactorInstanceComponentProvider(Map<Identifier, InMemoryCommandsQueueRepository>, TaskRepository) - Constructor for class com.snowflake.connectors.taskreactor.InMemoryTaskReactorInstanceComponentProvider
InMemoryTaskRef - Class in com.snowflake.connectors.common.task: In memory implementation of TaskRef.
InMemoryTaskRef(ObjectName, Map<ObjectName, TaskProperties>) - Constructor for class com.snowflake.connectors.common.task.InMemoryTaskRef
InMemoryTransactionManager - Class in com.snowflake.connectors.util.snowflake: In memory implementation of TransactionManager
InMemoryTransactionManager() - Constructor for class com.snowflake.connectors.util.snowflake.InMemoryTransactionManager
InMemoryWorkerCombinedView - Class in com.snowflake.connectors.taskreactor.worker: In memory implementation of WorkerCombinedView.
InMemoryWorkerCombinedView() - Constructor for class com.snowflake.connectors.taskreactor.worker.InMemoryWorkerCombinedView
InMemoryWorkerQueue - Class in com.snowflake.connectors.taskreactor.worker.queue: In memory implementation of WorkerQueue.
InMemoryWorkerQueue() - Constructor for class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueue
InMemoryWorkerQueueManager - Class in com.snowflake.connectors.taskreactor.worker.queue: In memory implementation of WorkerQueueManager.
InMemoryWorkerQueueManager() - Constructor for class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueueManager
InMemoryWorkerRegistry - Class in com.snowflake.connectors.taskreactor.worker.registry: In memory implementation of WorkerRegistry.
InMemoryWorkerRegistry() - Constructor for class com.snowflake.connectors.taskreactor.worker.registry.InMemoryWorkerRegistry
InMemoryWorkerStatusRepository - Class in com.snowflake.connectors.taskreactor.worker.status: In memory implementation of WorkerStatusRepository.
InMemoryWorkerStatusRepository() - Constructor for class com.snowflake.connectors.taskreactor.worker.status.InMemoryWorkerStatusRepository
InMemoryWorkerTaskManagerProvider - Class in com.snowflake.connectors.taskreactor.worker: In memory provider of WorkerTaskManager instances.
InMemoryWorkerTaskManagerProvider() - Constructor for class com.snowflake.connectors.taskreactor.worker.InMemoryWorkerTaskManagerProvider
InMemoryWorkItemQueue - Class in com.snowflake.connectors.taskreactor.queue: In memory implementation of WorkItemQueue.
InMemoryWorkItemQueue() - Constructor for class com.snowflake.connectors.taskreactor.queue.InMemoryWorkItemQueue
InMemoryWorkSelector - Class in com.snowflake.connectors.taskreactor.queue.selector: In memory implementation of WorkSelector.
InMemoryWorkSelector() - Constructor for class com.snowflake.connectors.taskreactor.queue.selector.InMemoryWorkSelector
insert(String, Variant) - Method in class com.snowflake.connectors.common.table.InMemoryAppendOnlyKeyValueTable
insertWorkers(int) - Method in class com.snowflake.connectors.taskreactor.worker.registry.InMemoryWorkerRegistry
isDisabled() - Method in class com.snowflake.connectors.common.assertions.ingestion.definition.ResourceIngestionDefinitionAssert: Asserts that this resource ingestion definition has an enabled state equal to false.
isEnabled() - Method in class com.snowflake.connectors.common.assertions.ingestion.definition.ResourceIngestionDefinitionAssert: Asserts that this resource ingestion definition has an enabled state equal to true.
isEnabled(boolean) - Method in class com.snowflake.connectors.common.assertions.ingestion.definition.ResourceIngestionDefinitionAssert: Asserts that this resource ingestion definition has an enabled state equal to the specified value.
isEqualTo(Variant) - Method in class com.snowflake.connectors.common.assertions.common.VariantAssert
isInConfigurationStatus(ConnectorStatus.ConnectorConfigurationStatus) - Method in class com.snowflake.connectors.common.assertions.application.status.FullConnectorStatusAssert: Asserts that this full status has a connector configuration status equal to the specified value.
isInStatus(ConnectorStatus) - Method in class com.snowflake.connectors.common.assertions.application.status.FullConnectorStatusAssert: Asserts that this full status has a connector status equal to the specified value.
isJson(String) - Method in class com.snowflake.connectors.common.assertions.common.response.ResponseMapAssert: Asserts that this response has a json value equal to the specified value.
isQuoted() - Method in class com.snowflake.connectors.common.assertions.common.object.IdentifierAssert: Asserts that this identifier is quoted.
isStarted() - Method in class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert: Asserts that these task properties have a state equal to started.
isSuspended() - Method in class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert: Asserts that these task properties have a state equal to suspended.
isTaskReactorConfigured() - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskManagement
isTestConfigObject() - Method in class com.snowflake.connectors.common.assertions.configurationRepository.TestConfigAssert: Asserts that this object is an instance of TestConfig.
isTestStateObject() - Method in class com.snowflake.connectors.common.assertions.common.state.TestStateAssert: Asserts that this object is an instance of TestState.
isUnquoted() - Method in class com.snowflake.connectors.common.assertions.common.object.IdentifierAssert: Asserts that this identifier is unquoted.

N

name() - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
NativeSdkAssertions - Class in com.snowflake.connectors.common.assertions: Entry point for custom native-sdk AssertJ based assertions.
NativeSdkAssertions() - Constructor for class com.snowflake.connectors.common.assertions.NativeSdkAssertions

O

OBJECT_NAME - Static variable in class com.snowflake.connectors.common.assertions.NativeSdkAssertions
ObjectNameAssert - Class in com.snowflake.connectors.common.assertions.common.object: AssertJ based assertions for ObjectName.
ObjectNameAssert(ObjectName, Class<ObjectNameAssert>) - Constructor for class com.snowflake.connectors.common.assertions.common.object.ObjectNameAssert

P

PauseConnectorHandlerTestBuilder - Class in com.snowflake.connectors.application.lifecycle.pause: Test builder for the PauseConnectorHandler.
PauseConnectorHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerTestBuilder: Creates a new, empty PauseConnectorHandlerTestBuilder.
PauseConnectorHandlerTestBuilder(Session) - Constructor for class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerTestBuilder: Creates a new PauseConnectorHandlerTestBuilder.
push(QueueItem, WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueue
push(List<WorkItem>) - Method in class com.snowflake.connectors.taskreactor.queue.InMemoryWorkItemQueue

R

randomId() - Static method in class com.snowflake.connectors.common.IdGenerator: Generates a random UUID.
recreate(List<WorkerId>) - Method in class com.snowflake.connectors.taskreactor.worker.InMemoryWorkerCombinedView
REFERENCE - Static variable in class com.snowflake.connectors.common.assertions.NativeSdkAssertions
ReferenceAssert - Class in com.snowflake.connectors.common.assertions.common.object: AssertJ based assertions for Reference.
ReferenceAssert(Reference, Class<ReferenceAssert>) - Constructor for class com.snowflake.connectors.common.assertions.common.object.ReferenceAssert
removeStatusFor(WorkerId) - Method in class com.snowflake.connectors.taskreactor.worker.status.InMemoryWorkerStatusRepository
RESOURCE_INGESTION_DEFINITION - Static variable in class com.snowflake.connectors.common.assertions.NativeSdkAssertions
ResourceIngestionDefinitionAssert - Class in com.snowflake.connectors.common.assertions.ingestion.definition: AssertJ based assertions for ResourceIngestionDefinition.
ResourceIngestionDefinitionAssert(ResourceIngestionDefinition<?, ?, ?, ?>, Class<ResourceIngestionDefinitionAssert>) - Constructor for class com.snowflake.connectors.common.assertions.ingestion.definition.ResourceIngestionDefinitionAssert
ResponseMapAssert - Class in com.snowflake.connectors.common.assertions.common.response: AssertJ based assertions for a map representing a variant response.
ResponseMapAssert(Map<String, Variant>, Class<ResponseMapAssert>) - Constructor for class com.snowflake.connectors.common.assertions.common.response.ResponseMapAssert
resume() - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
ResumeConnectorHandlerTestBuilder - Class in com.snowflake.connectors.application.lifecycle.resume: Builder for the ResumeConnectorHandler.
ResumeConnectorHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Creates a new, empty ResumeConnectorHandlerTestBuilder.
ResumeConnectorHandlerTestBuilder(Session) - Constructor for class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Creates a new ResumeConnectorHandler.
resumeIfExists() - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef

S

save(IngestionProcess) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
save(Collection<IngestionProcess>) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
save(R) - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository
saveMany(List<R>) - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository
SCHEMA_NAME - Static variable in class com.snowflake.connectors.common.assertions.NativeSdkAssertions
SchemaNameAssert - Class in com.snowflake.connectors.common.assertions.common.object: AssertJ based assertions for SchemaName.
SchemaNameAssert(SchemaName, Class<SchemaNameAssert>) - Constructor for class com.snowflake.connectors.common.assertions.common.object.SchemaNameAssert
selectItemsFromView(String) - Method in class com.snowflake.connectors.taskreactor.queue.selector.InMemoryWorkSelector
selectItemsUsingProcedure(List<QueueItem>, String) - Method in class com.snowflake.connectors.taskreactor.queue.selector.InMemoryWorkSelector
sessionConfigFromFile() - Static method in class com.snowflake.connectors.common.snowflake.SnowflakeCredentials: Extracts session properties from a snowflake credentials file.
setActive(Identifier) - Method in class com.snowflake.connectors.taskreactor.registry.InMemoryInstanceRegistryRepository
setFetchAllWherePredicate(Predicate<Map.Entry<String, R>>) - Method in class com.snowflake.connectors.application.ingestion.definition.InMemoryResourceIngestionDefinitionRepository: Sets the predicate used by the fetchAllWhere method.
setGetAllWherePredicate(Predicate<Map.Entry<String, FakeKeyValue>>) - Method in class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
setGetAllWherePredicate(Predicate<Map.Entry<String, Variant>>) - Method in class com.snowflake.connectors.common.table.InMemoryReadOnlyKeyValueTable
setGetAllWherePredicate(Predicate<Map.Entry<String, Collection<FakeKeyValue>>>) - Method in class com.snowflake.connectors.common.table.InMemoryAppendOnlyKeyValueTable: Sets the predicate used by the getAllWhere method.
setInactive(Identifier) - Method in class com.snowflake.connectors.taskreactor.registry.InMemoryInstanceRegistryRepository
setUpdatedAt(Instant) - Method in class com.snowflake.connectors.common.table.FakeKeyValue
setValue(Variant) - Method in class com.snowflake.connectors.common.table.FakeKeyValue
setWorkersStatus(WorkerLifecycleStatus, List<WorkerId>) - Method in class com.snowflake.connectors.taskreactor.worker.registry.InMemoryWorkerRegistry
showTask(ObjectName) - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskManagement
showTasks(String) - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskManagement
showTasks(String, String) - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskManagement
SnowflakeCredentials - Class in com.snowflake.connectors.common.snowflake: Utility for parsing a snowflake credentials file.
SnowflakeCredentials() - Constructor for class com.snowflake.connectors.common.snowflake.SnowflakeCredentials
SnowsqlConfigurer - Class in com.snowflake.connectors
SnowsqlConfigurer() - Constructor for class com.snowflake.connectors.SnowsqlConfigurer
store() - Method in class com.snowflake.connectors.taskreactor.queue.InMemoryWorkItemQueue: Returns the list backing this queue.
store() - Method in class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueue: Returns the map backing this queue.
store() - Method in class com.snowflake.connectors.taskreactor.worker.registry.InMemoryWorkerRegistry: Returns a map backing this registry.
store() - Method in class com.snowflake.connectors.taskreactor.worker.status.InMemoryWorkerStatusRepository
suspend() - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef
suspendIfExists() - Method in class com.snowflake.connectors.common.task.InMemoryTaskRef

T

TASK_PROPERTIES - Static variable in class com.snowflake.connectors.common.assertions.NativeSdkAssertions: Definition of InstanceOfAssertFactory for TaskProperties assertion classes.
TaskPropertiesAssert - Class in com.snowflake.connectors.common.assertions.task: AssertJ based assertions for TaskProperties.
TaskPropertiesAssert(TaskProperties, Class<?>) - Constructor for class com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert
taskRepository() - Method in class com.snowflake.connectors.taskreactor.InMemoryTaskReactorInstanceComponentProvider: Returns the task repository.
TestConfig - Class in com.snowflake.connectors.common.assertions.configurationRepository: Test implementation of a connector configuration entry.
TestConfig(boolean, String, int) - Constructor for class com.snowflake.connectors.common.assertions.configurationRepository.TestConfig
TestConfigAssert - Class in com.snowflake.connectors.common.assertions.configurationRepository: AssertJ based assertions for TestConfig.
TestConfigAssert(TestConfig, Class<TestConfigAssert>) - Constructor for class com.snowflake.connectors.common.assertions.configurationRepository.TestConfigAssert
TestState - Class in com.snowflake.connectors.common.assertions.common.state: Test implementation of a connector state entry.
TestState(boolean, String, int) - Constructor for class com.snowflake.connectors.common.assertions.common.state.TestState
TestStateAssert - Class in com.snowflake.connectors.common.assertions.common.state: AssertJ based assertions for TestState.
TestStateAssert(TestState, Class<TestStateAssert>) - Constructor for class com.snowflake.connectors.common.assertions.common.state.TestStateAssert

U

update(String, Variant) - Method in class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
update(String, Variant) - Method in class com.snowflake.connectors.common.table.InMemoryReadOnlyKeyValueTable
update(String, String) - Method in class com.snowflake.connectors.taskreactor.config.InMemoryConfigRepository
updateAll(List<KeyValue>) - Method in class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
updateAll(List<KeyValue>) - Method in class com.snowflake.connectors.common.table.InMemoryReadOnlyKeyValueTable
updateConfig(Map<String, String>) - Method in class com.snowflake.connectors.taskreactor.config.InMemoryConfigRepository: Updates the config stored in this repository with the provided values.
UpdateConnectionConfigurationHandlerTestBuilder - Class in com.snowflake.connectors.application.configuration.connection: Test builder for the UpdateConnectionConfigurationHandler.
UpdateConnectionConfigurationHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerTestBuilder: Creates a new, empty UpdateConnectionConfigurationHandlerTestBuilder.
updateMany(List<String>, String, Variant) - Method in class com.snowflake.connectors.common.table.InMemoryDefaultKeyValueTable
updateMany(List<String>, String, Variant) - Method in class com.snowflake.connectors.common.table.InMemoryReadOnlyKeyValueTable
UpdateResourceHandlerTestBuilder - Class in com.snowflake.connectors.application.ingestion.update: Test builder for the UpdateResourceHandler.
UpdateResourceHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerTestBuilder: Creates a new, empty UpdateResourceHandlerTestBuilder.
updateStatus(String, String) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
updateStatus(String, String, String, String) - Method in class com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository
updateStatusesFor(WorkerStatus, List<WorkerId>) - Method in class com.snowflake.connectors.taskreactor.worker.status.InMemoryWorkerStatusRepository
updateStatusFor(WorkerId, WorkerStatus) - Method in class com.snowflake.connectors.taskreactor.worker.status.InMemoryWorkerStatusRepository
UpdateWarehouseHandlerTestBuilder - Class in com.snowflake.connectors.application.configuration.warehouse: Test builder for the UpdateWarehouseHandler.
UpdateWarehouseHandlerTestBuilder() - Constructor for class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerTestBuilder: Creates a new, empty UpdateWarehouseHandlerTestBuilder.
UpdateWarehouseHandlerTestBuilder(Session) - Constructor for class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerTestBuilder: Creates a new UpdateWarehouseHandlerTestBuilder.
updateWorkersStatus(WorkerLifecycleStatus, WorkerLifecycleStatus, Collection<WorkerId>) - Method in class com.snowflake.connectors.taskreactor.worker.registry.InMemoryWorkerRegistry

V

VariantAssert - Class in com.snowflake.connectors.common.assertions.common: AssertJ based assertions for Variant.
VariantAssert(Variant, Class<VariantAssert>) - Constructor for class com.snowflake.connectors.common.assertions.common.VariantAssert

W

withCallback(ConnectionConfigurationCallback) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerTestBuilder: Sets the callback used to build the handler instance.
withCallback(ConnectionConfigurationCallback) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerTestBuilder
withCallback(ConfigureConnectorCallback) - Method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerTestBuilder: Sets the callback used to build the handler instance.
withCallback(FinalizeConnectorCallback) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerTestBuilder: Sets the callback used to build the handler instance.
withCallback(UpdateWarehouseCallback) - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerTestBuilder
withCallback(PauseConnectorCallback) - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerTestBuilder: Sets the callback used to build the handler instance.
withCallback(ResumeConnectorCallback) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Sets the callback used to build the handler instance.
withConfigurationService(ConnectorConfigurationService) - Method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerTestBuilder: Sets the connector configuration service used to build the handler instance.
withConnectionConfigurationService(ConnectionConfigurationService) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerTestBuilder: Sets the connection configuration service used to build the handler instance.
withConnectionConfigurationService(ConnectionConfigurationService) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerTestBuilder
withConnectionValidator(ConnectionValidator) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerTestBuilder: Sets the connection validator used to build the handler instance.
withConnectionValidator(ConnectionValidator) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerTestBuilder
withConnectorConfigurationService(ConnectorConfigurationService) - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerTestBuilder: Sets the connector configuration service used to build the handler instance.
withConnectorStatusService(ConnectorStatusService) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerTestBuilder: Sets the connector status service used to build the handler instance.
withConnectorStatusService(ConnectorStatusService) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerTestBuilder
withConnectorStatusService(ConnectorStatusService) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerTestBuilder: Sets the connector status service used to build the handler instance.
withConnectorStatusService(ConnectorStatusService) - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerTestBuilder: Sets the connector status service used to build the handler instance.
withCreateResourceValidator(CreateResourceValidator) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerTestBuilder: Sets the CreateResourceValidator used to build the handler instance.
withDraftCallback(ConnectionConfigurationCallback) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerTestBuilder
withDraftConnectionValidator(DraftConnectionValidator) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerTestBuilder
withEnableResourceValidator(EnableResourceValidator) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerTestBuilder: Sets the EnableResourceValidator used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerTestBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerTestBuilder
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerTestBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerTestBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerTestBuilder
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerTestBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerTestBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerTestBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerTestBuilder: Sets the error helper used to build the test handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerTestBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Sets the error helper used to build the handler instance.
withErrorHelper(ConnectorErrorHelper) - Method in class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerTestBuilder: Sets the error helper used to build the handler instance.
withExceptionLogging(Supplier<T>) - Method in class com.snowflake.connectors.common.exception.InMemoryConnectorErrorHelper
withExceptionWrapping(Supplier<ConnectorResponse>) - Method in class com.snowflake.connectors.common.exception.InMemoryConnectorErrorHelper
withIngestionProcessRepository(IngestionProcessRepository) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerTestBuilder: Sets the ingestion process repository used to build the handler instance.
withIngestionProcessRepository(IngestionProcessRepository) - Method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerTestBuilder: Sets the ingestion process repository used to build the handler instance.
withIngestionProcessRepository(IngestionProcessRepository) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerTestBuilder: Sets the ingestion process repository used to build the handler instance.
withIngestionProcessRepository(IngestionProcessRepository) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerTestBuilder: Sets the ingestion process repository used to build the test handler instance.
withInputValidator(ConnectionConfigurationInputValidator) - Method in class com.snowflake.connectors.application.configuration.connection.ConnectionConfigurationHandlerTestBuilder: Sets the input validator used to build the handler instance.
withInputValidator(ConnectionConfigurationInputValidator) - Method in class com.snowflake.connectors.application.configuration.connection.UpdateConnectionConfigurationHandlerTestBuilder
withInputValidator(ConfigureConnectorInputValidator) - Method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerTestBuilder: Sets the input validator used to build the handler instance.
withInputValidator(FinalizeConnectorInputValidator) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerTestBuilder: Sets the input validator used to build the handler instance.
withInputValidator(UpdateWarehouseInputValidator) - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerTestBuilder
withInstanceStreamService(InstanceStreamService) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Sets the task reactor instance stream service used to build the handler instance.
withLifecycleService(LifecycleService) - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerTestBuilder: Sets the lifecycle service used to build the handler instance.
withLifecycleService(LifecycleService) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Sets the lifecycle service used to build the handler instance.
withPauseTaskReactorService(PauseTaskReactorService) - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerTestBuilder: Sets the service used to pause Task Reactor instances.
withPostCreateResourceCallback(PostCreateResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerTestBuilder: Sets the PostCreateResourceCallback used to build the handler instance.
withPostEnableResourceCallback(PostEnableResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerTestBuilder: Sets the PostEnableResourceCallback used to build the handler instance.
withPostUpdateResourceCallback(PostUpdateResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerTestBuilder: Sets the PostUpdateResourceCallback used to build the test handler instance.
withPreCreateResourceCallback(PreCreateResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerTestBuilder: Sets the PreCreateResourceCallback used to build the handler instance.
withPreEnableResourceCallback(PreEnableResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerTestBuilder: Sets the PreEnableResourceCallback used to build the handler instance.
withPreUpdateResourceCallback(PreUpdateResourceCallback) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerTestBuilder: Sets the PreUpdateResourceCallback used to build the test handler instance.
withResourceIngestionDefinitionRepository(ResourceIngestionDefinitionRepository<VariantResource>) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerTestBuilder: Sets the resource ingestion definition repository used to build the handler instance.
withResourceIngestionDefinitionRepository(ResourceIngestionDefinitionRepository<VariantResource>) - Method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerTestBuilder: Sets the resource ingestion definition repository used to build the handler instance.
withResourceIngestionDefinitionRepository(ResourceIngestionDefinitionRepository<VariantResource>) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerTestBuilder: Sets the resource ingestion definition repository used to build the handler instance.
withResourceIngestionDefinitionRepository(ResourceIngestionDefinitionRepository<VariantResource>) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerTestBuilder: Sets the resource ingestion definition repository used to build the test handler instance.
withResumeTaskReactorService(ResumeTaskReactorService) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Sets the service used to resume Task Reactor instances.
withSchedulerCreator(SchedulerCreator) - Method in class com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerTestBuilder: Sets the scheduler creator used to build the handler instance.
withSdkCallback(FinalizeConnectorSdkCallback) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerTestBuilder: Sets the sdk callback used to build the handler instance.
withSdkCallback(UpdateWarehouseSdkCallback) - Method in class com.snowflake.connectors.application.configuration.warehouse.UpdateWarehouseHandlerTestBuilder: Sets the sdk callback used to build the handler instance.
withSdkCallback(PauseConnectorSdkCallback) - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerTestBuilder: Sets the internal sdk callback used to build the handler instance.
withSdkCallback(ResumeConnectorSdkCallback) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Sets the internal sdk callback used to build the handler instance.
withSourceValidator(SourceValidator) - Method in class com.snowflake.connectors.application.configuration.finalization.FinalizeConnectorHandlerTestBuilder: Sets the source validator used to build the handler instance.
withStateValidator(PauseConnectorStateValidator) - Method in class com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerTestBuilder: Sets the state validator used to build the handler instance.
withStateValidator(ResumeConnectorStateValidator) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Sets the state validator used to build the handler instance.
withStatusService(ConnectorStatusService) - Method in class com.snowflake.connectors.application.configuration.connector.ConfigureConnectorHandlerTestBuilder: Sets the connector status service used to build the handler instance.
withTaskReactorInstanceActionExecutor(TaskReactorInstanceActionExecutor) - Method in class com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder: Sets the task reactor instance action executor used to build the handler instance.
withTransaction(Runnable) - Method in class com.snowflake.connectors.util.snowflake.InMemoryTransactionManager
withTransaction(Runnable, Function<Throwable, RuntimeException>) - Method in class com.snowflake.connectors.util.snowflake.InMemoryTransactionManager
withTransactionManager(TransactionManager) - Method in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerTestBuilder: Sets the transaction manager used to build the handler instance.
withTransactionManager(TransactionManager) - Method in class com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerTestBuilder: Sets the transaction manager used to build the handler instance.
withTransactionManager(TransactionManager) - Method in class com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerTestBuilder: Sets the transaction manager used to build the handler instance.
withTransactionManager(TransactionManager) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerTestBuilder: Sets the transaction manager used to build the test handler instance.
withUpdateResourceValidator(UpdateResourceValidator) - Method in class com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerTestBuilder: Sets the UpdateResourceValidator used to build the test handler instance.
workerQueues() - Method in class com.snowflake.connectors.taskreactor.worker.queue.InMemoryWorkerQueueManager: Returns the set backing this manager.

A B C D E F G H I N O P R S T U V W
All Classes All Packages