DBZ-3566 Module debezium-testing-openshift renamed to debezium-testing-system together with package reordering
This commit is contained in:
jcechace
Chris Cranford
parent
80f205505e
commit
4f3b3ef25b
@ -1,17 +0,0 @@
|
||||
/*
|
||||
* Copyright Debezium Authors.
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.connectors.ConnectorRuntimeFixture;
|
||||
import io.debezium.testing.openshift.fixtures.databases.DatabaseRuntimeFixture;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.KafkaRuntimeFixture;
|
||||
import io.debezium.testing.openshift.fixtures.registry.RegistryRuntimeFixture;
|
||||
import io.debezium.testing.openshift.tools.databases.DatabaseController;
|
||||
|
||||
public interface TestRuntimeFixture<D extends DatabaseController<?>>
|
||||
extends KafkaRuntimeFixture, ConnectorRuntimeFixture, DatabaseRuntimeFixture<D>,
|
||||
RegistryRuntimeFixture, Assertions {
|
||||
}
|
||||
@ -1,15 +0,0 @@
|
||||
/*
|
||||
* Copyright Debezium Authors.
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.connectors.ConnectorSetupFixture;
|
||||
import io.debezium.testing.openshift.fixtures.databases.DatabaseSetupFixture;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.KafkaSetupFixture;
|
||||
import io.debezium.testing.openshift.fixtures.registry.RegistrySetupFixture;
|
||||
|
||||
public interface TestSetupFixture
|
||||
extends KafkaSetupFixture, DatabaseSetupFixture, ConnectorSetupFixture, RegistrySetupFixture {
|
||||
}
|
||||
@ -9,8 +9,8 @@
|
||||
</parent>
|
||||
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<artifactId>debezium-testing-openshift</artifactId>
|
||||
<name>Debezium OpenShift integration test-suite</name>
|
||||
<artifactId>debezium-testing-system</artifactId>
|
||||
<name>Debezium system integration test-suite</name>
|
||||
|
||||
<properties>
|
||||
<version.fabric8.client>5.2.1</version.fabric8.client>
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools;
|
||||
package io.debezium.testing.system.tools;
|
||||
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools;
|
||||
package io.debezium.testing.system.tools;
|
||||
|
||||
import java.util.Optional;
|
||||
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools;
|
||||
package io.debezium.testing.system.tools;
|
||||
|
||||
public interface Deployer<T> {
|
||||
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools;
|
||||
package io.debezium.testing.system.tools;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
import java.io.IOException;
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools;
|
||||
package io.debezium.testing.system.tools;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
import java.util.ArrayList;
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools;
|
||||
package io.debezium.testing.system.tools;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
import static java.util.concurrent.TimeUnit.MINUTES;
|
||||
import static java.util.concurrent.TimeUnit.SECONDS;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools;
|
||||
package io.debezium.testing.system.tools;
|
||||
|
||||
import java.util.stream.Stream;
|
||||
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools;
|
||||
package io.debezium.testing.system.tools;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases;
|
||||
package io.debezium.testing.system.tools.databases;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
import static java.util.concurrent.TimeUnit.MINUTES;
|
||||
import static java.util.concurrent.TimeUnit.SECONDS;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
@ -16,8 +16,8 @@
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.OpenShiftUtils;
|
||||
import io.debezium.testing.openshift.tools.WaitConditions;
|
||||
import io.debezium.testing.system.tools.OpenShiftUtils;
|
||||
import io.debezium.testing.system.tools.WaitConditions;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases;
|
||||
package io.debezium.testing.system.tools.databases;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
@ -14,9 +14,9 @@
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.Deployer;
|
||||
import io.debezium.testing.openshift.tools.OpenShiftUtils;
|
||||
import io.debezium.testing.openshift.tools.YAML;
|
||||
import io.debezium.testing.system.tools.Deployer;
|
||||
import io.debezium.testing.system.tools.OpenShiftUtils;
|
||||
import io.debezium.testing.system.tools.YAML;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases;
|
||||
package io.debezium.testing.system.tools.databases;
|
||||
|
||||
import java.util.Objects;
|
||||
import java.util.function.Consumer;
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases;
|
||||
package io.debezium.testing.system.tools.databases;
|
||||
|
||||
/**
|
||||
*
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases;
|
||||
package io.debezium.testing.system.tools.databases;
|
||||
|
||||
public interface DatabaseController<C extends DatabaseClient<?, ?>> {
|
||||
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases;
|
||||
package io.debezium.testing.system.tools.databases;
|
||||
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases;
|
||||
package io.debezium.testing.system.tools.databases;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases;
|
||||
package io.debezium.testing.system.tools.databases;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
import java.sql.Connection;
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases;
|
||||
package io.debezium.testing.system.tools.databases;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
@ -3,10 +3,10 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases.db2;
|
||||
package io.debezium.testing.system.tools.databases.db2;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_DB2_DBZ_PASSWORD;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_DB2_DBZ_USERNAME;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_DB2_DBZ_PASSWORD;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_DB2_DBZ_USERNAME;
|
||||
|
||||
import java.sql.SQLException;
|
||||
import java.util.List;
|
||||
@ -14,9 +14,9 @@
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.ConfigProperties;
|
||||
import io.debezium.testing.openshift.tools.databases.OcpSqlDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseClient;
|
||||
import io.debezium.testing.system.tools.ConfigProperties;
|
||||
import io.debezium.testing.system.tools.databases.OcpSqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseClient;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases.db2;
|
||||
package io.debezium.testing.system.tools.databases.db2;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.AbstractOcpDatabaseDeployer;
|
||||
import io.debezium.testing.system.tools.databases.AbstractOcpDatabaseDeployer;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases.mongodb;
|
||||
package io.debezium.testing.system.tools.databases.mongodb;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
import java.util.concurrent.TimeUnit;
|
||||
@ -20,8 +20,8 @@
|
||||
import com.mongodb.client.MongoCollection;
|
||||
import com.mongodb.client.MongoDatabase;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.Commands;
|
||||
import io.debezium.testing.openshift.tools.databases.DatabaseClient;
|
||||
import io.debezium.testing.system.tools.databases.Commands;
|
||||
import io.debezium.testing.system.tools.databases.DatabaseClient;
|
||||
|
||||
/**
|
||||
*
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases.mongodb;
|
||||
package io.debezium.testing.system.tools.databases.mongodb;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.DatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.DatabaseController;
|
||||
|
||||
public interface MongoDatabaseController extends DatabaseController<MongoDatabaseClient> {
|
||||
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases.mongodb;
|
||||
package io.debezium.testing.system.tools.databases.mongodb;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
@ -14,8 +14,8 @@
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.AbstractOcpDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.databases.DatabaseInitListener;
|
||||
import io.debezium.testing.system.tools.databases.AbstractOcpDatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.DatabaseInitListener;
|
||||
import io.fabric8.kubernetes.api.model.Pod;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases.mongodb;
|
||||
package io.debezium.testing.system.tools.databases.mongodb;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.AbstractOcpDatabaseDeployer;
|
||||
import io.debezium.testing.system.tools.databases.AbstractOcpDatabaseDeployer;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,15 +3,15 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases.mysql;
|
||||
package io.debezium.testing.system.tools.databases.mysql;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.AbstractOcpDatabaseDeployer;
|
||||
import io.debezium.testing.openshift.tools.databases.OcpSqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.AbstractOcpDatabaseDeployer;
|
||||
import io.debezium.testing.system.tools.databases.OcpSqlDatabaseController;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,15 +3,15 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases.postgresql;
|
||||
package io.debezium.testing.system.tools.databases.postgresql;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.AbstractOcpDatabaseDeployer;
|
||||
import io.debezium.testing.openshift.tools.databases.OcpSqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.AbstractOcpDatabaseDeployer;
|
||||
import io.debezium.testing.system.tools.databases.OcpSqlDatabaseController;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases.sqlserver;
|
||||
package io.debezium.testing.system.tools.databases.sqlserver;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_SQLSERVER_SA_PASSWORD;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_SQLSERVER_SA_PASSWORD;
|
||||
|
||||
import java.net.URISyntaxException;
|
||||
import java.nio.file.Path;
|
||||
@ -17,9 +17,9 @@
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.WaitConditions;
|
||||
import io.debezium.testing.openshift.tools.databases.DatabaseInitListener;
|
||||
import io.debezium.testing.openshift.tools.databases.OcpSqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.WaitConditions;
|
||||
import io.debezium.testing.system.tools.databases.DatabaseInitListener;
|
||||
import io.debezium.testing.system.tools.databases.OcpSqlDatabaseController;
|
||||
import io.fabric8.kubernetes.api.model.Pod;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.databases.sqlserver;
|
||||
package io.debezium.testing.system.tools.databases.sqlserver;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.AbstractOcpDatabaseDeployer;
|
||||
import io.debezium.testing.system.tools.databases.AbstractOcpDatabaseDeployer;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.kafka;
|
||||
package io.debezium.testing.system.tools.kafka;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.kafka;
|
||||
package io.debezium.testing.system.tools.kafka;
|
||||
|
||||
import java.io.IOException;
|
||||
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.kafka;
|
||||
package io.debezium.testing.system.tools.kafka;
|
||||
|
||||
import static org.apache.kafka.clients.consumer.ConsumerConfig.AUTO_OFFSET_RESET_CONFIG;
|
||||
import static org.apache.kafka.clients.consumer.ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG;
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.kafka;
|
||||
package io.debezium.testing.system.tools.kafka;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
import static io.strimzi.api.kafka.Crds.kafkaConnectOperation;
|
||||
import static java.util.concurrent.TimeUnit.MINUTES;
|
||||
import static java.util.concurrent.TimeUnit.SECONDS;
|
||||
@ -22,9 +22,9 @@
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.HttpUtils;
|
||||
import io.debezium.testing.openshift.tools.OpenShiftUtils;
|
||||
import io.debezium.testing.openshift.tools.WaitConditions;
|
||||
import io.debezium.testing.system.tools.HttpUtils;
|
||||
import io.debezium.testing.system.tools.OpenShiftUtils;
|
||||
import io.debezium.testing.system.tools.WaitConditions;
|
||||
import io.fabric8.kubernetes.api.model.IntOrString;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.networking.v1.NetworkPolicy;
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.kafka;
|
||||
package io.debezium.testing.system.tools.kafka;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.AbstractOcpDeployer;
|
||||
import io.debezium.testing.openshift.tools.Deployer;
|
||||
import io.debezium.testing.openshift.tools.YAML;
|
||||
import io.debezium.testing.system.tools.AbstractOcpDeployer;
|
||||
import io.debezium.testing.system.tools.Deployer;
|
||||
import io.debezium.testing.system.tools.YAML;
|
||||
import io.fabric8.kubernetes.api.model.ConfigMap;
|
||||
import io.fabric8.kubernetes.client.dsl.NonNamespaceOperation;
|
||||
import io.fabric8.kubernetes.client.dsl.Resource;
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.kafka;
|
||||
package io.debezium.testing.system.tools.kafka;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
import static java.util.concurrent.TimeUnit.MINUTES;
|
||||
|
||||
import java.util.List;
|
||||
@ -13,8 +13,8 @@
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.WaitConditions;
|
||||
import io.debezium.testing.openshift.tools.YAML;
|
||||
import io.debezium.testing.system.tools.WaitConditions;
|
||||
import io.debezium.testing.system.tools.YAML;
|
||||
import io.fabric8.kubernetes.client.dsl.NonNamespaceOperation;
|
||||
import io.fabric8.kubernetes.client.dsl.Resource;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.kafka;
|
||||
package io.debezium.testing.system.tools.kafka;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.AbstractOcpDeployer;
|
||||
import io.debezium.testing.openshift.tools.Deployer;
|
||||
import io.debezium.testing.openshift.tools.YAML;
|
||||
import io.debezium.testing.system.tools.AbstractOcpDeployer;
|
||||
import io.debezium.testing.system.tools.Deployer;
|
||||
import io.debezium.testing.system.tools.YAML;
|
||||
import io.fabric8.kubernetes.client.dsl.NonNamespaceOperation;
|
||||
import io.fabric8.kubernetes.client.dsl.Resource;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.kafka;
|
||||
package io.debezium.testing.system.tools.kafka;
|
||||
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
@ -11,8 +11,8 @@
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.tools.OperatorController;
|
||||
import io.debezium.testing.openshift.tools.YAML;
|
||||
import io.debezium.testing.system.tools.OperatorController;
|
||||
import io.debezium.testing.system.tools.YAML;
|
||||
import io.fabric8.kubernetes.api.model.Container;
|
||||
import io.fabric8.kubernetes.api.model.Secret;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.registry;
|
||||
package io.debezium.testing.system.tools.registry;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@ -12,7 +12,7 @@
|
||||
|
||||
import io.apicurio.registry.operator.api.model.ApicurioRegistry;
|
||||
import io.apicurio.registry.operator.api.model.ApicurioRegistryList;
|
||||
import io.debezium.testing.openshift.tools.OpenShiftUtils;
|
||||
import io.debezium.testing.system.tools.OpenShiftUtils;
|
||||
import io.fabric8.kubernetes.api.model.Service;
|
||||
import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinition;
|
||||
import io.fabric8.kubernetes.client.dsl.base.CustomResourceDefinitionContext;
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.tools.registry;
|
||||
package io.debezium.testing.system.tools.registry;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
import static java.util.concurrent.TimeUnit.MINUTES;
|
||||
import static java.util.concurrent.TimeUnit.SECONDS;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
@ -18,13 +18,13 @@
|
||||
|
||||
import io.apicurio.registry.operator.api.model.ApicurioRegistry;
|
||||
import io.apicurio.registry.operator.api.model.ApicurioRegistryList;
|
||||
import io.debezium.testing.openshift.tools.AbstractOcpDeployer;
|
||||
import io.debezium.testing.openshift.tools.Deployer;
|
||||
import io.debezium.testing.openshift.tools.OperatorController;
|
||||
import io.debezium.testing.openshift.tools.WaitConditions;
|
||||
import io.debezium.testing.openshift.tools.YAML;
|
||||
import io.debezium.testing.openshift.tools.kafka.KafkaController;
|
||||
import io.debezium.testing.openshift.tools.kafka.OcpKafkaController;
|
||||
import io.debezium.testing.system.tools.AbstractOcpDeployer;
|
||||
import io.debezium.testing.system.tools.Deployer;
|
||||
import io.debezium.testing.system.tools.OperatorController;
|
||||
import io.debezium.testing.system.tools.WaitConditions;
|
||||
import io.debezium.testing.system.tools.YAML;
|
||||
import io.debezium.testing.system.tools.kafka.KafkaController;
|
||||
import io.debezium.testing.system.tools.kafka.OcpKafkaController;
|
||||
import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinition;
|
||||
import io.fabric8.kubernetes.api.model.apps.Deployment;
|
||||
import io.fabric8.kubernetes.client.dsl.NonNamespaceOperation;
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift;
|
||||
package io.debezium.testing.system;
|
||||
|
||||
/**
|
||||
* Utility functions used in tests
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.assertions;
|
||||
package io.debezium.testing.system.assertions;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.assertions;
|
||||
package io.debezium.testing.system.assertions;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
|
||||
import static io.debezium.testing.system.tools.WaitConditions.scaled;
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.assertions;
|
||||
package io.debezium.testing.system.assertions;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
@ -3,13 +3,13 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures;
|
||||
package io.debezium.testing.system.fixtures;
|
||||
|
||||
import io.debezium.testing.openshift.assertions.AvroKafkaAssertions;
|
||||
import io.debezium.testing.openshift.assertions.KafkaAssertions;
|
||||
import io.debezium.testing.openshift.assertions.PlainKafkaAssertions;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.KafkaRuntimeFixture;
|
||||
import io.debezium.testing.openshift.fixtures.registry.RegistryRuntimeFixture;
|
||||
import io.debezium.testing.system.assertions.AvroKafkaAssertions;
|
||||
import io.debezium.testing.system.assertions.KafkaAssertions;
|
||||
import io.debezium.testing.system.assertions.PlainKafkaAssertions;
|
||||
import io.debezium.testing.system.fixtures.kafka.KafkaRuntimeFixture;
|
||||
import io.debezium.testing.system.fixtures.registry.RegistryRuntimeFixture;
|
||||
|
||||
public interface Assertions
|
||||
extends RegistryRuntimeFixture, KafkaRuntimeFixture {
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures;
|
||||
package io.debezium.testing.system.fixtures;
|
||||
|
||||
import io.debezium.testing.openshift.tools.ConfigProperties;
|
||||
import io.debezium.testing.system.tools.ConfigProperties;
|
||||
import io.fabric8.kubernetes.client.Config;
|
||||
import io.fabric8.kubernetes.client.ConfigBuilder;
|
||||
import io.fabric8.openshift.client.DefaultOpenShiftClient;
|
||||
@ -0,0 +1,17 @@
|
||||
/*
|
||||
* Copyright Debezium Authors.
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.system.fixtures;
|
||||
|
||||
import io.debezium.testing.system.fixtures.connectors.ConnectorRuntimeFixture;
|
||||
import io.debezium.testing.system.fixtures.databases.DatabaseRuntimeFixture;
|
||||
import io.debezium.testing.system.fixtures.kafka.KafkaRuntimeFixture;
|
||||
import io.debezium.testing.system.fixtures.registry.RegistryRuntimeFixture;
|
||||
import io.debezium.testing.system.tools.databases.DatabaseController;
|
||||
|
||||
public interface TestRuntimeFixture<D extends DatabaseController<?>>
|
||||
extends KafkaRuntimeFixture, ConnectorRuntimeFixture, DatabaseRuntimeFixture<D>,
|
||||
RegistryRuntimeFixture, Assertions {
|
||||
}
|
||||
@ -0,0 +1,15 @@
|
||||
/*
|
||||
* Copyright Debezium Authors.
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.system.fixtures;
|
||||
|
||||
import io.debezium.testing.system.fixtures.connectors.ConnectorSetupFixture;
|
||||
import io.debezium.testing.system.fixtures.databases.DatabaseSetupFixture;
|
||||
import io.debezium.testing.system.fixtures.kafka.KafkaSetupFixture;
|
||||
import io.debezium.testing.system.fixtures.registry.RegistrySetupFixture;
|
||||
|
||||
public interface TestSetupFixture
|
||||
extends KafkaSetupFixture, DatabaseSetupFixture, ConnectorSetupFixture, RegistrySetupFixture {
|
||||
}
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.connectors;
|
||||
package io.debezium.testing.system.fixtures.connectors;
|
||||
|
||||
import io.debezium.testing.openshift.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.system.tools.kafka.ConnectorConfigBuilder;
|
||||
|
||||
public interface ConnectorDecoratorFixture {
|
||||
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.connectors;
|
||||
package io.debezium.testing.system.fixtures.connectors;
|
||||
|
||||
import io.debezium.testing.openshift.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.system.tools.kafka.ConnectorConfigBuilder;
|
||||
|
||||
public interface ConnectorRuntimeFixture {
|
||||
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.connectors;
|
||||
package io.debezium.testing.system.fixtures.connectors;
|
||||
|
||||
public interface ConnectorSetupFixture extends ConnectorDecoratorFixture {
|
||||
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.connectors;
|
||||
package io.debezium.testing.system.fixtures.connectors;
|
||||
|
||||
import io.debezium.testing.openshift.TestUtils;
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.resources.ConnectorFactories;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.system.TestUtils;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.resources.ConnectorFactories;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.kafka.ConnectorConfigBuilder;
|
||||
|
||||
public interface Db2Connector
|
||||
extends TestSetupFixture, ConnectorSetupFixture, TestRuntimeFixture<SqlDatabaseController> {
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.connectors;
|
||||
package io.debezium.testing.system.fixtures.connectors;
|
||||
|
||||
import io.debezium.testing.openshift.TestUtils;
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.resources.ConnectorFactories;
|
||||
import io.debezium.testing.openshift.tools.databases.mongodb.MongoDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.system.TestUtils;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.resources.ConnectorFactories;
|
||||
import io.debezium.testing.system.tools.databases.mongodb.MongoDatabaseController;
|
||||
import io.debezium.testing.system.tools.kafka.ConnectorConfigBuilder;
|
||||
|
||||
public interface MongoConnector
|
||||
extends TestSetupFixture, ConnectorSetupFixture, TestRuntimeFixture<MongoDatabaseController> {
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.connectors;
|
||||
package io.debezium.testing.system.fixtures.connectors;
|
||||
|
||||
import io.debezium.testing.openshift.TestUtils;
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.resources.ConnectorFactories;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.system.TestUtils;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.resources.ConnectorFactories;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.kafka.ConnectorConfigBuilder;
|
||||
|
||||
public interface MySqlConnector
|
||||
extends TestSetupFixture, ConnectorSetupFixture, TestRuntimeFixture<SqlDatabaseController> {
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.connectors;
|
||||
package io.debezium.testing.system.fixtures.connectors;
|
||||
|
||||
import io.debezium.testing.openshift.TestUtils;
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.resources.ConnectorFactories;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.system.TestUtils;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.resources.ConnectorFactories;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.kafka.ConnectorConfigBuilder;
|
||||
|
||||
public interface PostgreSqlConnector
|
||||
extends TestSetupFixture, ConnectorSetupFixture, TestRuntimeFixture<SqlDatabaseController> {
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.connectors;
|
||||
package io.debezium.testing.system.fixtures.connectors;
|
||||
|
||||
import io.debezium.testing.openshift.TestUtils;
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.resources.ConnectorFactories;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.system.TestUtils;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.resources.ConnectorFactories;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.kafka.ConnectorConfigBuilder;
|
||||
|
||||
public interface SqlServerConnector
|
||||
extends TestSetupFixture, ConnectorSetupFixture, TestRuntimeFixture<SqlDatabaseController> {
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.databases;
|
||||
package io.debezium.testing.system.fixtures.databases;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.DatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.DatabaseController;
|
||||
|
||||
public interface DatabaseRuntimeFixture<T extends DatabaseController<?>> {
|
||||
void setDbController(T controller);
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.databases;
|
||||
package io.debezium.testing.system.fixtures.databases;
|
||||
|
||||
public interface DatabaseSetupFixture {
|
||||
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.databases;
|
||||
package io.debezium.testing.system.fixtures.databases;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.mongodb.MongoDatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.mongodb.MongoDatabaseController;
|
||||
|
||||
public interface MongoDatabaseFixture extends DatabaseRuntimeFixture<MongoDatabaseController> {
|
||||
}
|
||||
@ -3,13 +3,13 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.databases;
|
||||
package io.debezium.testing.system.fixtures.databases;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.OcpClient;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.tools.ConfigProperties;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.databases.db2.OcpDB2Deployer;
|
||||
import io.debezium.testing.system.fixtures.OcpClient;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.tools.ConfigProperties;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.db2.OcpDB2Deployer;
|
||||
|
||||
public interface OcpDb2 extends TestSetupFixture, SqlDatabaseFixture, OcpClient {
|
||||
|
||||
@ -3,13 +3,13 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.databases;
|
||||
package io.debezium.testing.system.fixtures.databases;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.OcpClient;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.tools.ConfigProperties;
|
||||
import io.debezium.testing.openshift.tools.databases.mongodb.OcpMongoController;
|
||||
import io.debezium.testing.openshift.tools.databases.mongodb.OcpMongoDeployer;
|
||||
import io.debezium.testing.system.fixtures.OcpClient;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.tools.ConfigProperties;
|
||||
import io.debezium.testing.system.tools.databases.mongodb.OcpMongoController;
|
||||
import io.debezium.testing.system.tools.databases.mongodb.OcpMongoDeployer;
|
||||
|
||||
public interface OcpMongo extends TestSetupFixture, MongoDatabaseFixture, OcpClient {
|
||||
|
||||
@ -3,13 +3,13 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.databases;
|
||||
package io.debezium.testing.system.fixtures.databases;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.OcpClient;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.tools.ConfigProperties;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.databases.mysql.OcpMySqlDeployer;
|
||||
import io.debezium.testing.system.fixtures.OcpClient;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.tools.ConfigProperties;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.mysql.OcpMySqlDeployer;
|
||||
|
||||
public interface OcpMySql extends TestSetupFixture, SqlDatabaseFixture, OcpClient {
|
||||
|
||||
@ -3,13 +3,13 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.databases;
|
||||
package io.debezium.testing.system.fixtures.databases;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.OcpClient;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.tools.ConfigProperties;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.databases.postgresql.OcpPostgreSqlDeployer;
|
||||
import io.debezium.testing.system.fixtures.OcpClient;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.tools.ConfigProperties;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.postgresql.OcpPostgreSqlDeployer;
|
||||
|
||||
public interface OcpPostgreSql extends TestSetupFixture, SqlDatabaseFixture, OcpClient {
|
||||
|
||||
@ -3,13 +3,13 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.databases;
|
||||
package io.debezium.testing.system.fixtures.databases;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.OcpClient;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.tools.ConfigProperties;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.openshift.tools.databases.sqlserver.OcpSqlServerDeployer;
|
||||
import io.debezium.testing.system.fixtures.OcpClient;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.tools.ConfigProperties;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.sqlserver.OcpSqlServerDeployer;
|
||||
|
||||
public interface OcpSqlServer extends TestSetupFixture, SqlDatabaseFixture, OcpClient {
|
||||
|
||||
@ -3,9 +3,9 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.databases;
|
||||
package io.debezium.testing.system.fixtures.databases;
|
||||
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
|
||||
public interface SqlDatabaseFixture extends DatabaseRuntimeFixture<SqlDatabaseController> {
|
||||
}
|
||||
@ -3,10 +3,10 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.kafka;
|
||||
package io.debezium.testing.system.fixtures.kafka;
|
||||
|
||||
import io.debezium.testing.openshift.tools.kafka.KafkaConnectController;
|
||||
import io.debezium.testing.openshift.tools.kafka.KafkaController;
|
||||
import io.debezium.testing.system.tools.kafka.KafkaConnectController;
|
||||
import io.debezium.testing.system.tools.kafka.KafkaController;
|
||||
|
||||
public interface KafkaRuntimeFixture {
|
||||
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.kafka;
|
||||
package io.debezium.testing.system.fixtures.kafka;
|
||||
|
||||
public interface KafkaSetupFixture {
|
||||
void setupKafka() throws Exception;
|
||||
@ -3,21 +3,21 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.kafka;
|
||||
package io.debezium.testing.system.fixtures.kafka;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.STRIMZI_CRD_VERSION;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.STRIMZI_CRD_VERSION;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.OcpClient;
|
||||
import io.debezium.testing.openshift.tools.ConfigProperties;
|
||||
import io.debezium.testing.openshift.tools.kafka.KafkaConnectController;
|
||||
import io.debezium.testing.openshift.tools.kafka.KafkaController;
|
||||
import io.debezium.testing.openshift.tools.kafka.OcpKafkaConnectController;
|
||||
import io.debezium.testing.openshift.tools.kafka.OcpKafkaConnectDeployer;
|
||||
import io.debezium.testing.openshift.tools.kafka.OcpKafkaDeployer;
|
||||
import io.debezium.testing.openshift.tools.kafka.StrimziOperatorController;
|
||||
import io.debezium.testing.system.fixtures.OcpClient;
|
||||
import io.debezium.testing.system.tools.ConfigProperties;
|
||||
import io.debezium.testing.system.tools.kafka.KafkaConnectController;
|
||||
import io.debezium.testing.system.tools.kafka.KafkaController;
|
||||
import io.debezium.testing.system.tools.kafka.OcpKafkaConnectController;
|
||||
import io.debezium.testing.system.tools.kafka.OcpKafkaConnectDeployer;
|
||||
import io.debezium.testing.system.tools.kafka.OcpKafkaDeployer;
|
||||
import io.debezium.testing.system.tools.kafka.StrimziOperatorController;
|
||||
import io.fabric8.kubernetes.api.model.ObjectMeta;
|
||||
import io.fabric8.kubernetes.api.model.Secret;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
@ -3,18 +3,18 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.registry;
|
||||
package io.debezium.testing.system.fixtures.registry;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.STRIMZI_CRD_VERSION;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.STRIMZI_CRD_VERSION;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.OcpClient;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.fixtures.connectors.ConnectorDecoratorFixture;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.KafkaRuntimeFixture;
|
||||
import io.debezium.testing.openshift.tools.ConfigProperties;
|
||||
import io.debezium.testing.openshift.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.openshift.tools.registry.OcpRegistryController;
|
||||
import io.debezium.testing.openshift.tools.registry.OcpRegistryDeployer;
|
||||
import io.debezium.testing.system.fixtures.OcpClient;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.fixtures.connectors.ConnectorDecoratorFixture;
|
||||
import io.debezium.testing.system.fixtures.kafka.KafkaRuntimeFixture;
|
||||
import io.debezium.testing.system.tools.ConfigProperties;
|
||||
import io.debezium.testing.system.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.system.tools.registry.OcpRegistryController;
|
||||
import io.debezium.testing.system.tools.registry.OcpRegistryDeployer;
|
||||
|
||||
import okhttp3.OkHttpClient;
|
||||
|
||||
@ -3,12 +3,12 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.registry;
|
||||
package io.debezium.testing.system.fixtures.registry;
|
||||
|
||||
import java.util.Optional;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.tools.registry.OcpRegistryController;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.tools.registry.OcpRegistryController;
|
||||
|
||||
public interface RegistryRuntimeFixture extends TestSetupFixture {
|
||||
default Optional<OcpRegistryController> getRegistryController() {
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.fixtures.registry;
|
||||
package io.debezium.testing.system.fixtures.registry;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
@ -3,14 +3,14 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.resources;
|
||||
package io.debezium.testing.system.resources;
|
||||
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_MONGO_HOST;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_MYSQL_HOST;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_POSTGRESQL_HOST;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_MONGO_HOST;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_MYSQL_HOST;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_POSTGRESQL_HOST;
|
||||
|
||||
import io.debezium.testing.openshift.tools.ConfigProperties;
|
||||
import io.debezium.testing.openshift.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.system.tools.ConfigProperties;
|
||||
import io.debezium.testing.system.tools.kafka.ConnectorConfigBuilder;
|
||||
|
||||
/**
|
||||
*
|
||||
@ -3,7 +3,7 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift;
|
||||
package io.debezium.testing.system.tests;
|
||||
|
||||
import java.util.Optional;
|
||||
|
||||
@ -13,13 +13,13 @@
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.openshift.tools.databases.DatabaseController;
|
||||
import io.debezium.testing.openshift.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.openshift.tools.kafka.KafkaConnectController;
|
||||
import io.debezium.testing.openshift.tools.kafka.KafkaController;
|
||||
import io.debezium.testing.openshift.tools.registry.OcpRegistryController;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.fixtures.TestSetupFixture;
|
||||
import io.debezium.testing.system.tools.databases.DatabaseController;
|
||||
import io.debezium.testing.system.tools.kafka.ConnectorConfigBuilder;
|
||||
import io.debezium.testing.system.tools.kafka.KafkaConnectController;
|
||||
import io.debezium.testing.system.tools.kafka.KafkaController;
|
||||
import io.debezium.testing.system.tools.registry.OcpRegistryController;
|
||||
|
||||
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
|
||||
public abstract class ConnectorTest<D extends DatabaseController<?>>
|
||||
@ -3,15 +3,15 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift;
|
||||
package io.debezium.testing.system.tests;
|
||||
|
||||
import org.junit.jupiter.api.TestInstance;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.OcpClient;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.openshift.tools.databases.DatabaseController;
|
||||
import io.debezium.testing.system.fixtures.OcpClient;
|
||||
import io.debezium.testing.system.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.system.tools.databases.DatabaseController;
|
||||
import io.fabric8.openshift.client.OpenShiftClient;
|
||||
|
||||
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
|
||||
@ -3,18 +3,18 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.db2;
|
||||
package io.debezium.testing.system.tests.db2;
|
||||
|
||||
import org.junit.jupiter.api.MethodOrderer;
|
||||
import org.junit.jupiter.api.Tag;
|
||||
import org.junit.jupiter.api.TestInstance;
|
||||
import org.junit.jupiter.api.TestMethodOrder;
|
||||
|
||||
import io.debezium.testing.openshift.OcpConnectorTest;
|
||||
import io.debezium.testing.openshift.fixtures.connectors.Db2Connector;
|
||||
import io.debezium.testing.openshift.fixtures.databases.OcpDb2;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tests.OcpConnectorTest;
|
||||
import io.debezium.testing.system.fixtures.connectors.Db2Connector;
|
||||
import io.debezium.testing.system.fixtures.databases.OcpDb2;
|
||||
import io.debezium.testing.system.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
|
||||
/**
|
||||
* @author Jakub Cechacek
|
||||
@ -3,12 +3,12 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.db2;
|
||||
package io.debezium.testing.system.tests.db2;
|
||||
|
||||
import static io.debezium.testing.openshift.assertions.KafkaAssertions.awaitAssert;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_DB2_DBZ_DBNAME;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_DB2_DBZ_PASSWORD;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_DB2_DBZ_USERNAME;
|
||||
import static io.debezium.testing.system.assertions.KafkaAssertions.awaitAssert;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_DB2_DBZ_DBNAME;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_DB2_DBZ_PASSWORD;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_DB2_DBZ_USERNAME;
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
import java.io.IOException;
|
||||
@ -17,9 +17,9 @@
|
||||
import org.junit.jupiter.api.Order;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseClient;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseClient;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
|
||||
import okhttp3.OkHttpClient;
|
||||
import okhttp3.Request;
|
||||
@ -3,13 +3,13 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.mongodb;
|
||||
package io.debezium.testing.system.tests.mongodb;
|
||||
|
||||
import static io.debezium.testing.openshift.assertions.KafkaAssertions.awaitAssert;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_MONGO_DBZ_DBNAME;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_MONGO_DBZ_LOGIN_DBNAME;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_MONGO_DBZ_PASSWORD;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_MONGO_DBZ_USERNAME;
|
||||
import static io.debezium.testing.system.assertions.KafkaAssertions.awaitAssert;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_MONGO_DBZ_DBNAME;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_MONGO_DBZ_LOGIN_DBNAME;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_MONGO_DBZ_PASSWORD;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_MONGO_DBZ_USERNAME;
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
import java.io.IOException;
|
||||
@ -18,9 +18,9 @@
|
||||
import org.junit.jupiter.api.Order;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.tools.databases.mongodb.MongoDatabaseClient;
|
||||
import io.debezium.testing.openshift.tools.databases.mongodb.MongoDatabaseController;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.tools.databases.mongodb.MongoDatabaseClient;
|
||||
import io.debezium.testing.system.tools.databases.mongodb.MongoDatabaseController;
|
||||
|
||||
import okhttp3.OkHttpClient;
|
||||
import okhttp3.Request;
|
||||
@ -3,18 +3,18 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.mongodb;
|
||||
package io.debezium.testing.system.tests.mongodb;
|
||||
|
||||
import org.junit.jupiter.api.MethodOrderer;
|
||||
import org.junit.jupiter.api.Tag;
|
||||
import org.junit.jupiter.api.TestInstance;
|
||||
import org.junit.jupiter.api.TestMethodOrder;
|
||||
|
||||
import io.debezium.testing.openshift.OcpConnectorTest;
|
||||
import io.debezium.testing.openshift.fixtures.connectors.MongoConnector;
|
||||
import io.debezium.testing.openshift.fixtures.databases.OcpMongo;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.openshift.tools.databases.mongodb.MongoDatabaseController;
|
||||
import io.debezium.testing.system.tests.OcpConnectorTest;
|
||||
import io.debezium.testing.system.fixtures.connectors.MongoConnector;
|
||||
import io.debezium.testing.system.fixtures.databases.OcpMongo;
|
||||
import io.debezium.testing.system.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.system.tools.databases.mongodb.MongoDatabaseController;
|
||||
|
||||
/**
|
||||
* @author Jakub Cechacek
|
||||
@ -3,11 +3,11 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.mysql;
|
||||
package io.debezium.testing.system.tests.mysql;
|
||||
|
||||
import static io.debezium.testing.openshift.assertions.KafkaAssertions.awaitAssert;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_MYSQL_PASSWORD;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_MYSQL_USERNAME;
|
||||
import static io.debezium.testing.system.assertions.KafkaAssertions.awaitAssert;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_MYSQL_PASSWORD;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_MYSQL_USERNAME;
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
import java.io.IOException;
|
||||
@ -16,9 +16,9 @@
|
||||
import org.junit.jupiter.api.Order;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseClient;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseClient;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
|
||||
import okhttp3.OkHttpClient;
|
||||
import okhttp3.Request;
|
||||
@ -3,19 +3,19 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.mysql;
|
||||
package io.debezium.testing.system.tests.mysql;
|
||||
|
||||
import org.junit.jupiter.api.MethodOrderer;
|
||||
import org.junit.jupiter.api.Tag;
|
||||
import org.junit.jupiter.api.TestInstance;
|
||||
import org.junit.jupiter.api.TestMethodOrder;
|
||||
|
||||
import io.debezium.testing.openshift.OcpConnectorTest;
|
||||
import io.debezium.testing.openshift.fixtures.connectors.MySqlConnector;
|
||||
import io.debezium.testing.openshift.fixtures.databases.OcpMySql;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.openshift.fixtures.registry.OcpApicurio;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tests.OcpConnectorTest;
|
||||
import io.debezium.testing.system.fixtures.connectors.MySqlConnector;
|
||||
import io.debezium.testing.system.fixtures.databases.OcpMySql;
|
||||
import io.debezium.testing.system.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.system.fixtures.registry.OcpApicurio;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
|
||||
/**
|
||||
* @author Jakub Cechacek
|
||||
@ -3,18 +3,18 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.mysql;
|
||||
package io.debezium.testing.system.tests.mysql;
|
||||
|
||||
import org.junit.jupiter.api.MethodOrderer;
|
||||
import org.junit.jupiter.api.Tag;
|
||||
import org.junit.jupiter.api.TestInstance;
|
||||
import org.junit.jupiter.api.TestMethodOrder;
|
||||
|
||||
import io.debezium.testing.openshift.OcpConnectorTest;
|
||||
import io.debezium.testing.openshift.fixtures.connectors.MySqlConnector;
|
||||
import io.debezium.testing.openshift.fixtures.databases.OcpMySql;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tests.OcpConnectorTest;
|
||||
import io.debezium.testing.system.fixtures.connectors.MySqlConnector;
|
||||
import io.debezium.testing.system.fixtures.databases.OcpMySql;
|
||||
import io.debezium.testing.system.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
|
||||
/**
|
||||
* @author Jakub Cechacek
|
||||
@ -3,18 +3,18 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.postgresql;
|
||||
package io.debezium.testing.system.tests.postgresql;
|
||||
|
||||
import org.junit.jupiter.api.MethodOrderer;
|
||||
import org.junit.jupiter.api.Tag;
|
||||
import org.junit.jupiter.api.TestInstance;
|
||||
import org.junit.jupiter.api.TestMethodOrder;
|
||||
|
||||
import io.debezium.testing.openshift.OcpConnectorTest;
|
||||
import io.debezium.testing.openshift.fixtures.connectors.PostgreSqlConnector;
|
||||
import io.debezium.testing.openshift.fixtures.databases.OcpPostgreSql;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tests.OcpConnectorTest;
|
||||
import io.debezium.testing.system.fixtures.connectors.PostgreSqlConnector;
|
||||
import io.debezium.testing.system.fixtures.databases.OcpPostgreSql;
|
||||
import io.debezium.testing.system.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
|
||||
/**
|
||||
* @author Jakub Cechacek
|
||||
@ -3,12 +3,12 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.postgresql;
|
||||
package io.debezium.testing.system.tests.postgresql;
|
||||
|
||||
import static io.debezium.testing.openshift.assertions.KafkaAssertions.awaitAssert;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_POSTGRESQL_DBZ_DBNAME;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_POSTGRESQL_PASSWORD;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_POSTGRESQL_USERNAME;
|
||||
import static io.debezium.testing.system.assertions.KafkaAssertions.awaitAssert;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_POSTGRESQL_DBZ_DBNAME;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_POSTGRESQL_PASSWORD;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_POSTGRESQL_USERNAME;
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
import java.io.IOException;
|
||||
@ -17,9 +17,9 @@
|
||||
import org.junit.jupiter.api.Order;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseClient;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseClient;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
|
||||
import okhttp3.OkHttpClient;
|
||||
import okhttp3.Request;
|
||||
@ -3,18 +3,18 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.sqlserver;
|
||||
package io.debezium.testing.system.tests.sqlserver;
|
||||
|
||||
import org.junit.jupiter.api.MethodOrderer;
|
||||
import org.junit.jupiter.api.Tag;
|
||||
import org.junit.jupiter.api.TestInstance;
|
||||
import org.junit.jupiter.api.TestMethodOrder;
|
||||
|
||||
import io.debezium.testing.openshift.OcpConnectorTest;
|
||||
import io.debezium.testing.openshift.fixtures.connectors.SqlServerConnector;
|
||||
import io.debezium.testing.openshift.fixtures.databases.OcpSqlServer;
|
||||
import io.debezium.testing.openshift.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.tests.OcpConnectorTest;
|
||||
import io.debezium.testing.system.fixtures.connectors.SqlServerConnector;
|
||||
import io.debezium.testing.system.fixtures.databases.OcpSqlServer;
|
||||
import io.debezium.testing.system.fixtures.kafka.OcpKafka;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
|
||||
/**
|
||||
* @author Jakub Cechacek
|
||||
@ -3,12 +3,12 @@
|
||||
*
|
||||
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
||||
*/
|
||||
package io.debezium.testing.openshift.sqlserver;
|
||||
package io.debezium.testing.system.tests.sqlserver;
|
||||
|
||||
import static io.debezium.testing.openshift.assertions.KafkaAssertions.awaitAssert;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_SQLSERVER_DBZ_DBNAME;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_SQLSERVER_DBZ_PASSWORD;
|
||||
import static io.debezium.testing.openshift.tools.ConfigProperties.DATABASE_SQLSERVER_DBZ_USERNAME;
|
||||
import static io.debezium.testing.system.assertions.KafkaAssertions.awaitAssert;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_SQLSERVER_DBZ_DBNAME;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_SQLSERVER_DBZ_PASSWORD;
|
||||
import static io.debezium.testing.system.tools.ConfigProperties.DATABASE_SQLSERVER_DBZ_USERNAME;
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
import java.io.IOException;
|
||||
@ -17,9 +17,9 @@
|
||||
import org.junit.jupiter.api.Order;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import io.debezium.testing.openshift.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseClient;
|
||||
import io.debezium.testing.openshift.tools.databases.SqlDatabaseController;
|
||||
import io.debezium.testing.system.fixtures.TestRuntimeFixture;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseClient;
|
||||
import io.debezium.testing.system.tools.databases.SqlDatabaseController;
|
||||
|
||||
import okhttp3.OkHttpClient;
|
||||
import okhttp3.Request;
|
||||
@ -12,6 +12,6 @@
|
||||
<packaging>pom</packaging>
|
||||
<modules>
|
||||
<module>debezium-testing-testcontainers</module>
|
||||
<module>debezium-testing-openshift</module>
|
||||
<module>debezium-testing-system</module>
|
||||
</modules>
|
||||
</project>
|
||||
|
||||
@ -31,7 +31,7 @@ then
|
||||
TEST_PROPERTIES="$TEST_PROPERTIES -Dimage.fullname=${DBZ_CONNECT_IMAGE}" ;
|
||||
fi
|
||||
|
||||
mvn install -pl debezium-testing/debezium-testing-openshift -PopenshiftITs \
|
||||
mvn install -pl debezium-testing/debezium-testing-system -PopenshiftITs \
|
||||
-Dtest.ocp.username="${OCP_USERNAME}" \
|
||||
-Dtest.ocp.password="${OCP_PASSWORD}" \
|
||||
-Dtest.ocp.url="${OCP_URL}" \
|
||||
@ -48,7 +48,7 @@ mvn install -pl debezium-testing/debezium-testing-openshift -PopenshiftITs \
|
||||
|
||||
popd;
|
||||
|
||||
cp debezium/debezium-testing/debezium-testing-openshift/target/failsafe-reports/*.xml /testsuite/logs
|
||||
cp debezium/debezium-testing/debezium-testing-system/target/failsafe-reports/*.xml /testsuite/logs
|
||||
|
||||
if [ "${DELETE_PROJECTS}" = true ] ;
|
||||
then
|
||||
@ -1,5 +1,5 @@
|
||||
pipelineJob('ocp-debezium-openshift-test') {
|
||||
displayName('Debezium OpenShift TestSuite')
|
||||
pipelineJob('ocp-debezium-testing-system') {
|
||||
displayName('Debezium System-level TestSuite')
|
||||
description('Executes tests for OpenShift & Strimzi compatibility verification')
|
||||
|
||||
properties {
|
||||
|
||||
@ -114,7 +114,7 @@ pipeline {
|
||||
}
|
||||
steps {
|
||||
script {
|
||||
env.DBZ_CONNECT_IMAGE = "quay.io/debezium/testing-openshift-connect:ci-${currentBuild.number}"
|
||||
env.DBZ_CONNECT_IMAGE = "quay.io/debezium/testing-system-connect:ci-${currentBuild.number}"
|
||||
}
|
||||
withCredentials([
|
||||
usernamePassword(credentialsId: "${QUAY_CREDENTIALS}", usernameVariable: 'QUAY_USERNAME', passwordVariable: 'QUAY_PASSWORD'),
|
||||
@ -123,7 +123,7 @@ pipeline {
|
||||
set -x
|
||||
cd ${WORKSPACE}/debezium
|
||||
docker login -u=${QUAY_USERNAME} -p=${QUAY_PASSWORD} quay.io
|
||||
mvn install -pl debezium-testing/debezium-testing-openshift -DskipTests -DskipITs -Pimage -Dimage.push.skip=false -Dimage.name=${DBZ_CONNECT_IMAGE}
|
||||
mvn install -pl debezium-testing/debezium-testing-system -DskipTests -DskipITs -Pimage -Dimage.push.skip=false -Dimage.name=${DBZ_CONNECT_IMAGE}
|
||||
'''
|
||||
}
|
||||
}
|
||||
@ -137,7 +137,7 @@ pipeline {
|
||||
sh '''
|
||||
set -x
|
||||
cd ${WORKSPACE}/debezium
|
||||
mvn install -pl debezium-testing/debezium-testing-openshift -PopenshiftITs \\
|
||||
mvn install -pl debezium-testing/debezium-testing-system -PopenshiftITs \\
|
||||
-Dtest.ocp.username="${OCP_USERNAME}" \\
|
||||
-Dtest.ocp.password="${OCP_PASSWORD}" \\
|
||||
-Dtest.ocp.url="${OCP_URL}" \\
|
||||
|
||||
Loading…
Reference in New Issue
Block a user