4
4
*/
5
5
package io .strimzi .systemtest .watcher ;
6
6
7
- import io .strimzi . systemtest . logs . CollectorElement ;
8
- import io .strimzi . systemtest .resources .NamespaceManager ;
7
+ import io .fabric8 . kubernetes . api . model . NamespaceBuilder ;
8
+ import io .skodjob . testframe .resources .KubeResourceManager ;
9
9
import io .strimzi .systemtest .resources .operator .ClusterOperatorConfigurationBuilder ;
10
10
import org .apache .logging .log4j .LogManager ;
11
11
import org .apache .logging .log4j .Logger ;
12
12
import org .junit .jupiter .api .BeforeAll ;
13
13
import org .junit .jupiter .api .Tag ;
14
14
15
- import java .util .Arrays ;
16
-
17
15
import static io .strimzi .systemtest .TestConstants .CO_NAMESPACE ;
18
16
import static io .strimzi .systemtest .TestTags .REGRESSION ;
19
17
@@ -25,8 +23,18 @@ class MultipleNamespaceST extends AbstractNamespaceST {
25
23
private void deployTestSpecificClusterOperator () {
26
24
LOGGER .info ("Creating Cluster Operator which will watch over multiple Namespaces" );
27
25
28
- NamespaceManager .getInstance ().createNamespaces (setupClusterOperator .getOperatorNamespace (),
29
- CollectorElement .createCollectorElement (this .getClass ().getName ()), Arrays .asList (PRIMARY_KAFKA_WATCHED_NAMESPACE , MAIN_TEST_NAMESPACE ));
26
+ KubeResourceManager .get ().createResourceWithWait (
27
+ new NamespaceBuilder ()
28
+ .withNewMetadata ()
29
+ .withName (PRIMARY_KAFKA_WATCHED_NAMESPACE )
30
+ .endMetadata ()
31
+ .build (),
32
+ new NamespaceBuilder ()
33
+ .withNewMetadata ()
34
+ .withName (MAIN_TEST_NAMESPACE )
35
+ .endMetadata ()
36
+ .build ()
37
+ );
30
38
31
39
setupClusterOperator
32
40
.withCustomConfiguration (new ClusterOperatorConfigurationBuilder ()
0 commit comments