Class KafkaBridgeResource
- java.lang.Object
-
- io.strimzi.systemtest.resources.crd.KafkaBridgeResource
-
public class KafkaBridgeResource extends Object
-
-
Field Summary
Fields Modifier and Type Field Description static StringPATH_TO_KAFKA_BRIDGE_CONFIGstatic StringPATH_TO_KAFKA_BRIDGE_METRICS_CONFIG
-
Constructor Summary
Constructors Constructor Description KafkaBridgeResource()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static io.strimzi.api.kafka.model.KafkaBridgecreateAndWaitForReadiness(io.strimzi.api.kafka.model.KafkaBridge kafkaBridge)static voiddeleteKafkaBridgeWithoutWait(String resourceName)static io.strimzi.api.kafka.model.KafkaBridgeBuilderkafkaBridge(String name, String bootstrap, int kafkaBridgeReplicas)static io.strimzi.api.kafka.model.KafkaBridgeBuilderkafkaBridge(String name, String clusterName, String bootstrap, int kafkaBridgeReplicas)static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.KafkaBridge,io.strimzi.api.kafka.KafkaBridgeList,io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.KafkaBridge>>kafkaBridgeClient()static io.strimzi.api.kafka.model.KafkaBridgeBuilderkafkaBridgeWithCors(String name, String bootstrap, int kafkaBridgeReplicas, String allowedCorsOrigin, String allowedCorsMethods)static io.strimzi.api.kafka.model.KafkaBridgeBuilderkafkaBridgeWithCors(String name, String clusterName, String bootstrap, int kafkaBridgeReplicas, String allowedCorsOrigin, String allowedCorsMethods)static io.strimzi.api.kafka.model.KafkaBridgeBuilderkafkaBridgeWithMetrics(String name, String clusterName, String bootstrap)static io.strimzi.api.kafka.model.KafkaBridgeBuilderkafkaBridgeWithMetrics(String name, String clusterName, String bootstrap, int kafkaBridgeReplicas)static io.strimzi.api.kafka.model.KafkaBridgekafkaBridgeWithoutWait(io.strimzi.api.kafka.model.KafkaBridge kafkaBridge)static voidreplaceBridgeResource(String resourceName, Consumer<io.strimzi.api.kafka.model.KafkaBridge> editor)
-
-
-
Method Detail
-
kafkaBridgeClient
public static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.KafkaBridge,io.strimzi.api.kafka.KafkaBridgeList,io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.KafkaBridge>> kafkaBridgeClient()
-
kafkaBridge
public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridge(String name, String bootstrap, int kafkaBridgeReplicas)
-
kafkaBridge
public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridge(String name, String clusterName, String bootstrap, int kafkaBridgeReplicas)
-
kafkaBridgeWithCors
public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridgeWithCors(String name, String bootstrap, int kafkaBridgeReplicas, String allowedCorsOrigin, String allowedCorsMethods)
-
kafkaBridgeWithCors
public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridgeWithCors(String name, String clusterName, String bootstrap, int kafkaBridgeReplicas, String allowedCorsOrigin, String allowedCorsMethods)
-
kafkaBridgeWithMetrics
public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridgeWithMetrics(String name, String clusterName, String bootstrap)
-
kafkaBridgeWithMetrics
public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridgeWithMetrics(String name, String clusterName, String bootstrap, int kafkaBridgeReplicas)
-
createAndWaitForReadiness
public static io.strimzi.api.kafka.model.KafkaBridge createAndWaitForReadiness(io.strimzi.api.kafka.model.KafkaBridge kafkaBridge)
-
kafkaBridgeWithoutWait
public static io.strimzi.api.kafka.model.KafkaBridge kafkaBridgeWithoutWait(io.strimzi.api.kafka.model.KafkaBridge kafkaBridge)
-
deleteKafkaBridgeWithoutWait
public static void deleteKafkaBridgeWithoutWait(String resourceName)
-
-