You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/09/15 10:23:55 UTC
[camel] 02/02: Fixed CS for Camel-Kubernetes component
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2428caf629ece9292e2a6e99e60a6d5a51e87107
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Sun Sep 15 12:19:00 2019 +0200
Fixed CS for Camel-Kubernetes component
---
.../kubernetes/AbstractKubernetesComponent.java | 3 +-
.../kubernetes/AbstractKubernetesEndpoint.java | 3 +-
.../component/kubernetes/KubernetesCategory.java | 24 +--
.../kubernetes/KubernetesConfiguration.java | 31 ++--
.../component/kubernetes/KubernetesHelper.java | 4 +-
.../component/kubernetes/KubernetesOperations.java | 32 ++--
.../cloud/KubernetesClientServiceDiscovery.java | 12 +-
.../cloud/KubernetesDnsServiceDiscovery.java | 10 +-
.../cloud/KubernetesDnsSrvServiceDiscovery.java | 17 +--
.../cluster/KubernetesClusterService.java | 41 +++--
.../kubernetes/cluster/KubernetesClusterView.java | 8 +-
.../cluster/lock/ConfigMapLockUtils.java | 18 +--
.../cluster/lock/KubernetesClusterEvent.java | 3 +-
.../lock/KubernetesLeadershipController.java | 81 ++++------
.../cluster/lock/KubernetesLockConfiguration.java | 18 ++-
.../cluster/lock/TimedLeaderNotifier.java | 3 +-
.../config_maps/KubernetesConfigMapsEndpoint.java | 6 +-
.../config_maps/KubernetesConfigMapsProducer.java | 4 +-
.../deployments/KubernetesDeploymentsConsumer.java | 18 +--
.../deployments/KubernetesDeploymentsEndpoint.java | 7 +-
.../deployments/KubernetesDeploymentsProducer.java | 10 +-
.../kubernetes/hpa/KubernetesHPAEndpoint.java | 7 +-
.../kubernetes/job/KubernetesJobEndpoint.java | 6 +-
.../kubernetes/job/KubernetesJobProducer.java | 3 +-
.../namespaces/KubernetesNamespacesConsumer.java | 22 ++-
.../namespaces/KubernetesNamespacesEndpoint.java | 7 +-
.../namespaces/KubernetesNamespacesProducer.java | 70 +++------
.../kubernetes/nodes/KubernetesNodesConsumer.java | 15 +-
.../kubernetes/nodes/KubernetesNodesEndpoint.java | 7 +-
.../kubernetes/nodes/KubernetesNodesProducer.java | 6 +-
.../KubernetesPersistentVolumesEndpoint.java | 6 +-
.../KubernetesPersistentVolumesProducer.java | 45 ++----
.../KubernetesPersistentVolumesClaimsEndpoint.java | 6 +-
.../KubernetesPersistentVolumesClaimsProducer.java | 126 +++++-----------
.../kubernetes/pods/KubernetesPodsConsumer.java | 13 +-
.../kubernetes/pods/KubernetesPodsEndpoint.java | 7 +-
.../kubernetes/pods/KubernetesPodsProducer.java | 102 +++++--------
.../KubernetesReplicationControllersConsumer.java | 25 ++-
.../KubernetesReplicationControllersEndpoint.java | 8 +-
.../KubernetesReplicationControllersProducer.java | 168 +++++++--------------
.../KubernetesResourcesQuotaEndpoint.java | 6 +-
.../KubernetesResourcesQuotaProducer.java | 120 +++++----------
.../secrets/KubernetesSecretsEndpoint.java | 3 +-
.../secrets/KubernetesSecretsProducer.java | 98 +++++-------
.../KubernetesServiceAccountsEndpoint.java | 6 +-
.../KubernetesServiceAccountsProducer.java | 98 +++++-------
.../services/KubernetesServicesConsumer.java | 21 ++-
.../services/KubernetesServicesEndpoint.java | 7 +-
.../services/KubernetesServicesProducer.java | 109 +++++--------
.../OpenshiftBuildConfigsEndpoint.java | 6 +-
.../OpenshiftBuildConfigsProducer.java | 24 ++-
.../openshift/builds/OpenshiftBuildsEndpoint.java | 3 +-
.../kubernetes/KubernetesTestSupport.java | 2 +-
.../cloud/ServiceCallClientRouteTest.java | 5 +-
.../cloud/ServiceCallEnvironmentRouteTest.java | 5 +-
.../cluster/KubernetesClusterServiceTest.java | 18 +--
.../cluster/TimedLeaderNotifierTest.java | 4 +-
.../cluster/utils/ConfigMapLockSimulator.java | 6 +-
.../kubernetes/cluster/utils/LockTestServer.java | 12 +-
.../cluster/utils/LockTestServerTest.java | 38 +----
.../consumer/KubernetesNamespacesConsumerTest.java | 63 +++-----
.../consumer/KubernetesNodesConsumerTest.java | 23 +--
.../consumer/KubernetesPodsConsumerTest.java | 27 ++--
...bernetesReplicationControllersConsumerTest.java | 35 ++---
.../consumer/KubernetesServicesConsumerTest.java | 25 +--
.../OpenshiftBuildConfigsProducerTest.java | 30 ++--
.../producer/OpenshiftBuildsProducerTest.java | 18 +--
67 files changed, 677 insertions(+), 1137 deletions(-)
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesComponent.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesComponent.java
index 8199613..e21ce0a 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesComponent.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesComponent.java
@@ -25,8 +25,7 @@ import org.apache.camel.util.ObjectHelper;
public abstract class AbstractKubernetesComponent extends DefaultComponent {
@Override
- protected Endpoint createEndpoint(String uri, String remaining,
- Map<String, Object> parameters) throws Exception {
+ protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
KubernetesConfiguration config = new KubernetesConfiguration();
setProperties(config, parameters);
config.setMasterUrl(remaining);
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesEndpoint.java
index 9904f7e..b721db0 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesEndpoint.java
@@ -60,7 +60,7 @@ public abstract class AbstractKubernetesEndpoint extends DefaultEndpoint {
client.close();
}
}
-
+
public ExecutorService createExecutor() {
return getCamelContext().getExecutorServiceManager().newFixedThreadPool(this, "KubernetesConsumer", configuration.getPoolSize());
}
@@ -76,5 +76,4 @@ public abstract class AbstractKubernetesEndpoint extends DefaultEndpoint {
return configuration;
}
-
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesCategory.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesCategory.java
index e69475a..1ce8c0c 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesCategory.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesCategory.java
@@ -19,28 +19,28 @@ package org.apache.camel.component.kubernetes;
public interface KubernetesCategory {
String NAMESPACES = "namespaces";
-
+
String SERVICES = "services";
-
+
String REPLICATION_CONTROLLERS = "replicationControllers";
-
+
String PODS = "pods";
-
+
String PERSISTENT_VOLUMES = "persistentVolumes";
-
+
String PERSISTENT_VOLUMES_CLAIMS = "persistentVolumesClaims";
-
+
String SECRETS = "secrets";
-
+
String RESOURCES_QUOTA = "resourcesQuota";
-
+
String SERVICE_ACCOUNTS = "serviceAccounts";
-
+
String NODES = "nodes";
-
+
String CONFIGMAPS = "configMaps";
-
+
String BUILDS = "builds";
-
+
String BUILD_CONFIGS = "buildConfigs";
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesConfiguration.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesConfiguration.java
index e9025b3..a677eb1 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesConfiguration.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesConfiguration.java
@@ -81,13 +81,13 @@ public class KubernetesConfiguration implements Cloneable {
@UriParam(label = "consumer")
private String namespace;
-
+
@UriParam(label = "consumer")
private String labelKey;
-
+
@UriParam(label = "consumer")
private String labelValue;
-
+
@UriParam(label = "consumer")
private String resourceName;
@@ -99,7 +99,7 @@ public class KubernetesConfiguration implements Cloneable {
@UriParam
private String dnsDomain;
-
+
@UriParam(label = "consumer", defaultValue = "1")
private int poolSize = 1;
@@ -363,7 +363,7 @@ public class KubernetesConfiguration implements Cloneable {
public void setPoolSize(int poolSize) {
this.poolSize = poolSize;
}
-
+
/**
* The Consumer Label key when watching at some resources
*/
@@ -385,7 +385,6 @@ public class KubernetesConfiguration implements Cloneable {
public void setLabelValue(String labelValue) {
this.labelValue = labelValue;
}
-
/**
* The Consumer Resource Name we would like to watch
@@ -403,7 +402,8 @@ public class KubernetesConfiguration implements Cloneable {
}
/**
- * Connection timeout in milliseconds to use when making requests to the Kubernetes API server.
+ * Connection timeout in milliseconds to use when making requests to the
+ * Kubernetes API server.
*/
public void setConnectionTimeout(Integer connectionTimeout) {
this.connectionTimeout = connectionTimeout;
@@ -415,7 +415,7 @@ public class KubernetesConfiguration implements Cloneable {
public KubernetesConfiguration copy() {
try {
- return (KubernetesConfiguration) super.clone();
+ return (KubernetesConfiguration)super.clone();
} catch (CloneNotSupportedException e) {
throw new RuntimeCamelException(e);
}
@@ -423,15 +423,12 @@ public class KubernetesConfiguration implements Cloneable {
@Override
public String toString() {
- return "KubernetesConfiguration [masterUrl=" + masterUrl + ", category=" + category + ", kubernetesClient="
- + kubernetesClient + ", username=" + username + ", password=" + password + ", operation=" + operation
- + ", apiVersion=" + apiVersion + ", caCertData=" + caCertData + ", caCertFile=" + caCertFile
- + ", clientCertData=" + clientCertData + ", clientCertFile=" + clientCertFile + ", clientKeyAlgo="
- + clientKeyAlgo + ", clientKeyData=" + clientKeyData + ", clientKeyFile=" + clientKeyFile
- + ", clientKeyPassphrase=" + clientKeyPassphrase + ", oauthToken=" + oauthToken + ", trustCerts="
- + trustCerts + ", namespace=" + namespace + ", labelKey=" + labelKey + ", labelValue=" + labelValue
- + ", resourceName=" + resourceName + ", portName=" + portName + ", dnsDomain=" + dnsDomain
- + ", poolSize=" + poolSize + ", connectionTimeout=" + connectionTimeout + "]";
+ return "KubernetesConfiguration [masterUrl=" + masterUrl + ", category=" + category + ", kubernetesClient=" + kubernetesClient + ", username=" + username + ", password="
+ + password + ", operation=" + operation + ", apiVersion=" + apiVersion + ", caCertData=" + caCertData + ", caCertFile=" + caCertFile + ", clientCertData="
+ + clientCertData + ", clientCertFile=" + clientCertFile + ", clientKeyAlgo=" + clientKeyAlgo + ", clientKeyData=" + clientKeyData + ", clientKeyFile="
+ + clientKeyFile + ", clientKeyPassphrase=" + clientKeyPassphrase + ", oauthToken=" + oauthToken + ", trustCerts=" + trustCerts + ", namespace=" + namespace
+ + ", labelKey=" + labelKey + ", labelValue=" + labelValue + ", resourceName=" + resourceName + ", portName=" + portName + ", dnsDomain=" + dnsDomain + ", poolSize="
+ + poolSize + ", connectionTimeout=" + connectionTimeout + "]";
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesHelper.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesHelper.java
index 02f4804..c3dfd59 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesHelper.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesHelper.java
@@ -51,9 +51,7 @@ public final class KubernetesHelper {
ConfigBuilder builder = new ConfigBuilder();
builder.withMasterUrl(configuration.getMasterUrl());
- if ((ObjectHelper.isNotEmpty(configuration.getUsername())
- && ObjectHelper.isNotEmpty(configuration.getPassword()))
- && ObjectHelper.isEmpty(configuration.getOauthToken())) {
+ if ((ObjectHelper.isNotEmpty(configuration.getUsername()) && ObjectHelper.isNotEmpty(configuration.getPassword())) && ObjectHelper.isEmpty(configuration.getOauthToken())) {
builder.withUsername(configuration.getUsername());
builder.withPassword(configuration.getPassword());
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesOperations.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesOperations.java
index 6978992..a3d7a0e 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesOperations.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/KubernetesOperations.java
@@ -24,14 +24,14 @@ public interface KubernetesOperations {
String GET_NAMESPACE_OPERATION = "getNamespace";
String CREATE_NAMESPACE_OPERATION = "createNamespace";
String DELETE_NAMESPACE_OPERATION = "deleteNamespace";
-
- // Services
+
+ // Services
String LIST_SERVICES_OPERATION = "listServices";
String LIST_SERVICES_BY_LABELS_OPERATION = "listServicesByLabels";
String GET_SERVICE_OPERATION = "getService";
String CREATE_SERVICE_OPERATION = "createService";
String DELETE_SERVICE_OPERATION = "deleteService";
-
+
// Replication Controllers
String LIST_REPLICATION_CONTROLLERS_OPERATION = "listReplicationControllers";
String LIST_REPLICATION_CONTROLLERS_BY_LABELS_OPERATION = "listReplicationControllersByLabels";
@@ -39,59 +39,59 @@ public interface KubernetesOperations {
String CREATE_REPLICATION_CONTROLLER_OPERATION = "createReplicationController";
String DELETE_REPLICATION_CONTROLLER_OPERATION = "deleteReplicationController";
String SCALE_REPLICATION_CONTROLLER_OPERATION = "scaleReplicationController";
-
+
// Pods
String LIST_PODS_OPERATION = "listPods";
String LIST_PODS_BY_LABELS_OPERATION = "listPodsByLabels";
String GET_POD_OPERATION = "getPod";
String CREATE_POD_OPERATION = "createPod";
String DELETE_POD_OPERATION = "deletePod";
-
+
// Persistent Volumes
String LIST_PERSISTENT_VOLUMES = "listPersistentVolumes";
String LIST_PERSISTENT_VOLUMES_BY_LABELS_OPERATION = "listPersistentVolumesByLabels";
String GET_PERSISTENT_VOLUME_OPERATION = "getPersistentVolume";
-
+
// Persistent Volumes Claims
String LIST_PERSISTENT_VOLUMES_CLAIMS = "listPersistentVolumesClaims";
String LIST_PERSISTENT_VOLUMES_CLAIMS_BY_LABELS_OPERATION = "listPersistentVolumesClaimsByLabels";
String GET_PERSISTENT_VOLUME_CLAIM_OPERATION = "getPersistentVolumeClaim";
String CREATE_PERSISTENT_VOLUME_CLAIM_OPERATION = "createPersistentVolumeClaim";
String DELETE_PERSISTENT_VOLUME_CLAIM_OPERATION = "deletePersistentVolumeClaim";
-
+
// Secrets
String LIST_SECRETS = "listSecrets";
String LIST_SECRETS_BY_LABELS_OPERATION = "listSecretsByLabels";
String GET_SECRET_OPERATION = "getSecret";
String CREATE_SECRET_OPERATION = "createSecret";
String DELETE_SECRET_OPERATION = "deleteSecret";
-
+
// Resources quota
String LIST_RESOURCES_QUOTA = "listResourcesQuota";
String LIST_RESOURCES_QUOTA_BY_LABELS_OPERATION = "listResourcesQuotaByLabels";
String GET_RESOURCE_QUOTA_OPERATION = "getResourceQuota";
String CREATE_RESOURCE_QUOTA_OPERATION = "createResourceQuota";
String DELETE_RESOURCE_QUOTA_OPERATION = "deleteResourceQuota";
-
+
// Service Accounts
String LIST_SERVICE_ACCOUNTS = "listServiceAccounts";
String LIST_SERVICE_ACCOUNTS_BY_LABELS_OPERATION = "listServiceAccountsByLabels";
String GET_SERVICE_ACCOUNT_OPERATION = "getServiceAccount";
String CREATE_SERVICE_ACCOUNT_OPERATION = "createServiceAccount";
String DELETE_SERVICE_ACCOUNT_OPERATION = "deleteServiceAccount";
-
+
// Nodes
String LIST_NODES = "listNodes";
String LIST_NODES_BY_LABELS_OPERATION = "listNodesByLabels";
String GET_NODE_OPERATION = "getNode";
-
+
// HPA
String LIST_HPA = "listHPA";
String LIST_HPA_BY_LABELS_OPERATION = "listHPAByLabels";
String GET_HPA_OPERATION = "getHPA";
String CREATE_HPA_OPERATION = "createHPA";
String DELETE_HPA_OPERATION = "deleteHPA";
-
+
// Deployments
String LIST_DEPLOYMENTS = "listDeployments";
String LIST_DEPLOYMENTS_BY_LABELS_OPERATION = "listDeploymentsByLabels";
@@ -99,24 +99,24 @@ public interface KubernetesOperations {
String DELETE_DEPLOYMENT = "deleteDeployment";
String CREATE_DEPLOYMENT = "createDeployment";
String SCALE_DEPLOYMENT = "scaleDeployment";
-
+
// Config Maps
String LIST_CONFIGMAPS = "listConfigMaps";
String LIST_CONFIGMAPS_BY_LABELS_OPERATION = "listConfigMapsByLabels";
String GET_CONFIGMAP_OPERATION = "getConfigMap";
String CREATE_CONFIGMAP_OPERATION = "createConfigMap";
String DELETE_CONFIGMAP_OPERATION = "deleteConfigMap";
-
+
// Builds
String LIST_BUILD = "listBuilds";
String LIST_BUILD_BY_LABELS_OPERATION = "listBuildsByLabels";
String GET_BUILD_OPERATION = "getBuild";
-
+
// Build Configs
String LIST_BUILD_CONFIGS = "listBuildConfigs";
String LIST_BUILD_CONFIGS_BY_LABELS_OPERATION = "listBuildConfigsByLabels";
String GET_BUILD_CONFIG_OPERATION = "getBuildConfig";
-
+
// Secrets
String LIST_JOB = "listJob";
String LIST_JOB_BY_LABELS_OPERATION = "listJobByLabels";
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesClientServiceDiscovery.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesClientServiceDiscovery.java
index 478532b..8beef79 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesClientServiceDiscovery.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesClientServiceDiscovery.java
@@ -54,8 +54,7 @@ public class KubernetesClientServiceDiscovery extends KubernetesServiceDiscovery
List<ServiceDefinition> result = new ArrayList<>();
if (endpoints != null) {
if (LOG.isDebugEnabled()) {
- LOG.debug("Found {} endpoints in namespace: {} for name: {} and portName: {}",
- endpoints.getSubsets().size(), this.namespace, name, this.portName);
+ LOG.debug("Found {} endpoints in namespace: {} for name: {} and portName: {}", endpoints.getSubsets().size(), this.namespace, name, this.portName);
}
for (EndpointSubset subset : endpoints.getSubsets()) {
if (subset.getPorts().size() == 1) {
@@ -98,9 +97,7 @@ public class KubernetesClientServiceDiscovery extends KubernetesServiceDiscovery
ConfigBuilder builder = new ConfigBuilder();
builder.withMasterUrl(configuration.getMasterUrl());
- if ((ObjectHelper.isNotEmpty(configuration.getUsername())
- && ObjectHelper.isNotEmpty(configuration.getPassword()))
- && ObjectHelper.isEmpty(configuration.getOauthToken())) {
+ if ((ObjectHelper.isNotEmpty(configuration.getUsername()) && ObjectHelper.isNotEmpty(configuration.getPassword())) && ObjectHelper.isEmpty(configuration.getOauthToken())) {
builder.withUsername(configuration.getUsername());
builder.withPassword(configuration.getPassword());
} else {
@@ -150,9 +147,6 @@ public class KubernetesClientServiceDiscovery extends KubernetesServiceDiscovery
@Override
public String toString() {
- return "KubernetesClientServiceDiscovery{"
- + "namespace='" + namespace + '\''
- + ", portName='" + portName + '\''
- + '}';
+ return "KubernetesClientServiceDiscovery{" + "namespace='" + namespace + '\'' + ", portName='" + portName + '\'' + '}';
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsServiceDiscovery.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsServiceDiscovery.java
index 9e16a3a..38a0343 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsServiceDiscovery.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsServiceDiscovery.java
@@ -50,17 +50,11 @@ public class KubernetesDnsServiceDiscovery extends KubernetesServiceDiscovery {
}
private ServiceDefinition newService(String name) {
- return new DefaultServiceDefinition(
- name,
- name + "." + getConfiguration().getNamespace() + ".svc." + getConfiguration().getDnsDomain(),
- -1);
+ return new DefaultServiceDefinition(name, name + "." + getConfiguration().getNamespace() + ".svc." + getConfiguration().getDnsDomain(), -1);
}
@Override
public String toString() {
- return "KubernetesDnsServiceDiscovery{"
- + "namespace='" + namespace + '\''
- + ", zone='" + zone + '\''
- + '}';
+ return "KubernetesDnsServiceDiscovery{" + "namespace='" + namespace + '\'' + ", zone='" + zone + '\'' + '}';
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsSrvServiceDiscovery.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsSrvServiceDiscovery.java
index 1d66ade..8b73f76 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsSrvServiceDiscovery.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsSrvServiceDiscovery.java
@@ -75,7 +75,6 @@ public class KubernetesDnsSrvServiceDiscovery extends KubernetesServiceDiscovery
/**
* Compute the query string to lookup SRV records.
- *
* https://kubernetes.io/docs/concepts/services-networking/dns-pod-service/#supported-dns-schema
* https://github.com/kubernetes/dns/blob/master/docs/specification.md
*
@@ -84,13 +83,7 @@ public class KubernetesDnsSrvServiceDiscovery extends KubernetesServiceDiscovery
*/
protected String computeQueryString(String serviceName) {
// _<port_name>._<port_proto>.<serviceName>.<namespace>.svc.<zone>.
- return String.format("_%s._%s.%s.%s.svc.%s",
- this.portName,
- this.portProtocol,
- serviceName,
- this.namespace,
- this.zone
- );
+ return String.format("_%s._%s.%s.%s.svc.%s", this.portName, this.portProtocol, serviceName, this.namespace, this.zone);
}
@Override
@@ -135,11 +128,7 @@ public class KubernetesDnsSrvServiceDiscovery extends KubernetesServiceDiscovery
@Override
public String toString() {
- return "KubernetesDnsSrvServiceDiscovery{"
- + "namespace='" + namespace + '\''
- + ", portName='" + portName + '\''
- + ", portProtocol='" + portProtocol + '\''
- + ", zone='" + zone + '\''
- + '}';
+ return "KubernetesDnsSrvServiceDiscovery{" + "namespace='" + namespace + '\'' + ", portName='" + portName + '\'' + ", portProtocol='" + portProtocol + '\'' + ", zone='"
+ + zone + '\'' + '}';
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterService.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterService.java
index 84de5fd..ce449ea 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterService.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterService.java
@@ -27,7 +27,8 @@ import org.apache.camel.support.cluster.AbstractCamelClusterService;
import org.apache.camel.util.ObjectHelper;
/**
- * A Kubernetes based cluster service leveraging Kubernetes optimistic locks on resources (specifically ConfigMaps).
+ * A Kubernetes based cluster service leveraging Kubernetes optimistic locks on
+ * resources (specifically ConfigMaps).
*/
public class KubernetesClusterService extends AbstractCamelClusterService<KubernetesClusterView> {
@@ -60,9 +61,10 @@ public class KubernetesClusterService extends AbstractCamelClusterService<Kubern
protected KubernetesConfiguration setConfigDefaults(KubernetesConfiguration configuration, KubernetesLockConfiguration lockConfiguration) {
if (configuration.getConnectionTimeout() == null) {
- // Set the connection timeout to be much lower than the renewal deadline,
+ // Set the connection timeout to be much lower than the renewal
+ // deadline,
// to avoid losing the leadership in case of stale connections
- int timeout = (int) (lockConfiguration.getRenewDeadlineMillis() / 3);
+ int timeout = (int)(lockConfiguration.getRenewDeadlineMillis() / 3);
timeout = Math.max(timeout, 3000);
timeout = Math.min(timeout, 30000);
configuration.setConnectionTimeout(timeout);
@@ -103,12 +105,12 @@ public class KubernetesClusterService extends AbstractCamelClusterService<Kubern
throw new IllegalStateException("leaseDurationMillis must be > 0 (found: " + config.getLeaseDurationMillis() + ")");
}
if (config.getLeaseDurationMillis() <= config.getRenewDeadlineMillis()) {
- throw new IllegalStateException("leaseDurationMillis must be greater than renewDeadlineMillis "
- + "(" + config.getLeaseDurationMillis() + " is not greater than " + config.getRenewDeadlineMillis() + ")");
+ throw new IllegalStateException("leaseDurationMillis must be greater than renewDeadlineMillis " + "(" + config.getLeaseDurationMillis() + " is not greater than "
+ + config.getRenewDeadlineMillis() + ")");
}
if (config.getRenewDeadlineMillis() <= config.getJitterFactor() * config.getRetryPeriodMillis()) {
- throw new IllegalStateException("renewDeadlineMillis must be greater than jitterFactor*retryPeriodMillis "
- + "(" + config.getRenewDeadlineMillis() + " is not greater than " + config.getJitterFactor() + "*" + config.getRetryPeriodMillis() + ")");
+ throw new IllegalStateException("renewDeadlineMillis must be greater than jitterFactor*retryPeriodMillis " + "(" + config.getRenewDeadlineMillis()
+ + " is not greater than " + config.getJitterFactor() + "*" + config.getRetryPeriodMillis() + ")");
}
return config;
@@ -119,7 +121,8 @@ public class KubernetesClusterService extends AbstractCamelClusterService<Kubern
}
/**
- * Set the URL of the Kubernetes master (read from Kubernetes client properties by default).
+ * Set the URL of the Kubernetes master (read from Kubernetes client
+ * properties by default).
*/
public void setMasterUrl(String masterUrl) {
configuration.setMasterUrl(masterUrl);
@@ -130,7 +133,8 @@ public class KubernetesClusterService extends AbstractCamelClusterService<Kubern
}
/**
- * Connection timeout in milliseconds to use when making requests to the Kubernetes API server.
+ * Connection timeout in milliseconds to use when making requests to the
+ * Kubernetes API server.
*/
public void setConnectionTimeoutMillis(Integer connectionTimeout) {
configuration.setConnectionTimeout(connectionTimeout);
@@ -141,7 +145,8 @@ public class KubernetesClusterService extends AbstractCamelClusterService<Kubern
}
/**
- * Set the name of the Kubernetes namespace containing the pods and the configmap (autodetected by default)
+ * Set the name of the Kubernetes namespace containing the pods and the
+ * configmap (autodetected by default)
*/
public void setKubernetesNamespace(String kubernetesNamespace) {
this.lockConfiguration.setKubernetesResourcesNamespace(kubernetesNamespace);
@@ -152,7 +157,8 @@ public class KubernetesClusterService extends AbstractCamelClusterService<Kubern
}
/**
- * Set the name of the ConfigMap used to do optimistic locking (defaults to 'leaders').
+ * Set the name of the ConfigMap used to do optimistic locking (defaults to
+ * 'leaders').
*/
public void setConfigMapName(String configMapName) {
this.lockConfiguration.setConfigMapName(configMapName);
@@ -163,7 +169,8 @@ public class KubernetesClusterService extends AbstractCamelClusterService<Kubern
}
/**
- * Set the name of the current pod (autodetected from container host name by default).
+ * Set the name of the current pod (autodetected from container host name by
+ * default).
*/
public void setPodName(String podName) {
this.lockConfiguration.setPodName(podName);
@@ -189,7 +196,8 @@ public class KubernetesClusterService extends AbstractCamelClusterService<Kubern
}
/**
- * A jitter factor to apply in order to prevent all pods to call Kubernetes APIs in the same instant.
+ * A jitter factor to apply in order to prevent all pods to call Kubernetes
+ * APIs in the same instant.
*/
public void setJitterFactor(double jitterFactor) {
lockConfiguration.setJitterFactor(jitterFactor);
@@ -211,7 +219,8 @@ public class KubernetesClusterService extends AbstractCamelClusterService<Kubern
}
/**
- * The deadline after which the leader must stop its services because it may have lost the leadership.
+ * The deadline after which the leader must stop its services because it may
+ * have lost the leadership.
*/
public void setRenewDeadlineMillis(long renewDeadlineMillis) {
lockConfiguration.setRenewDeadlineMillis(renewDeadlineMillis);
@@ -222,8 +231,8 @@ public class KubernetesClusterService extends AbstractCamelClusterService<Kubern
}
/**
- * The time between two subsequent attempts to check and acquire the leadership.
- * It is randomized using the jitter factor.
+ * The time between two subsequent attempts to check and acquire the
+ * leadership. It is randomized using the jitter factor.
*/
public void setRetryPeriodMillis(long retryPeriodMillis) {
lockConfiguration.setRetryPeriodMillis(retryPeriodMillis);
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterView.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterView.java
index ba22e7f..4d47b71 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterView.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterView.java
@@ -38,8 +38,9 @@ import org.apache.camel.support.cluster.AbstractCamelClusterView;
import org.apache.camel.util.ObjectHelper;
/**
- * The cluster view on a specific Camel cluster namespace (not to be confused with Kubernetes namespaces).
- * Namespaces are represented as keys in a Kubernetes ConfigMap (values are the current leader pods).
+ * The cluster view on a specific Camel cluster namespace (not to be confused
+ * with Kubernetes namespaces). Namespaces are represented as keys in a
+ * Kubernetes ConfigMap (values are the current leader pods).
*/
public class KubernetesClusterView extends AbstractCamelClusterView {
@@ -61,7 +62,8 @@ public class KubernetesClusterView extends AbstractCamelClusterView {
private KubernetesLeadershipController controller;
- public KubernetesClusterView(CamelContext camelContext, KubernetesClusterService cluster, KubernetesConfiguration configuration, KubernetesLockConfiguration lockConfiguration) {
+ public KubernetesClusterView(CamelContext camelContext, KubernetesClusterService cluster, KubernetesConfiguration configuration,
+ KubernetesLockConfiguration lockConfiguration) {
super(cluster, lockConfiguration.getGroupName());
this.camelContext = ObjectHelper.notNull(camelContext, "camelContext");
this.configuration = ObjectHelper.notNull(configuration, "configuration");
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/ConfigMapLockUtils.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/ConfigMapLockUtils.java
index 7e9568a..a0589f8 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/ConfigMapLockUtils.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/ConfigMapLockUtils.java
@@ -43,22 +43,14 @@ public final class ConfigMapLockUtils {
}
public static ConfigMap createNewConfigMap(String configMapName, LeaderInfo leaderInfo) {
- return new ConfigMapBuilder().
- withNewMetadata()
- .withName(configMapName)
- .addToLabels("provider", "camel")
- .addToLabels("kind", "locks").
- endMetadata()
- .addToData(LEADER_PREFIX + leaderInfo.getGroupName(), leaderInfo.getLeader())
- .addToData(LOCAL_TIMESTAMP_PREFIX + leaderInfo.getGroupName(), formatDate(leaderInfo.getLocalTimestamp()))
- .build();
+ return new ConfigMapBuilder().withNewMetadata().withName(configMapName).addToLabels("provider", "camel").addToLabels("kind", "locks").endMetadata()
+ .addToData(LEADER_PREFIX + leaderInfo.getGroupName(), leaderInfo.getLeader())
+ .addToData(LOCAL_TIMESTAMP_PREFIX + leaderInfo.getGroupName(), formatDate(leaderInfo.getLocalTimestamp())).build();
}
public static ConfigMap getConfigMapWithNewLeader(ConfigMap configMap, LeaderInfo leaderInfo) {
- return new ConfigMapBuilder(configMap)
- .addToData(LEADER_PREFIX + leaderInfo.getGroupName(), leaderInfo.getLeader())
- .addToData(LOCAL_TIMESTAMP_PREFIX + leaderInfo.getGroupName(), formatDate(leaderInfo.getLocalTimestamp()))
- .build();
+ return new ConfigMapBuilder(configMap).addToData(LEADER_PREFIX + leaderInfo.getGroupName(), leaderInfo.getLeader())
+ .addToData(LOCAL_TIMESTAMP_PREFIX + leaderInfo.getGroupName(), formatDate(leaderInfo.getLocalTimestamp())).build();
}
public static LeaderInfo getLeaderInfo(ConfigMap configMap, Set<String> members, String group) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesClusterEvent.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesClusterEvent.java
index 4759e72..78668f0 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesClusterEvent.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesClusterEvent.java
@@ -28,7 +28,8 @@ public interface KubernetesClusterEvent {
Object getData();
/**
- * Event signalling that the list of members of the Kubernetes cluster has changed.
+ * Event signalling that the list of members of the Kubernetes cluster has
+ * changed.
*/
interface KubernetesClusterMemberListChangedEvent extends KubernetesClusterEvent {
@Override
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLeadershipController.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLeadershipController.java
index 2035253..6ff1f6d 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLeadershipController.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLeadershipController.java
@@ -36,17 +36,16 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Monitors current status and participate to leader election when no active leaders are present.
- * It communicates changes in leadership and cluster members to the given event handler.
+ * Monitors current status and participate to leader election when no active
+ * leaders are present. It communicates changes in leadership and cluster
+ * members to the given event handler.
*/
public class KubernetesLeadershipController implements Service {
private static final Logger LOG = LoggerFactory.getLogger(KubernetesLeadershipController.class);
private enum State {
- NOT_LEADER,
- BECOMING_LEADER,
- LEADER
+ NOT_LEADER, BECOMING_LEADER, LEADER
}
private CamelContext camelContext;
@@ -67,7 +66,8 @@ public class KubernetesLeadershipController implements Service {
private volatile ConfigMap latestConfigMap;
private volatile Set<String> latestMembers;
- public KubernetesLeadershipController(CamelContext camelContext, KubernetesClient kubernetesClient, KubernetesLockConfiguration lockConfiguration, KubernetesClusterEventHandler eventHandler) {
+ public KubernetesLeadershipController(CamelContext camelContext, KubernetesClient kubernetesClient, KubernetesLockConfiguration lockConfiguration,
+ KubernetesClusterEventHandler eventHandler) {
this.camelContext = camelContext;
this.kubernetesClient = kubernetesClient;
this.lockConfiguration = lockConfiguration;
@@ -117,8 +117,8 @@ public class KubernetesLeadershipController implements Service {
}
/**
- * This pod is currently not leader. It should monitor the leader configuration and try
- * to acquire the leadership if possible.
+ * This pod is currently not leader. It should monitor the leader
+ * configuration and try to acquire the leadership if possible.
*/
private void refreshStatusNotLeader() {
LOG.debug("{} Pod is not leader, pulling new data from the cluster", logPrefix());
@@ -160,23 +160,22 @@ public class KubernetesLeadershipController implements Service {
return;
}
- this.leaderNotifier.refreshLeadership(Optional.ofNullable(this.latestLeaderInfo.getLeader()),
- System.currentTimeMillis(),
- this.lockConfiguration.getLeaseDurationMillis(),
- this.latestLeaderInfo.getMembers());
+ this.leaderNotifier.refreshLeadership(Optional.ofNullable(this.latestLeaderInfo.getLeader()), System.currentTimeMillis(), this.lockConfiguration.getLeaseDurationMillis(),
+ this.latestLeaderInfo.getMembers());
rescheduleAfterDelay();
}
/**
- * This pod has acquired the leadership but it should wait for the old leader
- * to tear down resources before starting the local services.
+ * This pod has acquired the leadership but it should wait for the old
+ * leader to tear down resources before starting the local services.
*/
private void refreshStatusBecomingLeader() {
// Wait always the same amount of time before becoming the leader
- // Even if the current pod is already leader, we should let a possible old version of the pod to shut down
+ // Even if the current pod is already leader, we should let a possible
+ // old version of the pod to shut down
long delay = this.lockConfiguration.getLeaseDurationMillis();
- LOG.info("{} Current pod owns the leadership, but it will be effective in {} seconds...", logPrefix(), new BigDecimal(delay).divide(BigDecimal
- .valueOf(1000), 2, BigDecimal.ROUND_HALF_UP));
+ LOG.info("{} Current pod owns the leadership, but it will be effective in {} seconds...", logPrefix(),
+ new BigDecimal(delay).divide(BigDecimal.valueOf(1000), 2, BigDecimal.ROUND_HALF_UP));
try {
Thread.sleep(delay);
@@ -200,20 +199,15 @@ public class KubernetesLeadershipController implements Service {
if (this.latestLeaderInfo.isValidLeader(this.lockConfiguration.getPodName())) {
LOG.debug("{} Current Pod is still the leader", logPrefix());
- this.leaderNotifier.refreshLeadership(Optional.of(this.lockConfiguration.getPodName()),
- timeBeforePulling,
- this.lockConfiguration.getRenewDeadlineMillis(),
- this.latestLeaderInfo.getMembers());
+ this.leaderNotifier.refreshLeadership(Optional.of(this.lockConfiguration.getPodName()), timeBeforePulling, this.lockConfiguration.getRenewDeadlineMillis(),
+ this.latestLeaderInfo.getMembers());
rescheduleAfterDelay();
return;
} else {
LOG.debug("{} Current Pod has lost the leadership", logPrefix());
this.currentState = State.NOT_LEADER;
// set a empty leader to signal leadership loss
- this.leaderNotifier.refreshLeadership(Optional.empty(),
- System.currentTimeMillis(),
- lockConfiguration.getLeaseDurationMillis(),
- this.latestLeaderInfo.getMembers());
+ this.leaderNotifier.refreshLeadership(Optional.empty(), System.currentTimeMillis(), lockConfiguration.getLeaseDurationMillis(), this.latestLeaderInfo.getMembers());
// restart from scratch to acquire leadership
this.serializedExecutor.execute(this::refreshStatus);
@@ -221,7 +215,8 @@ public class KubernetesLeadershipController implements Service {
}
private void rescheduleAfterDelay() {
- this.serializedExecutor.schedule(this::refreshStatus, jitter(this.lockConfiguration.getRetryPeriodMillis(), this.lockConfiguration.getJitterFactor()), TimeUnit.MILLISECONDS);
+ this.serializedExecutor.schedule(this::refreshStatus, jitter(this.lockConfiguration.getRetryPeriodMillis(), this.lockConfiguration.getJitterFactor()),
+ TimeUnit.MILLISECONDS);
}
private boolean lookupNewLeaderInfo() {
@@ -260,8 +255,7 @@ public class KubernetesLeadershipController implements Service {
LOG.warn(logPrefix() + " Unexpected condition. Latest leader info or list of members is empty.");
return false;
} else if (!members.contains(this.lockConfiguration.getPodName())) {
- LOG.warn(logPrefix() + " The list of cluster members " + latestLeaderInfo.getMembers() + " does not contain the current Pod. Cannot acquire"
- + " leadership.");
+ LOG.warn(logPrefix() + " The list of cluster members " + latestLeaderInfo.getMembers() + " does not contain the current Pod. Cannot acquire" + " leadership.");
return false;
}
@@ -274,18 +268,16 @@ public class KubernetesLeadershipController implements Service {
ConfigMap newConfigMap = ConfigMapLockUtils.createNewConfigMap(this.lockConfiguration.getConfigMapName(), newLeaderInfo);
try {
- kubernetesClient.configMaps()
- .inNamespace(this.lockConfiguration.getKubernetesResourcesNamespaceOrDefault(kubernetesClient))
- .create(newConfigMap);
+ kubernetesClient.configMaps().inNamespace(this.lockConfiguration.getKubernetesResourcesNamespaceOrDefault(kubernetesClient)).create(newConfigMap);
LOG.debug("{} ConfigMap {} successfully created", logPrefix(), this.lockConfiguration.getConfigMapName());
updateLatestLeaderInfo(newConfigMap, members);
return true;
} catch (Exception ex) {
// Suppress exception
- LOG.warn(logPrefix() + " Unable to create the ConfigMap, it may have been created by other cluster members concurrently. If the problem persists, check if the service account has "
- + "the right "
- + "permissions to create it");
+ LOG.warn(logPrefix()
+ + " Unable to create the ConfigMap, it may have been created by other cluster members concurrently. If the problem persists, check if the service account has "
+ + "the right " + "permissions to create it");
LOG.debug(logPrefix() + " Exception while trying to create the ConfigMap", ex);
return false;
}
@@ -298,11 +290,8 @@ public class KubernetesLeadershipController implements Service {
// Try to be the new leader
try {
ConfigMap updatedConfigMap = ConfigMapLockUtils.getConfigMapWithNewLeader(configMap, newLeaderInfo);
- kubernetesClient.configMaps()
- .inNamespace(this.lockConfiguration.getKubernetesResourcesNamespaceOrDefault(kubernetesClient))
- .withName(this.lockConfiguration.getConfigMapName())
- .lockResourceVersion(configMap.getMetadata().getResourceVersion())
- .replace(updatedConfigMap);
+ kubernetesClient.configMaps().inNamespace(this.lockConfiguration.getKubernetesResourcesNamespaceOrDefault(kubernetesClient))
+ .withName(this.lockConfiguration.getConfigMapName()).lockResourceVersion(configMap.getMetadata().getResourceVersion()).replace(updatedConfigMap);
LOG.debug("{} ConfigMap {} successfully updated", logPrefix(), this.lockConfiguration.getConfigMapName());
updateLatestLeaderInfo(updatedConfigMap, members);
@@ -329,23 +318,19 @@ public class KubernetesLeadershipController implements Service {
}
private ConfigMap pullConfigMap() {
- return kubernetesClient.configMaps()
- .inNamespace(this.lockConfiguration.getKubernetesResourcesNamespaceOrDefault(kubernetesClient))
- .withName(this.lockConfiguration.getConfigMapName())
- .get();
+ return kubernetesClient.configMaps().inNamespace(this.lockConfiguration.getKubernetesResourcesNamespaceOrDefault(kubernetesClient))
+ .withName(this.lockConfiguration.getConfigMapName()).get();
}
private Set<String> pullClusterMembers() {
- List<Pod> pods = kubernetesClient.pods()
- .inNamespace(this.lockConfiguration.getKubernetesResourcesNamespaceOrDefault(kubernetesClient))
- .withLabels(this.lockConfiguration.getClusterLabels())
- .list().getItems();
+ List<Pod> pods = kubernetesClient.pods().inNamespace(this.lockConfiguration.getKubernetesResourcesNamespaceOrDefault(kubernetesClient))
+ .withLabels(this.lockConfiguration.getClusterLabels()).list().getItems();
return pods.stream().map(pod -> pod.getMetadata().getName()).collect(Collectors.toSet());
}
private long jitter(long num, double factor) {
- return (long) (num * (1 + Math.random() * (factor - 1)));
+ return (long)(num * (1 + Math.random() * (factor - 1)));
}
private String logPrefix() {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLockConfiguration.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLockConfiguration.java
index c1877ec..c4765a5 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLockConfiguration.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLockConfiguration.java
@@ -34,7 +34,8 @@ public class KubernetesLockConfiguration implements Cloneable {
public static final long DEFAULT_RETRY_PERIOD_MILLIS = 5000;
/**
- * Kubernetes namespace containing the pods and the ConfigMap used for locking.
+ * Kubernetes namespace containing the pods and the ConfigMap used for
+ * locking.
*/
private String kubernetesResourcesNamespace;
@@ -44,7 +45,8 @@ public class KubernetesLockConfiguration implements Cloneable {
private String configMapName = DEFAULT_CONFIGMAP_NAME;
/**
- * Name of the lock group (or namespace according to the Camel cluster convention) within the chosen ConfigMap.
+ * Name of the lock group (or namespace according to the Camel cluster
+ * convention) within the chosen ConfigMap.
*/
private String groupName;
@@ -59,7 +61,8 @@ public class KubernetesLockConfiguration implements Cloneable {
private Map<String, String> clusterLabels = new HashMap<>();
/**
- * A jitter factor to apply in order to prevent all pods to call Kubernetes APIs in the same instant.
+ * A jitter factor to apply in order to prevent all pods to call Kubernetes
+ * APIs in the same instant.
*/
private double jitterFactor = DEFAULT_JITTER_FACTOR;
@@ -69,13 +72,14 @@ public class KubernetesLockConfiguration implements Cloneable {
private long leaseDurationMillis = DEFAULT_LEASE_DURATION_MILLIS;
/**
- * The deadline after which the leader must stop its services because it may have lost the leadership.
+ * The deadline after which the leader must stop its services because it may
+ * have lost the leadership.
*/
private long renewDeadlineMillis = DEFAULT_RENEW_DEADLINE_MILLIS;
/**
- * The time between two subsequent attempts to check and acquire the leadership.
- * It is randomized using the jitter factor.
+ * The time between two subsequent attempts to check and acquire the
+ * leadership. It is randomized using the jitter factor.
*/
private long retryPeriodMillis = DEFAULT_RETRY_PERIOD_MILLIS;
@@ -167,7 +171,7 @@ public class KubernetesLockConfiguration implements Cloneable {
public KubernetesLockConfiguration copy() {
try {
- KubernetesLockConfiguration copy = (KubernetesLockConfiguration) this.clone();
+ KubernetesLockConfiguration copy = (KubernetesLockConfiguration)this.clone();
return copy;
} catch (CloneNotSupportedException e) {
throw new IllegalStateException("Cannot clone", e);
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/TimedLeaderNotifier.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/TimedLeaderNotifier.java
index 383b4b9..53d6f0a 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/TimedLeaderNotifier.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/TimedLeaderNotifier.java
@@ -31,7 +31,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Receives information about the current leader and handles expiration automatically.
+ * Receives information about the current leader and handles expiration
+ * automatically.
*/
public class TimedLeaderNotifier implements Service {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java
index 96fbf5a..616dbfc 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java
@@ -26,10 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Configmaps component provides a producer to execute kubernetes configmap operations.
+ * The Kubernetes Configmaps component provides a producer to execute kubernetes
+ * configmap operations.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-config-maps", title = "Kubernetes ConfigMap",
- syntax = "kubernetes-config-maps:masterUrl", producerOnly = true, label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-config-maps", title = "Kubernetes ConfigMap", syntax = "kubernetes-config-maps:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesConfigMapsEndpoint extends AbstractKubernetesEndpoint {
public KubernetesConfigMapsEndpoint(String uri, KubernetesConfigMapsComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsProducer.java
index b0ac985..d756e20 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsProducer.java
@@ -84,8 +84,8 @@ public class KubernetesConfigMapsProducer extends DefaultProducer {
protected void doList(Exchange exchange, String operation) throws Exception {
ConfigMapList configMapsList = getEndpoint().getKubernetesClient().configMaps().inAnyNamespace().list();
-
- MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
+
+ MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(configMapsList.getItems());
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsConsumer.java
index 685730e..f453631 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsConsumer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsConsumer.java
@@ -49,7 +49,7 @@ public class KubernetesDeploymentsConsumer extends DefaultConsumer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
@@ -83,13 +83,14 @@ public class KubernetesDeploymentsConsumer extends DefaultConsumer {
}
class DeploymentsConsumerTask implements Runnable {
-
+
private Watch watch;
-
+
@Override
public void run() {
- NonNamespaceOperation<Deployment, DeploymentList, DoneableDeployment, RollableScalableResource<Deployment, DoneableDeployment>> w = getEndpoint().getKubernetesClient().apps().deployments();
- if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelKey())
+ NonNamespaceOperation<Deployment, DeploymentList, DoneableDeployment, RollableScalableResource<Deployment, DoneableDeployment>> w = getEndpoint().getKubernetesClient()
+ .apps().deployments();
+ if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelKey())
&& ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelValue())) {
w.withLabel(getEndpoint().getKubernetesConfiguration().getLabelKey(), getEndpoint().getKubernetesConfiguration().getLabelValue());
}
@@ -99,8 +100,7 @@ public class KubernetesDeploymentsConsumer extends DefaultConsumer {
watch = w.watch(new Watcher<Deployment>() {
@Override
- public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action,
- Deployment resource) {
+ public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, Deployment resource) {
DeploymentEvent de = new DeploymentEvent(action, resource);
Exchange exchange = getEndpoint().createExchange();
exchange.getIn().setBody(de.getDeployment());
@@ -122,13 +122,13 @@ public class KubernetesDeploymentsConsumer extends DefaultConsumer {
}
});
}
-
+
public Watch getWatch() {
return watch;
}
public void setWatch(Watch watch) {
this.watch = watch;
- }
+ }
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java
index 45db07c..dc6b73f 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java
@@ -26,11 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Nodes component provides a producer to execute kubernetes node operations
- * and a consumer to consume node events.
+ * The Kubernetes Nodes component provides a producer to execute kubernetes node
+ * operations and a consumer to consume node events.
*/
-@UriEndpoint(firstVersion = "2.20.0", scheme = "kubernetes-deployments", title = "Kubernetes Deployments",
- syntax = "kubernetes-deployments:masterUrl", label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.20.0", scheme = "kubernetes-deployments", title = "Kubernetes Deployments", syntax = "kubernetes-deployments:masterUrl", label = "container,cloud,paas")
public class KubernetesDeploymentsEndpoint extends AbstractKubernetesEndpoint {
public KubernetesDeploymentsEndpoint(String uri, KubernetesDeploymentsComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
index 45735c1..1114b08 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
@@ -43,7 +43,7 @@ public class KubernetesDeploymentsProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
@@ -77,7 +77,7 @@ public class KubernetesDeploymentsProducer extends DefaultProducer {
case KubernetesOperations.CREATE_DEPLOYMENT:
doCreateDeployment(exchange, operation);
break;
-
+
case KubernetesOperations.SCALE_DEPLOYMENT:
doScaleDeployment(exchange, operation);
break;
@@ -97,8 +97,8 @@ public class KubernetesDeploymentsProducer extends DefaultProducer {
protected void doListDeploymentsByLabels(Exchange exchange, String operation) throws Exception {
DeploymentList deploymentList = null;
Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_DEPLOYMENTS_LABELS, Map.class);
- NonNamespaceOperation<Deployment, DeploymentList, DoneableDeployment, RollableScalableResource<Deployment, DoneableDeployment>> deployments = getEndpoint().getKubernetesClient()
- .apps().deployments();
+ NonNamespaceOperation<Deployment, DeploymentList, DoneableDeployment, RollableScalableResource<Deployment, DoneableDeployment>> deployments = getEndpoint()
+ .getKubernetesClient().apps().deployments();
for (Map.Entry<String, String> entry : labels.entrySet()) {
deployments.withLabel(entry.getKey(), entry.getValue());
}
@@ -163,7 +163,7 @@ public class KubernetesDeploymentsProducer extends DefaultProducer {
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(deployment);
}
-
+
protected void doScaleDeployment(Exchange exchange, String operation) throws Exception {
String deploymentName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_DEPLOYMENT_NAME, String.class);
String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java
index 5323866..0ab76f5 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java
@@ -26,11 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes HPA component provides a producer to execute kubernetes hpa operations
- * and a consumer to consume HPA events.
+ * The Kubernetes HPA component provides a producer to execute kubernetes hpa
+ * operations and a consumer to consume HPA events.
*/
-@UriEndpoint(firstVersion = "2.23.0", scheme = "kubernetes-hpa", title = "Kubernetes HPA",
- syntax = "kubernetes-hpa:masterUrl", label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.23.0", scheme = "kubernetes-hpa", title = "Kubernetes HPA", syntax = "kubernetes-hpa:masterUrl", label = "container,cloud,paas")
public class KubernetesHPAEndpoint extends AbstractKubernetesEndpoint {
public KubernetesHPAEndpoint(String uri, KubernetesHPAComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobEndpoint.java
index 9862ae0..a5c09c5 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobEndpoint.java
@@ -26,10 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Jobs component provides a producer to execute kubernetes job operations
+ * The Kubernetes Jobs component provides a producer to execute kubernetes job
+ * operations
*/
-@UriEndpoint(firstVersion = "2.23.0", scheme = "kubernetes-job", title = "Kubernetes Job",
- syntax = "kubernetes-job:masterUrl", label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.23.0", scheme = "kubernetes-job", title = "Kubernetes Job", syntax = "kubernetes-job:masterUrl", label = "container,cloud,paas")
public class KubernetesJobEndpoint extends AbstractKubernetesEndpoint {
public KubernetesJobEndpoint(String uri, KubernetesJobComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobProducer.java
index 0ddee73..9ab6186 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobProducer.java
@@ -96,8 +96,7 @@ public class KubernetesJobProducer extends DefaultProducer {
throw new IllegalArgumentException("Get Job by labels require specify a labels set");
}
- FilterWatchListMultiDeletable<Job, JobList, Boolean, Watch, Watcher<Job>> jobs = getEndpoint()
- .getKubernetesClient().batch().jobs();
+ FilterWatchListMultiDeletable<Job, JobList, Boolean, Watch, Watcher<Job>> jobs = getEndpoint().getKubernetesClient().batch().jobs();
for (Map.Entry<String, String> entry : labels.entrySet()) {
jobs.withLabel(entry.getKey(), entry.getValue());
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesConsumer.java
index d7ae909..33957bf 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesConsumer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesConsumer.java
@@ -48,14 +48,14 @@ public class KubernetesNamespacesConsumer extends DefaultConsumer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
protected void doStart() throws Exception {
super.doStart();
executor = getEndpoint().createExecutor();
-
+
nsWatcher = new NamespacesConsumerTask();
executor.submit(nsWatcher);
}
@@ -63,7 +63,7 @@ public class KubernetesNamespacesConsumer extends DefaultConsumer {
@Override
protected void doStop() throws Exception {
super.doStop();
-
+
log.debug("Stopping Kubernetes Namespace Consumer");
if (executor != null) {
if (getEndpoint() != null && getEndpoint().getCamelContext() != null) {
@@ -80,11 +80,11 @@ public class KubernetesNamespacesConsumer extends DefaultConsumer {
}
executor = null;
}
-
+
class NamespacesConsumerTask implements Runnable {
private Watch watch;
-
+
@Override
public void run() {
NonNamespaceOperation<Namespace, NamespaceList, DoneableNamespace, Resource<Namespace, DoneableNamespace>> w = getEndpoint().getKubernetesClient().namespaces();
@@ -94,8 +94,7 @@ public class KubernetesNamespacesConsumer extends DefaultConsumer {
watch = w.watch(new Watcher<Namespace>() {
@Override
- public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action,
- Namespace resource) {
+ public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, Namespace resource) {
NamespaceEvent ne = new NamespaceEvent(action, resource);
Exchange exchange = getEndpoint().createExchange();
exchange.getIn().setBody(ne.getNamespace());
@@ -105,25 +104,24 @@ public class KubernetesNamespacesConsumer extends DefaultConsumer {
processor.process(exchange);
} catch (Exception e) {
getExceptionHandler().handleException("Error during processing", exchange, e);
- }
+ }
}
@Override
public void onClose(KubernetesClientException cause) {
if (cause != null) {
log.error(cause.getMessage(), cause);
- }
+ }
}
});
}
-
+
public Watch getWatch() {
return watch;
}
public void setWatch(Watch watch) {
this.watch = watch;
- }
+ }
}
}
-
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java
index eb56d2c..6398141 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java
@@ -26,11 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Namespaces component provides a producer to execute kubernetes namespace operations
- * and a consumer to consume namespace events.
+ * The Kubernetes Namespaces component provides a producer to execute kubernetes
+ * namespace operations and a consumer to consume namespace events.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-namespaces", title = "Kubernetes Namespaces",
- syntax = "kubernetes-namespaces:masterUrl", label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-namespaces", title = "Kubernetes Namespaces", syntax = "kubernetes-namespaces:masterUrl", label = "container,cloud,paas")
public class KubernetesNamespacesEndpoint extends AbstractKubernetesEndpoint {
public KubernetesNamespacesEndpoint(String uri, KubernetesNamespacesComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesProducer.java
index 0dd2d8c..380eaa3 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesProducer.java
@@ -37,8 +37,7 @@ import org.slf4j.LoggerFactory;
public class KubernetesNamespacesProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory
- .getLogger(KubernetesNamespacesProducer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(KubernetesNamespacesProducer.class);
public KubernetesNamespacesProducer(AbstractKubernetesEndpoint endpoint) {
super(endpoint);
@@ -46,20 +45,17 @@ public class KubernetesNamespacesProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
public void process(Exchange exchange) throws Exception {
String operation;
- if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration()
- .getOperation())) {
- operation = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_OPERATION, String.class);
+ if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration().getOperation())) {
+ operation = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_OPERATION, String.class);
} else {
- operation = getEndpoint().getKubernetesConfiguration()
- .getOperation();
+ operation = getEndpoint().getKubernetesConfiguration().getOperation();
}
switch (operation) {
@@ -85,83 +81,67 @@ public class KubernetesNamespacesProducer extends DefaultProducer {
break;
default:
- throw new IllegalArgumentException("Unsupported operation "
- + operation);
+ throw new IllegalArgumentException("Unsupported operation " + operation);
}
}
protected void doList(Exchange exchange, String operation) throws Exception {
- NamespaceList namespacesList = getEndpoint().getKubernetesClient()
- .namespaces().list();
-
+ NamespaceList namespacesList = getEndpoint().getKubernetesClient().namespaces().list();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(namespacesList.getItems());
}
protected void doListNamespaceByLabel(Exchange exchange, String operation) {
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_LABELS, Map.class);
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_LABELS, Map.class);
if (ObjectHelper.isEmpty(labels)) {
LOG.error("Get a specific namespace by labels require specify a labels set");
- throw new IllegalArgumentException(
- "Get a specific namespace by labels require specify a labels set");
+ throw new IllegalArgumentException("Get a specific namespace by labels require specify a labels set");
}
NonNamespaceOperation<Namespace, NamespaceList, DoneableNamespace, Resource<Namespace, DoneableNamespace>> namespaces = getEndpoint().getKubernetesClient().namespaces();
for (Map.Entry<String, String> entry : labels.entrySet()) {
namespaces.withLabel(entry.getKey(), entry.getValue());
}
NamespaceList namespace = namespaces.list();
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(namespace.getItems());
}
protected void doGetNamespace(Exchange exchange, String operation) {
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Get a specific namespace require specify a namespace name");
- throw new IllegalArgumentException(
- "Get a specific namespace require specify a namespace name");
+ throw new IllegalArgumentException("Get a specific namespace require specify a namespace name");
}
- Namespace namespace = getEndpoint().getKubernetesClient().namespaces()
- .withName(namespaceName).get();
-
+ Namespace namespace = getEndpoint().getKubernetesClient().namespaces().withName(namespaceName).get();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(namespace);
}
protected void doCreateNamespace(Exchange exchange, String operation) {
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Create a specific namespace require specify a namespace name");
- throw new IllegalArgumentException(
- "Create a specific namespace require specify a namespace name");
+ throw new IllegalArgumentException("Create a specific namespace require specify a namespace name");
}
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_LABELS, Map.class);
- Namespace ns = new NamespaceBuilder().withNewMetadata()
- .withName(namespaceName).withLabels(labels).endMetadata()
- .build();
- Namespace namespace = getEndpoint().getKubernetesClient().namespaces()
- .create(ns);
-
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_LABELS, Map.class);
+ Namespace ns = new NamespaceBuilder().withNewMetadata().withName(namespaceName).withLabels(labels).endMetadata().build();
+ Namespace namespace = getEndpoint().getKubernetesClient().namespaces().create(ns);
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(namespace);
}
protected void doDeleteNamespace(Exchange exchange, String operation) {
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Delete a specific namespace require specify a namespace name");
- throw new IllegalArgumentException(
- "Delete a specific namespace require specify a namespace name");
+ throw new IllegalArgumentException("Delete a specific namespace require specify a namespace name");
}
- Boolean namespace = getEndpoint().getKubernetesClient().namespaces()
- .withName(namespaceName).delete();
-
+ Boolean namespace = getEndpoint().getKubernetesClient().namespaces().withName(namespaceName).delete();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(namespace);
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesConsumer.java
index de48c4f..e701651 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesConsumer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesConsumer.java
@@ -48,7 +48,7 @@ public class KubernetesNodesConsumer extends DefaultConsumer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
@@ -82,13 +82,13 @@ public class KubernetesNodesConsumer extends DefaultConsumer {
}
class NodesConsumerTask implements Runnable {
-
+
private Watch watch;
-
+
@Override
public void run() {
NonNamespaceOperation<Node, NodeList, DoneableNode, Resource<Node, DoneableNode>> w = getEndpoint().getKubernetesClient().nodes();
- if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelKey())
+ if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelKey())
&& ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelValue())) {
w.withLabel(getEndpoint().getKubernetesConfiguration().getLabelKey(), getEndpoint().getKubernetesConfiguration().getLabelValue());
}
@@ -98,8 +98,7 @@ public class KubernetesNodesConsumer extends DefaultConsumer {
watch = w.watch(new Watcher<Node>() {
@Override
- public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action,
- Node resource) {
+ public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, Node resource) {
NodeEvent ne = new NodeEvent(action, resource);
Exchange exchange = getEndpoint().createExchange();
exchange.getIn().setBody(ne.getNode());
@@ -121,13 +120,13 @@ public class KubernetesNodesConsumer extends DefaultConsumer {
}
});
}
-
+
public Watch getWatch() {
return watch;
}
public void setWatch(Watch watch) {
this.watch = watch;
- }
+ }
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java
index 4d13dce..ab332e3 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java
@@ -26,11 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Nodes component provides a producer to execute kubernetes node operations
- * and a consumer to consume node events.
+ * The Kubernetes Nodes component provides a producer to execute kubernetes node
+ * operations and a consumer to consume node events.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-nodes", title = "Kubernetes Nodes",
- syntax = "kubernetes-nodes:masterUrl", label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-nodes", title = "Kubernetes Nodes", syntax = "kubernetes-nodes:masterUrl", label = "container,cloud,paas")
public class KubernetesNodesEndpoint extends AbstractKubernetesEndpoint {
public KubernetesNodesEndpoint(String uri, KubernetesNodesComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java
index 7735881..17449cc 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java
@@ -40,7 +40,7 @@ public class KubernetesNodesProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
@@ -74,7 +74,7 @@ public class KubernetesNodesProducer extends DefaultProducer {
protected void doList(Exchange exchange, String operation) throws Exception {
NodeList nodeList = getEndpoint().getKubernetesClient().nodes().list();
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(nodeList.getItems());
}
@@ -87,7 +87,7 @@ public class KubernetesNodesProducer extends DefaultProducer {
nodes.withLabel(entry.getKey(), entry.getValue());
}
nodeList = nodes.list();
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(nodeList.getItems());
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesEndpoint.java
index 4e63474..e41a30a 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesEndpoint.java
@@ -26,10 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Persistent Volumes component provides a producer to execute kubernetes persistent volume operations.
+ * The Kubernetes Persistent Volumes component provides a producer to execute
+ * kubernetes persistent volume operations.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-persistent-volumes", title = "Kubernetes Persistent Volume",
- syntax = "kubernetes-persistent-volumes:masterUrl", producerOnly = true, label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-persistent-volumes", title = "Kubernetes Persistent Volume", syntax = "kubernetes-persistent-volumes:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesPersistentVolumesEndpoint extends AbstractKubernetesEndpoint {
public KubernetesPersistentVolumesEndpoint(String uri, KubernetesPersistentVolumesComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesProducer.java
index c1c77b9..57cf748 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesProducer.java
@@ -36,8 +36,7 @@ import org.slf4j.LoggerFactory;
public class KubernetesPersistentVolumesProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory
- .getLogger(KubernetesPersistentVolumesProducer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(KubernetesPersistentVolumesProducer.class);
public KubernetesPersistentVolumesProducer(AbstractKubernetesEndpoint endpoint) {
super(endpoint);
@@ -45,20 +44,17 @@ public class KubernetesPersistentVolumesProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
public void process(Exchange exchange) throws Exception {
String operation;
- if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration()
- .getOperation())) {
- operation = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_OPERATION, String.class);
+ if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration().getOperation())) {
+ operation = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_OPERATION, String.class);
} else {
- operation = getEndpoint().getKubernetesConfiguration()
- .getOperation();
+ operation = getEndpoint().getKubernetesConfiguration().getOperation();
}
switch (operation) {
@@ -76,49 +72,40 @@ public class KubernetesPersistentVolumesProducer extends DefaultProducer {
break;
default:
- throw new IllegalArgumentException("Unsupported operation "
- + operation);
+ throw new IllegalArgumentException("Unsupported operation " + operation);
}
}
protected void doList(Exchange exchange, String operation) throws Exception {
- PersistentVolumeList persistentVolumeList = getEndpoint()
- .getKubernetesClient().persistentVolumes().list();
-
+ PersistentVolumeList persistentVolumeList = getEndpoint().getKubernetesClient().persistentVolumes().list();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(persistentVolumeList.getItems());
}
- protected void doListPersistentVolumesByLabels(Exchange exchange,
- String operation) throws Exception {
+ protected void doListPersistentVolumesByLabels(Exchange exchange, String operation) throws Exception {
PersistentVolumeList pvList = null;
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_PERSISTENT_VOLUMES_LABELS,
- Map.class);
- NonNamespaceOperation<PersistentVolume, PersistentVolumeList, DoneablePersistentVolume, Resource<PersistentVolume, DoneablePersistentVolume>> pvs;
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUMES_LABELS, Map.class);
+ NonNamespaceOperation<PersistentVolume, PersistentVolumeList, DoneablePersistentVolume, Resource<PersistentVolume, DoneablePersistentVolume>> pvs;
pvs = getEndpoint().getKubernetesClient().persistentVolumes();
for (Map.Entry<String, String> entry : labels.entrySet()) {
pvs.withLabel(entry.getKey(), entry.getValue());
}
pvList = pvs.list();
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(pvList.getItems());
}
- protected void doGetPersistentVolume(Exchange exchange, String operation)
- throws Exception {
+ protected void doGetPersistentVolume(Exchange exchange, String operation) throws Exception {
PersistentVolume pv = null;
- String pvName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_NAME,
- String.class);
+ String pvName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_NAME, String.class);
if (ObjectHelper.isEmpty(pvName)) {
LOG.error("Get a specific Persistent Volume require specify a Persistent Volume name");
- throw new IllegalArgumentException(
- "Get a specific Persistent Volume require specify a Persistent Volume name");
+ throw new IllegalArgumentException("Get a specific Persistent Volume require specify a Persistent Volume name");
}
pv = getEndpoint().getKubernetesClient().persistentVolumes().withName(pvName).get();
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(pv);
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsEndpoint.java
index 14c3398..35d6a02 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsEndpoint.java
@@ -26,10 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Persistent Volumes Claims component provides a producer to execute kubernetes persistent volume claim operations.
+ * The Kubernetes Persistent Volumes Claims component provides a producer to
+ * execute kubernetes persistent volume claim operations.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-persistent-volumes-claims", title = "Kubernetes Persistent Volume Claim",
- syntax = "kubernetes-persistent-volumes-claims:masterUrl", producerOnly = true, label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-persistent-volumes-claims", title = "Kubernetes Persistent Volume Claim", syntax = "kubernetes-persistent-volumes-claims:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesPersistentVolumesClaimsEndpoint extends AbstractKubernetesEndpoint {
public KubernetesPersistentVolumesClaimsEndpoint(String uri, KubernetesPersistentVolumesClaimsComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsProducer.java
index 858c645..b01da07 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsProducer.java
@@ -41,8 +41,7 @@ import org.slf4j.LoggerFactory;
public class KubernetesPersistentVolumesClaimsProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory
- .getLogger(KubernetesPersistentVolumesClaimsProducer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(KubernetesPersistentVolumesClaimsProducer.class);
public KubernetesPersistentVolumesClaimsProducer(AbstractKubernetesEndpoint endpoint) {
super(endpoint);
@@ -50,20 +49,17 @@ public class KubernetesPersistentVolumesClaimsProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
public void process(Exchange exchange) throws Exception {
String operation;
- if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration()
- .getOperation())) {
- operation = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_OPERATION, String.class);
+ if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration().getOperation())) {
+ operation = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_OPERATION, String.class);
} else {
- operation = getEndpoint().getKubernetesConfiguration()
- .getOperation();
+ operation = getEndpoint().getKubernetesConfiguration().getOperation();
}
switch (operation) {
@@ -89,137 +85,97 @@ public class KubernetesPersistentVolumesClaimsProducer extends DefaultProducer {
break;
default:
- throw new IllegalArgumentException("Unsupported operation "
- + operation);
+ throw new IllegalArgumentException("Unsupported operation " + operation);
}
}
protected void doList(Exchange exchange, String operation) throws Exception {
- PersistentVolumeClaimList persistentVolumeClaimList = getEndpoint()
- .getKubernetesClient().persistentVolumeClaims().list();
+ PersistentVolumeClaimList persistentVolumeClaimList = getEndpoint().getKubernetesClient().persistentVolumeClaims().list();
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
-
+
exchange.getOut().setBody(persistentVolumeClaimList.getItems());
}
- protected void doListPersistentVolumesClaimsByLabels(Exchange exchange,
- String operation) throws Exception {
+ protected void doListPersistentVolumesClaimsByLabels(Exchange exchange, String operation) throws Exception {
PersistentVolumeClaimList pvcList = null;
- Map<String, String> labels = exchange
- .getIn()
- .getHeader(
- KubernetesConstants.KUBERNETES_PERSISTENT_VOLUMES_CLAIMS_LABELS,
- Map.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUMES_CLAIMS_LABELS, Map.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (!ObjectHelper.isEmpty(namespaceName)) {
- NonNamespaceOperation<PersistentVolumeClaim, PersistentVolumeClaimList, DoneablePersistentVolumeClaim,
- Resource<PersistentVolumeClaim, DoneablePersistentVolumeClaim>> pvcs = getEndpoint().getKubernetesClient().persistentVolumeClaims()
- .inNamespace(namespaceName);
+ NonNamespaceOperation<PersistentVolumeClaim, PersistentVolumeClaimList, DoneablePersistentVolumeClaim, Resource<PersistentVolumeClaim, DoneablePersistentVolumeClaim>> pvcs = getEndpoint()
+ .getKubernetesClient().persistentVolumeClaims().inNamespace(namespaceName);
for (Map.Entry<String, String> entry : labels.entrySet()) {
pvcs.withLabel(entry.getKey(), entry.getValue());
}
pvcList = pvcs.list();
} else {
- FilterWatchListMultiDeletable<PersistentVolumeClaim, PersistentVolumeClaimList, Boolean,
- Watch, Watcher<PersistentVolumeClaim>> pvcs = getEndpoint().getKubernetesClient().persistentVolumeClaims().inAnyNamespace();
+ FilterWatchListMultiDeletable<PersistentVolumeClaim, PersistentVolumeClaimList, Boolean, Watch, Watcher<PersistentVolumeClaim>> pvcs = getEndpoint()
+ .getKubernetesClient().persistentVolumeClaims().inAnyNamespace();
for (Map.Entry<String, String> entry : labels.entrySet()) {
pvcs.withLabel(entry.getKey(), entry.getValue());
}
pvcList = pvcs.list();
}
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(pvcList.getItems());
}
- protected void doGetPersistentVolumeClaim(Exchange exchange,
- String operation) throws Exception {
+ protected void doGetPersistentVolumeClaim(Exchange exchange, String operation) throws Exception {
PersistentVolumeClaim pvc = null;
- String pvcName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_NAME,
- String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String pvcName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(pvcName)) {
LOG.error("Get a specific Persistent Volume Claim require specify a Persistent Volume Claim name");
- throw new IllegalArgumentException(
- "Get a specific Persistent Volume Claim require specify a Persistent Volume Claim name");
+ throw new IllegalArgumentException("Get a specific Persistent Volume Claim require specify a Persistent Volume Claim name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Get a specific Persistent Volume Claim require specify a namespace name");
- throw new IllegalArgumentException(
- "Get a specific Persistent Volume Claim require specify a namespace name");
+ throw new IllegalArgumentException("Get a specific Persistent Volume Claim require specify a namespace name");
}
- pvc = getEndpoint().getKubernetesClient().persistentVolumeClaims()
- .inNamespace(namespaceName).withName(pvcName).get();
-
+ pvc = getEndpoint().getKubernetesClient().persistentVolumeClaims().inNamespace(namespaceName).withName(pvcName).get();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(pvc);
}
- protected void doCreatePersistentVolumeClaim(Exchange exchange,
- String operation) throws Exception {
+ protected void doCreatePersistentVolumeClaim(Exchange exchange, String operation) throws Exception {
PersistentVolumeClaim pvc = null;
- String pvcName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_NAME,
- String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
- PersistentVolumeClaimSpec pvcSpec = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_SPEC,
- PersistentVolumeClaimSpec.class);
+ String pvcName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ PersistentVolumeClaimSpec pvcSpec = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_SPEC, PersistentVolumeClaimSpec.class);
if (ObjectHelper.isEmpty(pvcName)) {
LOG.error("Create a specific Persistent Volume Claim require specify a Persistent Volume Claim name");
- throw new IllegalArgumentException(
- "Create a specific Persistent Volume Claim require specify a Persistent Volume Claim name");
+ throw new IllegalArgumentException("Create a specific Persistent Volume Claim require specify a Persistent Volume Claim name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Create a specific Persistent Volume Claim require specify a namespace name");
- throw new IllegalArgumentException(
- "Create a specific Persistent Volume Claim require specify a namespace name");
+ throw new IllegalArgumentException("Create a specific Persistent Volume Claim require specify a namespace name");
}
if (ObjectHelper.isEmpty(pvcSpec)) {
LOG.error("Create a specific Persistent Volume Claim require specify a Persistent Volume Claim spec bean");
- throw new IllegalArgumentException(
- "Create a specific Persistent Volume Claim require specify a Persistent Volume Claim spec bean");
+ throw new IllegalArgumentException("Create a specific Persistent Volume Claim require specify a Persistent Volume Claim spec bean");
}
- Map<String, String> labels = exchange
- .getIn()
- .getHeader(
- KubernetesConstants.KUBERNETES_PERSISTENT_VOLUMES_CLAIMS_LABELS,
- Map.class);
- PersistentVolumeClaim pvcCreating = new PersistentVolumeClaimBuilder()
- .withNewMetadata().withName(pvcName).withLabels(labels)
- .endMetadata().withSpec(pvcSpec).build();
- pvc = getEndpoint().getKubernetesClient().persistentVolumeClaims()
- .inNamespace(namespaceName).create(pvcCreating);
-
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUMES_CLAIMS_LABELS, Map.class);
+ PersistentVolumeClaim pvcCreating = new PersistentVolumeClaimBuilder().withNewMetadata().withName(pvcName).withLabels(labels).endMetadata().withSpec(pvcSpec).build();
+ pvc = getEndpoint().getKubernetesClient().persistentVolumeClaims().inNamespace(namespaceName).create(pvcCreating);
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(pvc);
}
- protected void doDeletePersistentVolumeClaim(Exchange exchange,
- String operation) throws Exception {
- String pvcName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_NAME,
- String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ protected void doDeletePersistentVolumeClaim(Exchange exchange, String operation) throws Exception {
+ String pvcName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(pvcName)) {
LOG.error("Delete a specific Persistent Volume Claim require specify a Persistent Volume Claim name");
- throw new IllegalArgumentException(
- "Delete a specific Persistent Volume Claim require specify a Persistent Volume Claim name");
+ throw new IllegalArgumentException("Delete a specific Persistent Volume Claim require specify a Persistent Volume Claim name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Delete a specific Persistent Volume Claim require specify a namespace name");
- throw new IllegalArgumentException(
- "Delete a specific Persistent Volume Claim require specify a namespace name");
+ throw new IllegalArgumentException("Delete a specific Persistent Volume Claim require specify a namespace name");
}
- boolean pvcDeleted = getEndpoint().getKubernetesClient()
- .persistentVolumeClaims().inNamespace(namespaceName)
- .withName(pvcName).delete();
-
+ boolean pvcDeleted = getEndpoint().getKubernetesClient().persistentVolumeClaims().inNamespace(namespaceName).withName(pvcName).delete();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(pvcDeleted);
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsConsumer.java
index f5ac50b..347821f 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsConsumer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsConsumer.java
@@ -48,14 +48,14 @@ public class KubernetesPodsConsumer extends DefaultConsumer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
protected void doStart() throws Exception {
super.doStart();
executor = getEndpoint().createExecutor();
-
+
podsWatcher = new PodsConsumerTask();
executor.submit(podsWatcher);
}
@@ -84,14 +84,14 @@ public class KubernetesPodsConsumer extends DefaultConsumer {
class PodsConsumerTask implements Runnable {
private Watch watch;
-
+
@Override
public void run() {
MixedOperation<Pod, PodList, DoneablePod, PodResource<Pod, DoneablePod>> w = getEndpoint().getKubernetesClient().pods();
if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getNamespace())) {
w.inNamespace(getEndpoint().getKubernetesConfiguration().getNamespace());
}
- if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelKey())
+ if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelKey())
&& ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelValue())) {
w.withLabel(getEndpoint().getKubernetesConfiguration().getLabelKey(), getEndpoint().getKubernetesConfiguration().getLabelValue());
}
@@ -101,8 +101,7 @@ public class KubernetesPodsConsumer extends DefaultConsumer {
watch = w.watch(new Watcher<Pod>() {
@Override
- public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action,
- Pod resource) {
+ public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, Pod resource) {
PodEvent pe = new PodEvent(action, resource);
Exchange exchange = getEndpoint().createExchange();
exchange.getIn().setBody(pe.getPod());
@@ -131,6 +130,6 @@ public class KubernetesPodsConsumer extends DefaultConsumer {
public void setWatch(Watch watch) {
this.watch = watch;
- }
+ }
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java
index 5cc12e4..c796f9e 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java
@@ -26,11 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Pods component provides a producer to execute kubernetes pod operations
- * and a consumer to consume pod events.
+ * The Kubernetes Pods component provides a producer to execute kubernetes pod
+ * operations and a consumer to consume pod events.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-pods", title = "Kubernetes Pods",
- syntax = "kubernetes-pods:masterUrl", label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-pods", title = "Kubernetes Pods", syntax = "kubernetes-pods:masterUrl", label = "container,cloud,paas")
public class KubernetesPodsEndpoint extends AbstractKubernetesEndpoint {
public KubernetesPodsEndpoint(String uri, KubernetesPodsComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsProducer.java
index 27dd98d..c84c7d0 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsProducer.java
@@ -38,8 +38,7 @@ import org.slf4j.LoggerFactory;
public class KubernetesPodsProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory
- .getLogger(KubernetesPodsProducer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(KubernetesPodsProducer.class);
public KubernetesPodsProducer(AbstractKubernetesEndpoint endpoint) {
super(endpoint);
@@ -47,20 +46,17 @@ public class KubernetesPodsProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
public void process(Exchange exchange) throws Exception {
String operation;
- if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration()
- .getOperation())) {
- operation = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_OPERATION, String.class);
+ if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration().getOperation())) {
+ operation = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_OPERATION, String.class);
} else {
- operation = getEndpoint().getKubernetesConfiguration()
- .getOperation();
+ operation = getEndpoint().getKubernetesConfiguration().getOperation();
}
switch (operation) {
@@ -86,116 +82,90 @@ public class KubernetesPodsProducer extends DefaultProducer {
break;
default:
- throw new IllegalArgumentException("Unsupported operation "
- + operation);
+ throw new IllegalArgumentException("Unsupported operation " + operation);
}
}
protected void doList(Exchange exchange, String operation) throws Exception {
PodList podList = getEndpoint().getKubernetesClient().pods().inAnyNamespace().list();
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(podList.getItems());
}
protected void doListPodsByLabel(Exchange exchange, String operation) {
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_PODS_LABELS, Map.class);
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PODS_LABELS, Map.class);
if (ObjectHelper.isEmpty(labels)) {
LOG.error("Get pods by labels require specify a labels set");
- throw new IllegalArgumentException(
- "Get pods by labels require specify a labels set");
+ throw new IllegalArgumentException("Get pods by labels require specify a labels set");
}
-
+
FilterWatchListMultiDeletable<Pod, PodList, Boolean, Watch, Watcher<Pod>> pods = getEndpoint().getKubernetesClient().pods().inAnyNamespace();
for (Map.Entry<String, String> entry : labels.entrySet()) {
pods.withLabel(entry.getKey(), entry.getValue());
}
PodList podList = pods.list();
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(podList.getItems());
}
- protected void doGetPod(Exchange exchange, String operation)
- throws Exception {
+ protected void doGetPod(Exchange exchange, String operation) throws Exception {
Pod pod = null;
- String podName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_POD_NAME, String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String podName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_POD_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(podName)) {
LOG.error("Get a specific pod require specify a pod name");
- throw new IllegalArgumentException(
- "Get a specific pod require specify a pod name");
+ throw new IllegalArgumentException("Get a specific pod require specify a pod name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Get a specific pod require specify a namespace name");
- throw new IllegalArgumentException(
- "Get a specific pod require specify a namespace name");
+ throw new IllegalArgumentException("Get a specific pod require specify a namespace name");
}
- pod = getEndpoint().getKubernetesClient().pods()
- .inNamespace(namespaceName).withName(podName).get();
-
+ pod = getEndpoint().getKubernetesClient().pods().inNamespace(namespaceName).withName(podName).get();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(pod);
}
- protected void doCreatePod(Exchange exchange, String operation)
- throws Exception {
+ protected void doCreatePod(Exchange exchange, String operation) throws Exception {
Pod pod = null;
- String podName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_POD_NAME, String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
- PodSpec podSpec = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_POD_SPEC, PodSpec.class);
+ String podName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_POD_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ PodSpec podSpec = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_POD_SPEC, PodSpec.class);
if (ObjectHelper.isEmpty(podName)) {
LOG.error("Create a specific pod require specify a pod name");
- throw new IllegalArgumentException(
- "Create a specific pod require specify a pod name");
+ throw new IllegalArgumentException("Create a specific pod require specify a pod name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Create a specific pod require specify a namespace name");
- throw new IllegalArgumentException(
- "Create a specific pod require specify a namespace name");
+ throw new IllegalArgumentException("Create a specific pod require specify a namespace name");
}
if (ObjectHelper.isEmpty(podSpec)) {
LOG.error("Create a specific pod require specify a pod spec bean");
- throw new IllegalArgumentException(
- "Create a specific pod require specify a pod spec bean");
+ throw new IllegalArgumentException("Create a specific pod require specify a pod spec bean");
}
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_PODS_LABELS, Map.class);
- Pod podCreating = new PodBuilder().withNewMetadata()
- .withName(podName).withLabels(labels).endMetadata()
- .withSpec(podSpec).build();
- pod = getEndpoint().getKubernetesClient().pods()
- .inNamespace(namespaceName).create(podCreating);
-
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PODS_LABELS, Map.class);
+ Pod podCreating = new PodBuilder().withNewMetadata().withName(podName).withLabels(labels).endMetadata().withSpec(podSpec).build();
+ pod = getEndpoint().getKubernetesClient().pods().inNamespace(namespaceName).create(podCreating);
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(pod);
}
- protected void doDeletePod(Exchange exchange, String operation)
- throws Exception {
- String podName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_POD_NAME, String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ protected void doDeletePod(Exchange exchange, String operation) throws Exception {
+ String podName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_POD_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(podName)) {
LOG.error("Delete a specific pod require specify a pod name");
- throw new IllegalArgumentException(
- "Delete a specific pod require specify a pod name");
+ throw new IllegalArgumentException("Delete a specific pod require specify a pod name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Delete a specific pod require specify a namespace name");
- throw new IllegalArgumentException(
- "Delete a specific pod require specify a namespace name");
+ throw new IllegalArgumentException("Delete a specific pod require specify a namespace name");
}
- boolean podDeleted = getEndpoint().getKubernetesClient().pods()
- .inNamespace(namespaceName).withName(podName).delete();
-
+ boolean podDeleted = getEndpoint().getKubernetesClient().pods().inNamespace(namespaceName).withName(podName).delete();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(podDeleted);
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersConsumer.java
index 3ddd040..32abb99 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersConsumer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersConsumer.java
@@ -48,7 +48,7 @@ public class KubernetesReplicationControllersConsumer extends DefaultConsumer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
@@ -57,13 +57,13 @@ public class KubernetesReplicationControllersConsumer extends DefaultConsumer {
executor = getEndpoint().createExecutor();
rcWatcher = new ReplicationControllersConsumerTask();
- executor.submit(rcWatcher);
+ executor.submit(rcWatcher);
}
@Override
protected void doStop() throws Exception {
super.doStop();
-
+
log.debug("Stopping Kubernetes Replication Controllers Consumer");
if (executor != null) {
if (getEndpoint() != null && getEndpoint().getCamelContext() != null) {
@@ -80,19 +80,19 @@ public class KubernetesReplicationControllersConsumer extends DefaultConsumer {
}
executor = null;
}
-
+
class ReplicationControllersConsumerTask implements Runnable {
-
+
private Watch watch;
-
+
@Override
public void run() {
- MixedOperation<ReplicationController, ReplicationControllerList,
- DoneableReplicationController, RollableScalableResource<ReplicationController, DoneableReplicationController>> w = getEndpoint().getKubernetesClient().replicationControllers();
+ MixedOperation<ReplicationController, ReplicationControllerList, DoneableReplicationController, RollableScalableResource<ReplicationController, DoneableReplicationController>> w = getEndpoint()
+ .getKubernetesClient().replicationControllers();
if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getNamespace())) {
w.inNamespace(getEndpoint().getKubernetesConfiguration().getNamespace());
}
- if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelKey())
+ if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelKey())
&& ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelValue())) {
w.withLabel(getEndpoint().getKubernetesConfiguration().getLabelKey(), getEndpoint().getKubernetesConfiguration().getLabelValue());
}
@@ -102,8 +102,7 @@ public class KubernetesReplicationControllersConsumer extends DefaultConsumer {
watch = w.watch(new Watcher<ReplicationController>() {
@Override
- public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action,
- ReplicationController resource) {
+ public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, ReplicationController resource) {
ReplicationControllerEvent rce = new ReplicationControllerEvent(action, resource);
Exchange exchange = getEndpoint().createExchange();
exchange.getIn().setBody(rce.getReplicationController());
@@ -126,13 +125,13 @@ public class KubernetesReplicationControllersConsumer extends DefaultConsumer {
});
}
-
+
public Watch getWatch() {
return watch;
}
public void setWatch(Watch watch) {
this.watch = watch;
- }
+ }
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java
index 2e7f230..a993879 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java
@@ -26,11 +26,11 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Replication Controllers component provides a producer to execute kubernetes replication controller
- * operations and a consumer to consume replication controller events.
+ * The Kubernetes Replication Controllers component provides a producer to
+ * execute kubernetes replication controller operations and a consumer to
+ * consume replication controller events.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-replication-controllers", title = "Kubernetes Replication Controller",
- syntax = "kubernetes-replication-controllers:masterUrl", label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-replication-controllers", title = "Kubernetes Replication Controller", syntax = "kubernetes-replication-controllers:masterUrl", label = "container,cloud,paas")
public class KubernetesReplicationControllersEndpoint extends AbstractKubernetesEndpoint {
public KubernetesReplicationControllersEndpoint(String uri, KubernetesReplicationControllersComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersProducer.java
index 5993a7a..9ac3dd9 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersProducer.java
@@ -41,8 +41,7 @@ import org.slf4j.LoggerFactory;
public class KubernetesReplicationControllersProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory
- .getLogger(KubernetesReplicationControllersProducer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(KubernetesReplicationControllersProducer.class);
public KubernetesReplicationControllersProducer(AbstractKubernetesEndpoint endpoint) {
super(endpoint);
@@ -50,20 +49,17 @@ public class KubernetesReplicationControllersProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
public void process(Exchange exchange) throws Exception {
String operation;
- if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration()
- .getOperation())) {
- operation = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_OPERATION, String.class);
+ if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration().getOperation())) {
+ operation = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_OPERATION, String.class);
} else {
- operation = getEndpoint().getKubernetesConfiguration()
- .getOperation();
+ operation = getEndpoint().getKubernetesConfiguration().getOperation();
}
switch (operation) {
@@ -87,183 +83,133 @@ public class KubernetesReplicationControllersProducer extends DefaultProducer {
case KubernetesOperations.DELETE_REPLICATION_CONTROLLER_OPERATION:
doDeleteReplicationController(exchange, operation);
break;
-
+
case KubernetesOperations.SCALE_REPLICATION_CONTROLLER_OPERATION:
doScaleReplicationController(exchange, operation);
break;
default:
- throw new IllegalArgumentException("Unsupported operation "
- + operation);
+ throw new IllegalArgumentException("Unsupported operation " + operation);
}
}
protected void doList(Exchange exchange, String operation) throws Exception {
ReplicationControllerList rcList = null;
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (!ObjectHelper.isEmpty(namespaceName)) {
- rcList = getEndpoint().getKubernetesClient()
- .replicationControllers().inNamespace(namespaceName).list();
+ rcList = getEndpoint().getKubernetesClient().replicationControllers().inNamespace(namespaceName).list();
} else {
- rcList = getEndpoint().getKubernetesClient()
- .replicationControllers().inAnyNamespace().list();
+ rcList = getEndpoint().getKubernetesClient().replicationControllers().inAnyNamespace().list();
}
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(rcList.getItems());
}
- protected void doListReplicationControllersByLabels(Exchange exchange,
- String operation) throws Exception {
+ protected void doListReplicationControllersByLabels(Exchange exchange, String operation) throws Exception {
ReplicationControllerList rcList = null;
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLERS_LABELS,
- Map.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLERS_LABELS, Map.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (!ObjectHelper.isEmpty(namespaceName)) {
- NonNamespaceOperation<ReplicationController, ReplicationControllerList, DoneableReplicationController,
- RollableScalableResource<ReplicationController, DoneableReplicationController>> replicationControllers = getEndpoint().getKubernetesClient()
- .replicationControllers().inNamespace(namespaceName);
+ NonNamespaceOperation<ReplicationController, ReplicationControllerList, DoneableReplicationController, RollableScalableResource<ReplicationController, DoneableReplicationController>> replicationControllers = getEndpoint()
+ .getKubernetesClient().replicationControllers().inNamespace(namespaceName);
for (Map.Entry<String, String> entry : labels.entrySet()) {
- replicationControllers.withLabel(entry.getKey(),
- entry.getValue());
+ replicationControllers.withLabel(entry.getKey(), entry.getValue());
}
rcList = replicationControllers.list();
} else {
- FilterWatchListMultiDeletable<ReplicationController, ReplicationControllerList, Boolean, Watch, Watcher<ReplicationController>> replicationControllers = getEndpoint().getKubernetesClient()
- .replicationControllers().inAnyNamespace();
+ FilterWatchListMultiDeletable<ReplicationController, ReplicationControllerList, Boolean, Watch, Watcher<ReplicationController>> replicationControllers = getEndpoint()
+ .getKubernetesClient().replicationControllers().inAnyNamespace();
for (Map.Entry<String, String> entry : labels.entrySet()) {
- replicationControllers.withLabel(entry.getKey(),
- entry.getValue());
+ replicationControllers.withLabel(entry.getKey(), entry.getValue());
}
rcList = replicationControllers.list();
}
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(rcList.getItems());
-
+
}
- protected void doGetReplicationController(Exchange exchange,
- String operation) throws Exception {
+ protected void doGetReplicationController(Exchange exchange, String operation) throws Exception {
ReplicationController rc = null;
- String rcName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME,
- String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String rcName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(rcName)) {
LOG.error("Get a specific replication controller require specify a replication controller name");
- throw new IllegalArgumentException(
- "Get a specific replication controller require specify a replication controller name");
+ throw new IllegalArgumentException("Get a specific replication controller require specify a replication controller name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Get a specific replication controller require specify a namespace name");
- throw new IllegalArgumentException(
- "Get a specific replication controller require specify a namespace name");
+ throw new IllegalArgumentException("Get a specific replication controller require specify a namespace name");
}
- rc = getEndpoint().getKubernetesClient().replicationControllers()
- .inNamespace(namespaceName).withName(rcName).get();
-
+ rc = getEndpoint().getKubernetesClient().replicationControllers().inNamespace(namespaceName).withName(rcName).get();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(rc);
}
- protected void doCreateReplicationController(Exchange exchange,
- String operation) throws Exception {
+ protected void doCreateReplicationController(Exchange exchange, String operation) throws Exception {
ReplicationController rc = null;
- String rcName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME,
- String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
- ReplicationControllerSpec rcSpec = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_SPEC,
- ReplicationControllerSpec.class);
+ String rcName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ ReplicationControllerSpec rcSpec = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_SPEC, ReplicationControllerSpec.class);
if (ObjectHelper.isEmpty(rcName)) {
LOG.error("Create a specific replication controller require specify a replication controller name");
- throw new IllegalArgumentException(
- "Create a specific replication controller require specify a replication controller name");
+ throw new IllegalArgumentException("Create a specific replication controller require specify a replication controller name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Create a specific replication controller require specify a namespace name");
- throw new IllegalArgumentException(
- "Create a specific replication controller require specify a namespace name");
+ throw new IllegalArgumentException("Create a specific replication controller require specify a namespace name");
}
if (ObjectHelper.isEmpty(rcSpec)) {
LOG.error("Create a specific replication controller require specify a replication controller spec bean");
- throw new IllegalArgumentException(
- "Create a specific replication controller require specify a replication controller spec bean");
+ throw new IllegalArgumentException("Create a specific replication controller require specify a replication controller spec bean");
}
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLERS_LABELS,
- Map.class);
- ReplicationController rcCreating = new ReplicationControllerBuilder()
- .withNewMetadata().withName(rcName).withLabels(labels)
- .endMetadata().withSpec(rcSpec).build();
- rc = getEndpoint().getKubernetesClient().replicationControllers()
- .inNamespace(namespaceName).create(rcCreating);
-
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLERS_LABELS, Map.class);
+ ReplicationController rcCreating = new ReplicationControllerBuilder().withNewMetadata().withName(rcName).withLabels(labels).endMetadata().withSpec(rcSpec).build();
+ rc = getEndpoint().getKubernetesClient().replicationControllers().inNamespace(namespaceName).create(rcCreating);
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(rc);
}
- protected void doDeleteReplicationController(Exchange exchange,
- String operation) throws Exception {
- String rcName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME,
- String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ protected void doDeleteReplicationController(Exchange exchange, String operation) throws Exception {
+ String rcName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(rcName)) {
LOG.error("Delete a specific replication controller require specify a replication controller name");
- throw new IllegalArgumentException(
- "Delete a specific replication controller require specify a replication controller name");
+ throw new IllegalArgumentException("Delete a specific replication controller require specify a replication controller name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Delete a specific replication controller require specify a namespace name");
- throw new IllegalArgumentException(
- "Delete a specific replication controller require specify a namespace name");
+ throw new IllegalArgumentException("Delete a specific replication controller require specify a namespace name");
}
- boolean rcDeleted = getEndpoint().getKubernetesClient()
- .replicationControllers().inNamespace(namespaceName)
- .withName(rcName).delete();
-
+ boolean rcDeleted = getEndpoint().getKubernetesClient().replicationControllers().inNamespace(namespaceName).withName(rcName).delete();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(rcDeleted);
}
-
- protected void doScaleReplicationController(Exchange exchange,
- String operation) throws Exception {
- String rcName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME,
- String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
- Integer replicasNumber = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_REPLICAS, Integer.class);
+
+ protected void doScaleReplicationController(Exchange exchange, String operation) throws Exception {
+ String rcName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ Integer replicasNumber = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_REPLICAS, Integer.class);
if (ObjectHelper.isEmpty(rcName)) {
LOG.error("Scale a specific replication controller require specify a replication controller name");
- throw new IllegalArgumentException(
- "Scale a specific replication controller require specify a replication controller name");
+ throw new IllegalArgumentException("Scale a specific replication controller require specify a replication controller name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Scale a specific replication controller require specify a namespace name");
- throw new IllegalArgumentException(
- "Scale a specific replication controller require specify a namespace name");
+ throw new IllegalArgumentException("Scale a specific replication controller require specify a namespace name");
}
if (ObjectHelper.isEmpty(replicasNumber)) {
LOG.error("Scale a specific replication controller require specify a replicas number");
- throw new IllegalArgumentException(
- "Scale a specific replication controller require specify a replicas number");
+ throw new IllegalArgumentException("Scale a specific replication controller require specify a replicas number");
}
- ReplicationController rcScaled = getEndpoint().getKubernetesClient()
- .replicationControllers().inNamespace(namespaceName)
- .withName(rcName).scale(replicasNumber, false);
-
+ ReplicationController rcScaled = getEndpoint().getKubernetesClient().replicationControllers().inNamespace(namespaceName).withName(rcName).scale(replicasNumber, false);
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(rcScaled.getStatus().getReplicas());
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaEndpoint.java
index a50508d..6cfdfd6 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaEndpoint.java
@@ -26,10 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Resources Quota component provides a producer to execute kubernetes resources quota operations.
+ * The Kubernetes Resources Quota component provides a producer to execute
+ * kubernetes resources quota operations.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-resources-quota", title = "Kubernetes Resources Quota",
- syntax = "kubernetes-resources-quota:masterUrl", producerOnly = true, label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-resources-quota", title = "Kubernetes Resources Quota", syntax = "kubernetes-resources-quota:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesResourcesQuotaEndpoint extends AbstractKubernetesEndpoint {
public KubernetesResourcesQuotaEndpoint(String uri, KubernetesResourcesQuotaComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaProducer.java
index 0d39dd6..cb7f7b2 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaProducer.java
@@ -39,8 +39,7 @@ import org.slf4j.LoggerFactory;
public class KubernetesResourcesQuotaProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory
- .getLogger(KubernetesResourcesQuotaProducer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(KubernetesResourcesQuotaProducer.class);
public KubernetesResourcesQuotaProducer(AbstractKubernetesEndpoint endpoint) {
super(endpoint);
@@ -48,20 +47,17 @@ public class KubernetesResourcesQuotaProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
public void process(Exchange exchange) throws Exception {
String operation;
- if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration()
- .getOperation())) {
- operation = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_OPERATION, String.class);
+ if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration().getOperation())) {
+ operation = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_OPERATION, String.class);
} else {
- operation = getEndpoint().getKubernetesConfiguration()
- .getOperation();
+ operation = getEndpoint().getKubernetesConfiguration().getOperation();
}
switch (operation) {
@@ -87,133 +83,97 @@ public class KubernetesResourcesQuotaProducer extends DefaultProducer {
break;
default:
- throw new IllegalArgumentException("Unsupported operation "
- + operation);
+ throw new IllegalArgumentException("Unsupported operation " + operation);
}
}
protected void doList(Exchange exchange, String operation) throws Exception {
- ResourceQuotaList resList = getEndpoint().getKubernetesClient()
- .resourceQuotas().inAnyNamespace().list();
-
+ ResourceQuotaList resList = getEndpoint().getKubernetesClient().resourceQuotas().inAnyNamespace().list();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(resList.getItems());
}
- protected void doListResourceQuotasByLabels(Exchange exchange,
- String operation) throws Exception {
+ protected void doListResourceQuotasByLabels(Exchange exchange, String operation) throws Exception {
ResourceQuotaList resList = null;
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_LABELS,
- Map.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_LABELS, Map.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (!ObjectHelper.isEmpty(namespaceName)) {
- NonNamespaceOperation<ResourceQuota, ResourceQuotaList, DoneableResourceQuota, Resource<ResourceQuota, DoneableResourceQuota>> resQuota;
- resQuota = getEndpoint().getKubernetesClient().resourceQuotas()
- .inNamespace(namespaceName);
+ NonNamespaceOperation<ResourceQuota, ResourceQuotaList, DoneableResourceQuota, Resource<ResourceQuota, DoneableResourceQuota>> resQuota;
+ resQuota = getEndpoint().getKubernetesClient().resourceQuotas().inNamespace(namespaceName);
for (Map.Entry<String, String> entry : labels.entrySet()) {
resQuota.withLabel(entry.getKey(), entry.getValue());
}
resList = resQuota.list();
} else {
- MixedOperation<ResourceQuota, ResourceQuotaList, DoneableResourceQuota, Resource<ResourceQuota, DoneableResourceQuota>> resQuota;
+ MixedOperation<ResourceQuota, ResourceQuotaList, DoneableResourceQuota, Resource<ResourceQuota, DoneableResourceQuota>> resQuota;
resQuota = getEndpoint().getKubernetesClient().resourceQuotas();
for (Map.Entry<String, String> entry : labels.entrySet()) {
resQuota.withLabel(entry.getKey(), entry.getValue());
}
resList = resQuota.list();
}
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(resList.getItems());
}
- protected void doGetResourceQuota(Exchange exchange, String operation)
- throws Exception {
+ protected void doGetResourceQuota(Exchange exchange, String operation) throws Exception {
ResourceQuota rq = null;
- String rqName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_NAME,
- String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String rqName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(rqName)) {
LOG.error("Get a specific Resource Quota require specify a Resource Quota name");
- throw new IllegalArgumentException(
- "Get a specific Resource Quota require specify a Resource Quota name");
+ throw new IllegalArgumentException("Get a specific Resource Quota require specify a Resource Quota name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Get a specific Resource Quota require specify a namespace name");
- throw new IllegalArgumentException(
- "Get a specific Resource Quota require specify a namespace name");
+ throw new IllegalArgumentException("Get a specific Resource Quota require specify a namespace name");
}
- rq = getEndpoint().getKubernetesClient().resourceQuotas()
- .inNamespace(namespaceName).withName(rqName).get();
-
+ rq = getEndpoint().getKubernetesClient().resourceQuotas().inNamespace(namespaceName).withName(rqName).get();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(rq);
}
- protected void doCreateResourceQuota(Exchange exchange, String operation)
- throws Exception {
+ protected void doCreateResourceQuota(Exchange exchange, String operation) throws Exception {
ResourceQuota rq = null;
- String rqName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_NAME,
- String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
- ResourceQuotaSpec rqSpec = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_RESOURCE_QUOTA_SPEC,
- ResourceQuotaSpec.class);
+ String rqName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ ResourceQuotaSpec rqSpec = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_RESOURCE_QUOTA_SPEC, ResourceQuotaSpec.class);
if (ObjectHelper.isEmpty(rqName)) {
LOG.error("Create a specific resource quota require specify a resource quota name");
- throw new IllegalArgumentException(
- "Create a specific resource quota require specify a resource quota name");
+ throw new IllegalArgumentException("Create a specific resource quota require specify a resource quota name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Create a specific resource quota require specify a namespace name");
- throw new IllegalArgumentException(
- "Create a specific resource quota require specify a namespace name");
+ throw new IllegalArgumentException("Create a specific resource quota require specify a namespace name");
}
if (ObjectHelper.isEmpty(rqSpec)) {
LOG.error("Create a specific resource quota require specify a resource quota spec bean");
- throw new IllegalArgumentException(
- "Create a specific resource quota require specify a resource quota spec bean");
+ throw new IllegalArgumentException("Create a specific resource quota require specify a resource quota spec bean");
}
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_LABELS,
- Map.class);
- ResourceQuota rqCreating = new ResourceQuotaBuilder()
- .withNewMetadata().withName(rqName).withLabels(labels)
- .endMetadata().withSpec(rqSpec).build();
- rq = getEndpoint().getKubernetesClient().resourceQuotas()
- .inNamespace(namespaceName).create(rqCreating);
-
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_LABELS, Map.class);
+ ResourceQuota rqCreating = new ResourceQuotaBuilder().withNewMetadata().withName(rqName).withLabels(labels).endMetadata().withSpec(rqSpec).build();
+ rq = getEndpoint().getKubernetesClient().resourceQuotas().inNamespace(namespaceName).create(rqCreating);
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(rq);
}
- protected void doDeleteResourceQuota(Exchange exchange, String operation)
- throws Exception {
- String rqName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_NAME,
- String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ protected void doDeleteResourceQuota(Exchange exchange, String operation) throws Exception {
+ String rqName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(rqName)) {
LOG.error("Delete a specific resource quota require specify a resource quota name");
- throw new IllegalArgumentException(
- "Delete a specific resource quota require specify a resource quota name");
+ throw new IllegalArgumentException("Delete a specific resource quota require specify a resource quota name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Delete a specific resource quota require specify a namespace name");
- throw new IllegalArgumentException(
- "Delete a specific resource quota require specify a namespace name");
+ throw new IllegalArgumentException("Delete a specific resource quota require specify a namespace name");
}
- boolean rqDeleted = getEndpoint().getKubernetesClient()
- .resourceQuotas().inNamespace(namespaceName).withName(rqName)
- .delete();
-
+ boolean rqDeleted = getEndpoint().getKubernetesClient().resourceQuotas().inNamespace(namespaceName).withName(rqName).delete();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(rqDeleted);
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsEndpoint.java
index a6f24e0..1264cd5 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsEndpoint.java
@@ -26,7 +26,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Secrets component provides a producer to execute kubernetes secret operations.
+ * The Kubernetes Secrets component provides a producer to execute kubernetes
+ * secret operations.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-secrets", title = "Kubernetes Secrets", syntax = "kubernetes-secrets:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesSecretsEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsProducer.java
index 6360696..2242e05 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsProducer.java
@@ -39,8 +39,7 @@ import org.slf4j.LoggerFactory;
public class KubernetesSecretsProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory
- .getLogger(KubernetesSecretsProducer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(KubernetesSecretsProducer.class);
public KubernetesSecretsProducer(AbstractKubernetesEndpoint endpoint) {
super(endpoint);
@@ -48,20 +47,17 @@ public class KubernetesSecretsProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
public void process(Exchange exchange) throws Exception {
String operation;
- if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration()
- .getOperation())) {
- operation = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_OPERATION, String.class);
+ if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration().getOperation())) {
+ operation = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_OPERATION, String.class);
} else {
- operation = getEndpoint().getKubernetesConfiguration()
- .getOperation();
+ operation = getEndpoint().getKubernetesConfiguration().getOperation();
}
switch (operation) {
@@ -87,113 +83,89 @@ public class KubernetesSecretsProducer extends DefaultProducer {
break;
default:
- throw new IllegalArgumentException("Unsupported operation "
- + operation);
+ throw new IllegalArgumentException("Unsupported operation " + operation);
}
}
protected void doList(Exchange exchange, String operation) throws Exception {
- SecretList secretsList = getEndpoint().getKubernetesClient().secrets().inAnyNamespace()
- .list();
+ SecretList secretsList = getEndpoint().getKubernetesClient().secrets().inAnyNamespace().list();
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(secretsList.getItems());
}
- protected void doListSecretsByLabels(Exchange exchange, String operation)
- throws Exception {
+ protected void doListSecretsByLabels(Exchange exchange, String operation) throws Exception {
SecretList secretsList = null;
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SECRETS_LABELS, Map.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SECRETS_LABELS, Map.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (!ObjectHelper.isEmpty(namespaceName)) {
- NonNamespaceOperation<Secret, SecretList, DoneableSecret, Resource<Secret, DoneableSecret>> secrets;
- secrets = getEndpoint().getKubernetesClient().secrets()
- .inNamespace(namespaceName);
+ NonNamespaceOperation<Secret, SecretList, DoneableSecret, Resource<Secret, DoneableSecret>> secrets;
+ secrets = getEndpoint().getKubernetesClient().secrets().inNamespace(namespaceName);
for (Map.Entry<String, String> entry : labels.entrySet()) {
secrets.withLabel(entry.getKey(), entry.getValue());
}
secretsList = secrets.list();
} else {
- FilterWatchListMultiDeletable<Secret, SecretList, Boolean, Watch, Watcher<Secret>> secrets;
+ FilterWatchListMultiDeletable<Secret, SecretList, Boolean, Watch, Watcher<Secret>> secrets;
secrets = getEndpoint().getKubernetesClient().secrets().inAnyNamespace();
for (Map.Entry<String, String> entry : labels.entrySet()) {
secrets.withLabel(entry.getKey(), entry.getValue());
}
secretsList = secrets.list();
}
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(secretsList.getItems());
}
- protected void doGetSecret(Exchange exchange, String operation)
- throws Exception {
+ protected void doGetSecret(Exchange exchange, String operation) throws Exception {
Secret secret = null;
- String secretName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SECRET_NAME, String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String secretName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SECRET_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(secretName)) {
LOG.error("Get a specific Secret require specify a Secret name");
- throw new IllegalArgumentException(
- "Get a specific Secret require specify a Secret name");
+ throw new IllegalArgumentException("Get a specific Secret require specify a Secret name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Get a specific Secret require specify a namespace name");
- throw new IllegalArgumentException(
- "Get a specific Secret require specify a namespace name");
+ throw new IllegalArgumentException("Get a specific Secret require specify a namespace name");
}
- secret = getEndpoint().getKubernetesClient().secrets()
- .inNamespace(namespaceName).withName(secretName).get();
-
+ secret = getEndpoint().getKubernetesClient().secrets().inNamespace(namespaceName).withName(secretName).get();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(secret);
}
- protected void doCreateSecret(Exchange exchange, String operation)
- throws Exception {
+ protected void doCreateSecret(Exchange exchange, String operation) throws Exception {
Secret secret = null;
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
- Secret secretToCreate = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SECRET, Secret.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ Secret secretToCreate = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SECRET, Secret.class);
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Create a specific secret require specify a namespace name");
- throw new IllegalArgumentException(
- "Create a specific secret require specify a namespace name");
+ throw new IllegalArgumentException("Create a specific secret require specify a namespace name");
}
if (ObjectHelper.isEmpty(secretToCreate)) {
LOG.error("Create a specific secret require specify a secret bean");
- throw new IllegalArgumentException(
- "Create a specific secret require specify a secret bean");
+ throw new IllegalArgumentException("Create a specific secret require specify a secret bean");
}
- secret = getEndpoint().getKubernetesClient().secrets()
- .inNamespace(namespaceName).create(secretToCreate);
-
+ secret = getEndpoint().getKubernetesClient().secrets().inNamespace(namespaceName).create(secretToCreate);
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(secret);
}
- protected void doDeleteSecret(Exchange exchange, String operation)
- throws Exception {
- String secretName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SECRET_NAME, String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ protected void doDeleteSecret(Exchange exchange, String operation) throws Exception {
+ String secretName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SECRET_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(secretName)) {
LOG.error("Delete a specific secret require specify a secret name");
- throw new IllegalArgumentException(
- "Delete a specific secret require specify a secret name");
+ throw new IllegalArgumentException("Delete a specific secret require specify a secret name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Delete a specific secret require specify a namespace name");
- throw new IllegalArgumentException(
- "Delete a specific secret require specify a namespace name");
+ throw new IllegalArgumentException("Delete a specific secret require specify a namespace name");
}
- boolean secretDeleted = getEndpoint().getKubernetesClient().secrets()
- .inNamespace(namespaceName).withName(secretName).delete();
-
+ boolean secretDeleted = getEndpoint().getKubernetesClient().secrets().inNamespace(namespaceName).withName(secretName).delete();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(secretDeleted);
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsEndpoint.java
index d0643b7..25f69c1 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsEndpoint.java
@@ -26,10 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Service Accounts component provides a producer to execute service account operations.
+ * The Kubernetes Service Accounts component provides a producer to execute
+ * service account operations.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-service-accounts", title = "Kubernetes Service Account",
- syntax = "kubernetes-service-accounts:masterUrl", producerOnly = true, label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-service-accounts", title = "Kubernetes Service Account", syntax = "kubernetes-service-accounts:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesServiceAccountsEndpoint extends AbstractKubernetesEndpoint {
public KubernetesServiceAccountsEndpoint(String uri, KubernetesServiceAccountsComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsProducer.java
index 1eb75be..c940d82 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsProducer.java
@@ -39,8 +39,7 @@ import org.slf4j.LoggerFactory;
public class KubernetesServiceAccountsProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory
- .getLogger(KubernetesServiceAccountsProducer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(KubernetesServiceAccountsProducer.class);
public KubernetesServiceAccountsProducer(AbstractKubernetesEndpoint endpoint) {
super(endpoint);
@@ -48,20 +47,17 @@ public class KubernetesServiceAccountsProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
public void process(Exchange exchange) throws Exception {
String operation;
- if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration()
- .getOperation())) {
- operation = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_OPERATION, String.class);
+ if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration().getOperation())) {
+ operation = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_OPERATION, String.class);
} else {
- operation = getEndpoint().getKubernetesConfiguration()
- .getOperation();
+ operation = getEndpoint().getKubernetesConfiguration().getOperation();
}
switch (operation) {
@@ -87,113 +83,89 @@ public class KubernetesServiceAccountsProducer extends DefaultProducer {
break;
default:
- throw new IllegalArgumentException("Unsupported operation "
- + operation);
+ throw new IllegalArgumentException("Unsupported operation " + operation);
}
}
protected void doList(Exchange exchange, String operation) throws Exception {
- ServiceAccountList saList = getEndpoint().getKubernetesClient().serviceAccounts().inAnyNamespace()
- .list();
+ ServiceAccountList saList = getEndpoint().getKubernetesClient().serviceAccounts().inAnyNamespace().list();
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(saList.getItems());
}
- protected void doListServiceAccountsByLabels(Exchange exchange, String operation)
- throws Exception {
+ protected void doListServiceAccountsByLabels(Exchange exchange, String operation) throws Exception {
ServiceAccountList saList = null;
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SERVICE_ACCOUNTS_LABELS, Map.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_ACCOUNTS_LABELS, Map.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (!ObjectHelper.isEmpty(namespaceName)) {
- NonNamespaceOperation<ServiceAccount, ServiceAccountList, DoneableServiceAccount, Resource<ServiceAccount, DoneableServiceAccount>> serviceAccounts;
- serviceAccounts = getEndpoint().getKubernetesClient().serviceAccounts()
- .inNamespace(namespaceName);
+ NonNamespaceOperation<ServiceAccount, ServiceAccountList, DoneableServiceAccount, Resource<ServiceAccount, DoneableServiceAccount>> serviceAccounts;
+ serviceAccounts = getEndpoint().getKubernetesClient().serviceAccounts().inNamespace(namespaceName);
for (Map.Entry<String, String> entry : labels.entrySet()) {
serviceAccounts.withLabel(entry.getKey(), entry.getValue());
}
saList = serviceAccounts.list();
} else {
- FilterWatchListMultiDeletable<ServiceAccount, ServiceAccountList, Boolean, Watch, Watcher<ServiceAccount>> serviceAccounts;
+ FilterWatchListMultiDeletable<ServiceAccount, ServiceAccountList, Boolean, Watch, Watcher<ServiceAccount>> serviceAccounts;
serviceAccounts = getEndpoint().getKubernetesClient().serviceAccounts().inAnyNamespace();
for (Map.Entry<String, String> entry : labels.entrySet()) {
serviceAccounts.withLabel(entry.getKey(), entry.getValue());
}
saList = serviceAccounts.list();
}
-
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(saList.getItems());
}
- protected void doGetServiceAccount(Exchange exchange, String operation)
- throws Exception {
+ protected void doGetServiceAccount(Exchange exchange, String operation) throws Exception {
ServiceAccount sa = null;
- String saName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SERVICE_ACCOUNT_NAME, String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String saName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_ACCOUNT_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(saName)) {
LOG.error("Get a specific Service Account require specify a Service Account name");
- throw new IllegalArgumentException(
- "Get a specific Service Account require specify a Service Account name");
+ throw new IllegalArgumentException("Get a specific Service Account require specify a Service Account name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Get a specific Service Account require specify a namespace name");
- throw new IllegalArgumentException(
- "Get a specific Service Account require specify a namespace name");
+ throw new IllegalArgumentException("Get a specific Service Account require specify a namespace name");
}
- sa = getEndpoint().getKubernetesClient().serviceAccounts()
- .inNamespace(namespaceName).withName(saName).get();
-
+ sa = getEndpoint().getKubernetesClient().serviceAccounts().inNamespace(namespaceName).withName(saName).get();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(sa);
}
- protected void doCreateServiceAccount(Exchange exchange, String operation)
- throws Exception {
+ protected void doCreateServiceAccount(Exchange exchange, String operation) throws Exception {
ServiceAccount sa = null;
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
- ServiceAccount saToCreate = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SERVICE_ACCOUNT, ServiceAccount.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ ServiceAccount saToCreate = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_ACCOUNT, ServiceAccount.class);
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Create a specific Service Account require specify a namespace name");
- throw new IllegalArgumentException(
- "Create a specific Service Account require specify a namespace name");
+ throw new IllegalArgumentException("Create a specific Service Account require specify a namespace name");
}
if (ObjectHelper.isEmpty(saToCreate)) {
LOG.error("Create a specific Service Account require specify a Service Account bean");
- throw new IllegalArgumentException(
- "Create a specific Service Account require specify a Service Account bean");
+ throw new IllegalArgumentException("Create a specific Service Account require specify a Service Account bean");
}
- sa = getEndpoint().getKubernetesClient().serviceAccounts()
- .inNamespace(namespaceName).create(saToCreate);
-
+ sa = getEndpoint().getKubernetesClient().serviceAccounts().inNamespace(namespaceName).create(saToCreate);
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(sa);
}
- protected void doDeleteServiceAccount(Exchange exchange, String operation)
- throws Exception {
- String saName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SERVICE_ACCOUNT_NAME, String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ protected void doDeleteServiceAccount(Exchange exchange, String operation) throws Exception {
+ String saName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_ACCOUNT_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(saName)) {
LOG.error("Delete a specific Service Account require specify a Service Account name");
- throw new IllegalArgumentException(
- "Delete a specific Service Account require specify a Service Account name");
+ throw new IllegalArgumentException("Delete a specific Service Account require specify a Service Account name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Delete a specific Service Account require specify a namespace name");
- throw new IllegalArgumentException(
- "Delete a specific Service Account require specify a namespace name");
+ throw new IllegalArgumentException("Delete a specific Service Account require specify a namespace name");
}
- boolean saDeleted = getEndpoint().getKubernetesClient().serviceAccounts()
- .inNamespace(namespaceName).withName(saName).delete();
-
+ boolean saDeleted = getEndpoint().getKubernetesClient().serviceAccounts().inNamespace(namespaceName).withName(saName).delete();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(saDeleted);
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesConsumer.java
index 1df41ca..2fdcf15 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesConsumer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesConsumer.java
@@ -48,7 +48,7 @@ public class KubernetesServicesConsumer extends DefaultConsumer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
@@ -57,7 +57,7 @@ public class KubernetesServicesConsumer extends DefaultConsumer {
executor = getEndpoint().createExecutor();
servicesWatcher = new ServicesConsumerTask();
- executor.submit(servicesWatcher);
+ executor.submit(servicesWatcher);
}
@@ -80,18 +80,18 @@ public class KubernetesServicesConsumer extends DefaultConsumer {
}
executor = null;
}
-
+
class ServicesConsumerTask implements Runnable {
-
+
private Watch watch;
-
+
@Override
public void run() {
MixedOperation<Service, ServiceList, DoneableService, ServiceResource<Service, DoneableService>> w = getEndpoint().getKubernetesClient().services();
if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getNamespace())) {
w.inNamespace(getEndpoint().getKubernetesConfiguration().getNamespace());
}
- if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelKey())
+ if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelKey())
&& ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getLabelValue())) {
w.withLabel(getEndpoint().getKubernetesConfiguration().getLabelKey(), getEndpoint().getKubernetesConfiguration().getLabelValue());
}
@@ -101,8 +101,7 @@ public class KubernetesServicesConsumer extends DefaultConsumer {
watch = w.watch(new Watcher<Service>() {
@Override
- public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action,
- Service resource) {
+ public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, Service resource) {
ServiceEvent se = new ServiceEvent(action, resource);
Exchange exchange = getEndpoint().createExchange();
exchange.getIn().setBody(se.getService());
@@ -124,14 +123,14 @@ public class KubernetesServicesConsumer extends DefaultConsumer {
}
});
- }
-
+ }
+
public Watch getWatch() {
return watch;
}
public void setWatch(Watch watch) {
this.watch = watch;
- }
+ }
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java
index 2ef6651..c6c3fc2 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java
@@ -26,11 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Service Accounts component provides a producer to execute service operations
- * and a consumer to consume service events.
+ * The Kubernetes Service Accounts component provides a producer to execute
+ * service operations and a consumer to consume service events.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-services", title = "Kubernetes Services",
- syntax = "kubernetes-services:masterUrl", label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-services", title = "Kubernetes Services", syntax = "kubernetes-services:masterUrl", label = "container,cloud,paas")
public class KubernetesServicesEndpoint extends AbstractKubernetesEndpoint {
public KubernetesServicesEndpoint(String uri, KubernetesServicesComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java
index ebe3fed..30502c5 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java
@@ -41,8 +41,7 @@ import org.slf4j.LoggerFactory;
public class KubernetesServicesProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory
- .getLogger(KubernetesServicesProducer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(KubernetesServicesProducer.class);
public KubernetesServicesProducer(AbstractKubernetesEndpoint endpoint) {
super(endpoint);
@@ -50,20 +49,17 @@ public class KubernetesServicesProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
public void process(Exchange exchange) throws Exception {
String operation;
- if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration()
- .getOperation())) {
- operation = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_OPERATION, String.class);
+ if (ObjectHelper.isEmpty(getEndpoint().getKubernetesConfiguration().getOperation())) {
+ operation = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_OPERATION, String.class);
} else {
- operation = getEndpoint().getKubernetesConfiguration()
- .getOperation();
+ operation = getEndpoint().getKubernetesConfiguration().getOperation();
}
switch (operation) {
@@ -89,43 +85,35 @@ public class KubernetesServicesProducer extends DefaultProducer {
break;
default:
- throw new IllegalArgumentException("Unsupported operation "
- + operation);
+ throw new IllegalArgumentException("Unsupported operation " + operation);
}
}
protected void doList(Exchange exchange, String operation) throws Exception {
ServiceList servicesList = null;
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (!ObjectHelper.isEmpty(namespaceName)) {
- servicesList = getEndpoint().getKubernetesClient().services()
- .inNamespace(namespaceName).list();
+ servicesList = getEndpoint().getKubernetesClient().services().inNamespace(namespaceName).list();
} else {
- servicesList = getEndpoint().getKubernetesClient().services().inAnyNamespace()
- .list();
+ servicesList = getEndpoint().getKubernetesClient().services().inAnyNamespace().list();
}
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(servicesList.getItems());
}
- protected void doListServiceByLabels(Exchange exchange, String operation)
- throws Exception {
+ protected void doListServiceByLabels(Exchange exchange, String operation) throws Exception {
ServiceList servicesList = null;
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SERVICE_LABELS, Map.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_LABELS, Map.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (!ObjectHelper.isEmpty(namespaceName)) {
- NonNamespaceOperation<Service, ServiceList, DoneableService, ServiceResource<Service, DoneableService>> services;
- services = getEndpoint().getKubernetesClient().services()
- .inNamespace(namespaceName);
+ NonNamespaceOperation<Service, ServiceList, DoneableService, ServiceResource<Service, DoneableService>> services;
+ services = getEndpoint().getKubernetesClient().services().inNamespace(namespaceName);
for (Map.Entry<String, String> entry : labels.entrySet()) {
services.withLabel(entry.getKey(), entry.getValue());
}
servicesList = services.list();
} else {
- FilterWatchListMultiDeletable<Service, ServiceList, Boolean, Watch, Watcher<Service>> services;
+ FilterWatchListMultiDeletable<Service, ServiceList, Boolean, Watch, Watcher<Service>> services;
services = getEndpoint().getKubernetesClient().services().inAnyNamespace();
for (Map.Entry<String, String> entry : labels.entrySet()) {
services.withLabel(entry.getKey(), entry.getValue());
@@ -136,82 +124,59 @@ public class KubernetesServicesProducer extends DefaultProducer {
exchange.getOut().setBody(servicesList.getItems());
}
- protected void doGetService(Exchange exchange, String operation)
- throws Exception {
+ protected void doGetService(Exchange exchange, String operation) throws Exception {
Service service = null;
- String serviceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SERVICE_NAME, String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ String serviceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(serviceName)) {
LOG.error("Get a specific service require specify a service name");
- throw new IllegalArgumentException(
- "Get a specific service require specify a service name");
+ throw new IllegalArgumentException("Get a specific service require specify a service name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Get a specific service require specify a namespace name");
- throw new IllegalArgumentException(
- "Get a specific service require specify a namespace name");
+ throw new IllegalArgumentException("Get a specific service require specify a namespace name");
}
- service = getEndpoint().getKubernetesClient().services()
- .inNamespace(namespaceName).withName(serviceName).get();
+ service = getEndpoint().getKubernetesClient().services().inNamespace(namespaceName).withName(serviceName).get();
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(service);
}
- protected void doCreateService(Exchange exchange, String operation)
- throws Exception {
+ protected void doCreateService(Exchange exchange, String operation) throws Exception {
Service service = null;
- String serviceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SERVICE_NAME, String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
- ServiceSpec serviceSpec = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SERVICE_SPEC, ServiceSpec.class);
+ String serviceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ ServiceSpec serviceSpec = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_SPEC, ServiceSpec.class);
if (ObjectHelper.isEmpty(serviceName)) {
LOG.error("Create a specific service require specify a service name");
- throw new IllegalArgumentException(
- "Create a specific service require specify a service name");
+ throw new IllegalArgumentException("Create a specific service require specify a service name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Create a specific service require specify a namespace name");
- throw new IllegalArgumentException(
- "Create a specific service require specify a namespace name");
+ throw new IllegalArgumentException("Create a specific service require specify a namespace name");
}
if (ObjectHelper.isEmpty(serviceSpec)) {
LOG.error("Create a specific service require specify a service spec bean");
- throw new IllegalArgumentException(
- "Create a specific service require specify a service spec bean");
+ throw new IllegalArgumentException("Create a specific service require specify a service spec bean");
}
- Map<String, String> labels = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SERVICE_LABELS, Map.class);
- Service serviceCreating = new ServiceBuilder()
- .withNewMetadata().withName(serviceName).withLabels(labels)
- .endMetadata().withSpec(serviceSpec).build();
- service = getEndpoint().getKubernetesClient().services()
- .inNamespace(namespaceName).create(serviceCreating);
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_LABELS, Map.class);
+ Service serviceCreating = new ServiceBuilder().withNewMetadata().withName(serviceName).withLabels(labels).endMetadata().withSpec(serviceSpec).build();
+ service = getEndpoint().getKubernetesClient().services().inNamespace(namespaceName).create(serviceCreating);
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(service);
}
- protected void doDeleteService(Exchange exchange, String operation)
- throws Exception {
- String serviceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_SERVICE_NAME, String.class);
- String namespaceName = exchange.getIn().getHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
+ protected void doDeleteService(Exchange exchange, String operation) throws Exception {
+ String serviceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_NAME, String.class);
+ String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(serviceName)) {
LOG.error("Delete a specific service require specify a service name");
- throw new IllegalArgumentException(
- "Delete a specific service require specify a service name");
+ throw new IllegalArgumentException("Delete a specific service require specify a service name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
LOG.error("Delete a specific service require specify a namespace name");
- throw new IllegalArgumentException(
- "Delete a specific service require specify a namespace name");
+ throw new IllegalArgumentException("Delete a specific service require specify a namespace name");
}
- boolean serviceDeleted = getEndpoint().getKubernetesClient().services()
- .inNamespace(namespaceName).withName(serviceName).delete();
+ boolean serviceDeleted = getEndpoint().getKubernetesClient().services().inNamespace(namespaceName).withName(serviceName).delete();
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(serviceDeleted);
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsEndpoint.java
index 71bf551..4765d1c 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsEndpoint.java
@@ -26,10 +26,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Kubernetes Build Config component provides a producer to execute kubernetes build config operations.
+ * The Kubernetes Build Config component provides a producer to execute
+ * kubernetes build config operations.
*/
-@UriEndpoint(firstVersion = "2.17.0", scheme = "openshift-build-configs", title = "Openshift Build Config",
- syntax = "openshift-build-configs:masterUrl", producerOnly = true, label = "container,cloud,paas")
+@UriEndpoint(firstVersion = "2.17.0", scheme = "openshift-build-configs", title = "Openshift Build Config", syntax = "openshift-build-configs:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class OpenshiftBuildConfigsEndpoint extends AbstractKubernetesEndpoint {
public OpenshiftBuildConfigsEndpoint(String uri, OpenshiftBuildConfigsComponent component, KubernetesConfiguration config) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsProducer.java
index 26bf94f..d0e098c 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsProducer.java
@@ -45,7 +45,7 @@ public class OpenshiftBuildConfigsProducer extends DefaultProducer {
@Override
public AbstractKubernetesEndpoint getEndpoint() {
- return (AbstractKubernetesEndpoint) super.getEndpoint();
+ return (AbstractKubernetesEndpoint)super.getEndpoint();
}
@Override
@@ -78,27 +78,23 @@ public class OpenshiftBuildConfigsProducer extends DefaultProducer {
}
protected void doList(Exchange exchange, String operation) throws Exception {
- BuildConfigList buildConfigsList = getEndpoint().getKubernetesClient().adapt(OpenShiftClient.class)
- .buildConfigs().inAnyNamespace().list();
+ BuildConfigList buildConfigsList = getEndpoint().getKubernetesClient().adapt(OpenShiftClient.class).buildConfigs().inAnyNamespace().list();
exchange.getOut().setBody(buildConfigsList.getItems());
}
protected void doListBuildConfigsByLabels(Exchange exchange, String operation) throws Exception {
BuildConfigList buildConfigsList = null;
- Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_BUILD_CONFIGS_LABELS,
- Map.class);
+ Map<String, String> labels = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_BUILD_CONFIGS_LABELS, Map.class);
String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (!ObjectHelper.isEmpty(namespaceName)) {
- NonNamespaceOperation<BuildConfig, BuildConfigList, DoneableBuildConfig,
- BuildConfigResource<BuildConfig, DoneableBuildConfig, Void, Build>> buildConfigs;
- buildConfigs = getEndpoint().getKubernetesClient().adapt(OpenShiftClient.class).buildConfigs()
- .inNamespace(namespaceName);
+ NonNamespaceOperation<BuildConfig, BuildConfigList, DoneableBuildConfig, BuildConfigResource<BuildConfig, DoneableBuildConfig, Void, Build>> buildConfigs;
+ buildConfigs = getEndpoint().getKubernetesClient().adapt(OpenShiftClient.class).buildConfigs().inNamespace(namespaceName);
for (Map.Entry<String, String> entry : labels.entrySet()) {
buildConfigs.withLabel(entry.getKey(), entry.getValue());
}
buildConfigsList = buildConfigs.list();
} else {
- FilterWatchListMultiDeletable<BuildConfig, BuildConfigList, Boolean, Watch, Watcher<BuildConfig>> buildConfigs;
+ FilterWatchListMultiDeletable<BuildConfig, BuildConfigList, Boolean, Watch, Watcher<BuildConfig>> buildConfigs;
buildConfigs = getEndpoint().getKubernetesClient().adapt(OpenShiftClient.class).buildConfigs().inAnyNamespace();
for (Map.Entry<String, String> entry : labels.entrySet()) {
buildConfigs.withLabel(entry.getKey(), entry.getValue());
@@ -111,8 +107,7 @@ public class OpenshiftBuildConfigsProducer extends DefaultProducer {
protected void doGetBuildConfig(Exchange exchange, String operation) throws Exception {
BuildConfig buildConfig = null;
- String buildConfigName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_BUILD_CONFIG_NAME,
- String.class);
+ String buildConfigName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_BUILD_CONFIG_NAME, String.class);
String namespaceName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class);
if (ObjectHelper.isEmpty(buildConfigName)) {
log.error("Get a specific Build Config require specify a Build Config name");
@@ -122,9 +117,8 @@ public class OpenshiftBuildConfigsProducer extends DefaultProducer {
log.error("Get a specific Build Config require specify a namespace name");
throw new IllegalArgumentException("Get a specific Build Config require specify a namespace name");
}
- buildConfig = getEndpoint().getKubernetesClient().adapt(OpenShiftClient.class).buildConfigs()
- .inNamespace(namespaceName).withName(buildConfigName).get();
-
+ buildConfig = getEndpoint().getKubernetesClient().adapt(OpenShiftClient.class).buildConfigs().inNamespace(namespaceName).withName(buildConfigName).get();
+
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(buildConfig);
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsEndpoint.java
index d780efe..0efef79 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsEndpoint.java
@@ -26,7 +26,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Openshift Builds component provides a producer to execute openshift build operations.
+ * The Openshift Builds component provides a producer to execute openshift build
+ * operations.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "openshift-builds", title = "Openshift Builds", syntax = "openshift-builds:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class OpenshiftBuildsEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/KubernetesTestSupport.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/KubernetesTestSupport.java
index faa2bc3..90d7cd4 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/KubernetesTestSupport.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/KubernetesTestSupport.java
@@ -38,7 +38,7 @@ public class KubernetesTestSupport extends CamelTestSupport {
host = "https://192.168.99.100:8443";
super.setUp();
}
-
+
public static String toUrlEncoded(String str) throws UnsupportedEncodingException {
return URLEncoder.encode(str, "UTF-8");
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallClientRouteTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallClientRouteTest.java
index 74699c5..959096f 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallClientRouteTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallClientRouteTest.java
@@ -53,10 +53,7 @@ public class ServiceCallClientRouteTest extends CamelTestSupport {
// register configuration
context.setServiceCallConfiguration(config);
- from("direct:start")
- .serviceCall("cdi-camel-jetty")
- .serviceCall("cdi-camel-jetty")
- .to("mock:result");
+ from("direct:start").serviceCall("cdi-camel-jetty").serviceCall("cdi-camel-jetty").to("mock:result");
}
};
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallEnvironmentRouteTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallEnvironmentRouteTest.java
index 3653438..d5b989d 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallEnvironmentRouteTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cloud/ServiceCallEnvironmentRouteTest.java
@@ -46,10 +46,7 @@ public class ServiceCallEnvironmentRouteTest extends CamelTestSupport {
// register configuration
context.setServiceCallConfiguration(config);
- from("direct:start")
- .serviceCall("cdi-camel-jetty")
- .serviceCall("cdi-camel-jetty")
- .to("mock:result");
+ from("direct:start").serviceCall("cdi-camel-jetty").serviceCall("cdi-camel-jetty").to("mock:result");
}
};
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java
index dfa12bb..9066a66 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java
@@ -101,10 +101,7 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
@Test
public void testSimpleLeaderElectionWithExistingConfigMap() throws Exception {
- lockSimulator.setConfigMap(new ConfigMapBuilder()
- .withNewMetadata()
- .withName("leaders")
- .and().build(), true);
+ lockSimulator.setConfigMap(new ConfigMapBuilder().withNewMetadata().withName("leaders").and().build(), true);
LeaderRecorder mypod1 = addMember("mypod1");
LeaderRecorder mypod2 = addMember("mypod2");
@@ -144,7 +141,8 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
Long lossTimestamp = formerLeaderRecorder.getLastTimeOf(l -> l == null);
Long gainTimestamp = formerLoserRecorder.getLastTimeOf(secondLeader::equals);
- assertTrue("At least half distance must elapse from leadership loss and regain (see renewDeadlineSeconds)", gainTimestamp >= lossTimestamp + (LEASE_TIME_MILLIS - RENEW_DEADLINE_MILLIS) / 2);
+ assertTrue("At least half distance must elapse from leadership loss and regain (see renewDeadlineSeconds)",
+ gainTimestamp >= lossTimestamp + (LEASE_TIME_MILLIS - RENEW_DEADLINE_MILLIS) / 2);
checkLeadershipChangeDistance((LEASE_TIME_MILLIS - RENEW_DEADLINE_MILLIS) / 2, TimeUnit.MILLISECONDS, mypod1, mypod2);
}
@@ -239,10 +237,8 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
}
private void checkLeadershipChangeDistance(long minimum, TimeUnit unit, LeaderRecorder... recorders) {
- List<LeaderRecorder.LeadershipInfo> infos = Arrays.stream(recorders)
- .flatMap(lr -> lr.getLeadershipInfo().stream())
- .sorted((li1, li2) -> Long.compare(li1.getChangeTimestamp(), li2.getChangeTimestamp()))
- .collect(Collectors.toList());
+ List<LeaderRecorder.LeadershipInfo> infos = Arrays.stream(recorders).flatMap(lr -> lr.getLeadershipInfo().stream())
+ .sorted((li1, li2) -> Long.compare(li1.getChangeTimestamp(), li2.getChangeTimestamp())).collect(Collectors.toList());
LeaderRecorder.LeadershipInfo currentLeaderLastSeen = null;
for (LeaderRecorder.LeadershipInfo info : infos) {
@@ -254,8 +250,8 @@ public class KubernetesClusterServiceTest extends CamelTestSupport {
} else if (info.getLeader() != null && !info.getLeader().equals(currentLeaderLastSeen.getLeader())) {
// switch
long delay = info.getChangeTimestamp() - currentLeaderLastSeen.getChangeTimestamp();
- assertTrue("Lease time not elapsed between switch, minimum=" + TimeUnit.MILLISECONDS.convert(minimum, unit) + ", found=" + delay, delay >= TimeUnit.MILLISECONDS.convert(minimum,
- unit));
+ assertTrue("Lease time not elapsed between switch, minimum=" + TimeUnit.MILLISECONDS.convert(minimum, unit) + ", found=" + delay,
+ delay >= TimeUnit.MILLISECONDS.convert(minimum, unit));
currentLeaderLastSeen = info;
}
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/TimedLeaderNotifierTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/TimedLeaderNotifierTest.java
index 2372fa6..24f029e 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/TimedLeaderNotifierTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/TimedLeaderNotifierTest.java
@@ -52,9 +52,9 @@ public class TimedLeaderNotifierTest {
this.notifier = new TimedLeaderNotifier(context, e -> {
if (e instanceof KubernetesClusterEvent.KubernetesClusterLeaderChangedEvent) {
- currentLeader = ((KubernetesClusterEvent.KubernetesClusterLeaderChangedEvent) e).getData();
+ currentLeader = ((KubernetesClusterEvent.KubernetesClusterLeaderChangedEvent)e).getData();
} else if (e instanceof KubernetesClusterEvent.KubernetesClusterMemberListChangedEvent) {
- currentMembers = ((KubernetesClusterEvent.KubernetesClusterMemberListChangedEvent) e).getData();
+ currentMembers = ((KubernetesClusterEvent.KubernetesClusterMemberListChangedEvent)e).getData();
}
});
this.notifier.start();
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/ConfigMapLockSimulator.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/ConfigMapLockSimulator.java
index 9a43d02..1df7628 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/ConfigMapLockSimulator.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/ConfigMapLockSimulator.java
@@ -64,11 +64,7 @@ public class ConfigMapLockSimulator {
}
}
- this.currentMap = new ConfigMapBuilder(map)
- .editOrNewMetadata()
- .withResourceVersion(String.valueOf(++versionCounter))
- .endMetadata()
- .build();
+ this.currentMap = new ConfigMapBuilder(map).editOrNewMetadata().withResourceVersion(String.valueOf(++versionCounter)).endMetadata().build();
return true;
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServer.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServer.java
index ef5d563..e20c73e 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServer.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServer.java
@@ -58,10 +58,10 @@ public class LockTestServer extends KubernetesMockServer {
this.pods = new TreeSet<>(initialPods);
expect().get().withPath("/api/v1/namespaces/test/configmaps/" + lockSimulator.getConfigMapName()).andReply(new ResponseProvider<Object>() {
- ThreadLocal<Integer> responseCode = ThreadLocal.withInitial(() -> 1);
+ ThreadLocal<Integer> responseCode = ThreadLocal.withInitial(() -> 1);
private Headers headers = new Headers.Builder().build();
-
+
@Override
public int getStatusCode() {
return responseCode.get();
@@ -98,7 +98,7 @@ public class LockTestServer extends KubernetesMockServer {
expect().post().withPath("/api/v1/namespaces/test/configmaps").andReply(new ResponseProvider<Object>() {
ThreadLocal<Integer> responseCode = ThreadLocal.withInitial(() -> 1);
-
+
private Headers headers = new Headers.Builder().build();
@Override
@@ -142,7 +142,7 @@ public class LockTestServer extends KubernetesMockServer {
expect().put().withPath("/api/v1/namespaces/test/configmaps/" + lockSimulator.getConfigMapName()).andReply(new ResponseProvider<Object>() {
ThreadLocal<Integer> responseCode = ThreadLocal.withInitial(() -> 1);
-
+
private Headers headers = new Headers.Builder().build();
@Override
@@ -184,8 +184,8 @@ public class LockTestServer extends KubernetesMockServer {
// Other resources
expect().get().withPath("/api/v1/namespaces/test/pods")
.andReply(200,
- request -> new PodListBuilder().withNewMetadata().withResourceVersion("1").and().withItems(getCurrentPods()
- .stream().map(name -> new PodBuilder().withNewMetadata().withName(name).and().build()).collect(Collectors.toList())).build())
+ request -> new PodListBuilder().withNewMetadata().withResourceVersion("1").and()
+ .withItems(getCurrentPods().stream().map(name -> new PodBuilder().withNewMetadata().withName(name).and().build()).collect(Collectors.toList())).build())
.always();
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServerTest.java
index fae9bed..64e3d16 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LockTestServerTest.java
@@ -41,52 +41,28 @@ public class LockTestServerTest {
assertNull(client.configMaps().withName("xxx").get());
- client.configMaps().withName("xxx").createNew()
- .withNewMetadata()
- .withName("xxx")
- .and().done();
+ client.configMaps().withName("xxx").createNew().withNewMetadata().withName("xxx").and().done();
try {
- client.configMaps().withName("xxx").createNew()
- .withNewMetadata()
- .withName("xxx")
- .and().done();
+ client.configMaps().withName("xxx").createNew().withNewMetadata().withName("xxx").and().done();
Assert.fail("Should have failed for duplicate insert");
} catch (Exception e) {
}
- client.configMaps().withName("xxx")
- .createOrReplaceWithNew()
- .editOrNewMetadata()
- .withName("xxx")
- .addToLabels("a", "b")
- .and().done();
+ client.configMaps().withName("xxx").createOrReplaceWithNew().editOrNewMetadata().withName("xxx").addToLabels("a", "b").and().done();
ConfigMap map = client.configMaps().withName("xxx").get();
assertEquals("b", map.getMetadata().getLabels().get("a"));
-
- client.configMaps().withName("xxx")
- .lockResourceVersion(map.getMetadata().getResourceVersion())
- .replace(new ConfigMapBuilder(map)
- .editOrNewMetadata()
- .withName("xxx")
- .addToLabels("c", "d")
- .and()
- .build());
+ client.configMaps().withName("xxx").lockResourceVersion(map.getMetadata().getResourceVersion())
+ .replace(new ConfigMapBuilder(map).editOrNewMetadata().withName("xxx").addToLabels("c", "d").and().build());
ConfigMap newMap = client.configMaps().withName("xxx").get();
assertEquals("d", newMap.getMetadata().getLabels().get("c"));
try {
- client.configMaps().withName("xxx")
- .lockResourceVersion(map.getMetadata().getResourceVersion())
- .replace(new ConfigMapBuilder(map)
- .editOrNewMetadata()
- .withName("xxx")
- .addToLabels("e", "f")
- .and()
- .build());
+ client.configMaps().withName("xxx").lockResourceVersion(map.getMetadata().getResourceVersion())
+ .replace(new ConfigMapBuilder(map).editOrNewMetadata().withName("xxx").addToLabels("e", "f").and().build());
Assert.fail("Should have failed for wrong version");
} catch (Exception ex) {
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumerTest.java
index fc3f7a3..c4b06fe 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNamespacesConsumerTest.java
@@ -48,25 +48,18 @@ public class KubernetesNamespacesConsumerTest extends KubernetesTestSupport {
}
mockResultEndpoint.expectedMessageCount(5);
- mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED",
- "MODIFIED", "MODIFIED", "MODIFIED", "DELETED");
-
- Exchange ex = template.request("direct:createNamespace",
- new Processor() {
-
- @Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
- "test");
- Map<String, String> labels = new HashMap<>();
- labels.put("this", "rocks");
- exchange.getIn()
- .setHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_LABELS,
- labels);
- }
- });
+ mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED", "MODIFIED", "MODIFIED", "MODIFIED", "DELETED");
+
+ Exchange ex = template.request("direct:createNamespace", new Processor() {
+
+ @Override
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "test");
+ Map<String, String> labels = new HashMap<>();
+ labels.put("this", "rocks");
+ exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_LABELS, labels);
+ }
+ });
Namespace ns = ex.getOut().getBody(Namespace.class);
@@ -78,10 +71,7 @@ public class KubernetesNamespacesConsumerTest extends KubernetesTestSupport {
public void process(Exchange exchange) throws Exception {
Map<String, String> labels = new HashMap<>();
labels.put("this", "rocks");
- exchange.getIn()
- .setHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_LABELS,
- labels);
+ exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_LABELS, labels);
}
});
@@ -103,15 +93,14 @@ public class KubernetesNamespacesConsumerTest extends KubernetesTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(
- KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "test");
+ exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "test");
}
});
boolean nsDeleted = ex.getOut().getBody(Boolean.class);
assertTrue(nsDeleted);
-
+
Thread.sleep(3000);
mockResultEndpoint.assertIsSatisfied();
@@ -122,19 +111,12 @@ public class KubernetesNamespacesConsumerTest extends KubernetesTestSupport {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("direct:list").toF("kubernetes-namespaces://%s?oauthToken=%s&operation=listNamespaces",
- host, authToken);
- from("direct:listByLabels").toF(
- "kubernetes-namespaces://%s?oauthToken=%s&operation=listNamespacesByLabels", host,
- authToken);
- from("direct:getNs").toF("kubernetes-namespaces://%s?oauthToken=%s&operation=getNamespace",
- host, authToken);
- from("direct:createNamespace").toF(
- "kubernetes-namespaces://%s?oauthToken=%s&operation=createNamespace", host, authToken);
- from("direct:deleteNamespace").toF(
- "kubernetes-namespaces://%s?oauthToken=%s&operation=deleteNamespace", host, authToken);
- fromF("kubernetes-namespaces://%s?oauthToken=%s", host, authToken).process(
- new KubernertesProcessor()).to(mockResultEndpoint);
+ from("direct:list").toF("kubernetes-namespaces://%s?oauthToken=%s&operation=listNamespaces", host, authToken);
+ from("direct:listByLabels").toF("kubernetes-namespaces://%s?oauthToken=%s&operation=listNamespacesByLabels", host, authToken);
+ from("direct:getNs").toF("kubernetes-namespaces://%s?oauthToken=%s&operation=getNamespace", host, authToken);
+ from("direct:createNamespace").toF("kubernetes-namespaces://%s?oauthToken=%s&operation=createNamespace", host, authToken);
+ from("direct:deleteNamespace").toF("kubernetes-namespaces://%s?oauthToken=%s&operation=deleteNamespace", host, authToken);
+ fromF("kubernetes-namespaces://%s?oauthToken=%s", host, authToken).process(new KubernertesProcessor()).to(mockResultEndpoint);
}
};
}
@@ -143,8 +125,7 @@ public class KubernetesNamespacesConsumerTest extends KubernetesTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
Message in = exchange.getIn();
- log.info("Got event with body: " + in.getBody() + " and action "
- + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ log.info("Got event with body: " + in.getBody() + " and action " + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNodesConsumerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNodesConsumerTest.java
index 5646c7a..d3a0fbc 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNodesConsumerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesNodesConsumerTest.java
@@ -85,7 +85,7 @@ public class KubernetesNodesConsumerTest extends KubernetesTestSupport {
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_POD_SPEC, podSpec);
}
});
-
+
ex = template.request("direct:deletePod", new Processor() {
@Override
@@ -109,18 +109,12 @@ public class KubernetesNodesConsumerTest extends KubernetesTestSupport {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("direct:list").toF("kubernetes-pods://%s?oauthToken=%s&operation=listPods", host,
- authToken);
- from("direct:listByLabels")
- .toF("kubernetes-pods://%s?oauthToken=%s&operation=listPodsByLabels", host, authToken);
- from("direct:getPod").toF("kubernetes-pods://%s?oauthToken=%s&operation=getPod", host,
- authToken);
- from("direct:createPod").toF("kubernetes-pods://%s?oauthToken=%s&operation=createPod", host,
- authToken);
- from("direct:deletePod").toF("kubernetes-pods://%s?oauthToken=%s&operation=deletePod", host,
- authToken);
- fromF("kubernetes-nodes://%s?oauthToken=%s&resourceName=minikube", host, authToken)
- .process(new KubernertesProcessor()).to(mockResultEndpoint);
+ from("direct:list").toF("kubernetes-pods://%s?oauthToken=%s&operation=listPods", host, authToken);
+ from("direct:listByLabels").toF("kubernetes-pods://%s?oauthToken=%s&operation=listPodsByLabels", host, authToken);
+ from("direct:getPod").toF("kubernetes-pods://%s?oauthToken=%s&operation=getPod", host, authToken);
+ from("direct:createPod").toF("kubernetes-pods://%s?oauthToken=%s&operation=createPod", host, authToken);
+ from("direct:deletePod").toF("kubernetes-pods://%s?oauthToken=%s&operation=deletePod", host, authToken);
+ fromF("kubernetes-nodes://%s?oauthToken=%s&resourceName=minikube", host, authToken).process(new KubernertesProcessor()).to(mockResultEndpoint);
}
};
}
@@ -130,8 +124,7 @@ public class KubernetesNodesConsumerTest extends KubernetesTestSupport {
public void process(Exchange exchange) throws Exception {
Message in = exchange.getIn();
Node node = exchange.getIn().getBody(Node.class);
- log.info("Got event with node name: " + node.getMetadata().getName() + " and action "
- + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ log.info("Got event with node name: " + node.getMetadata().getName() + " and action " + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumerTest.java
index c7de7a8..c2ca36e 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumerTest.java
@@ -51,8 +51,7 @@ public class KubernetesPodsConsumerTest extends KubernetesTestSupport {
}
mockResultEndpoint.expectedMessageCount(3);
- mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED",
- "MODIFIED", "MODIFIED");
+ mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED", "MODIFIED", "MODIFIED");
Exchange ex = template.request("direct:createPod", new Processor() {
@Override
@@ -86,7 +85,7 @@ public class KubernetesPodsConsumerTest extends KubernetesTestSupport {
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_POD_SPEC, podSpec);
}
});
-
+
ex = template.request("direct:deletePod", new Processor() {
@Override
@@ -110,18 +109,13 @@ public class KubernetesPodsConsumerTest extends KubernetesTestSupport {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("direct:list").toF("kubernetes-pods://%s?oauthToken=%s&operation=listPods", host,
- authToken);
- from("direct:listByLabels")
- .toF("kubernetes-pods://%s?oauthToken=%s&operation=listPodsByLabels", host, authToken);
- from("direct:getPod").toF("kubernetes-pods://%s?oauthToken=%s&operation=getPod", host,
- authToken);
- from("direct:createPod").toF("kubernetes-pods://%s?oauthToken=%s&operation=createPod", host,
- authToken);
- from("direct:deletePod").toF("kubernetes-pods://%s?oauthToken=%s&operation=deletePod", host,
- authToken);
- fromF("kubernetes-pods://%s?oauthToken=%s&namespace=default&labelKey=this&labelValue=rocks", host, authToken)
- .process(new KubernertesProcessor()).to(mockResultEndpoint);
+ from("direct:list").toF("kubernetes-pods://%s?oauthToken=%s&operation=listPods", host, authToken);
+ from("direct:listByLabels").toF("kubernetes-pods://%s?oauthToken=%s&operation=listPodsByLabels", host, authToken);
+ from("direct:getPod").toF("kubernetes-pods://%s?oauthToken=%s&operation=getPod", host, authToken);
+ from("direct:createPod").toF("kubernetes-pods://%s?oauthToken=%s&operation=createPod", host, authToken);
+ from("direct:deletePod").toF("kubernetes-pods://%s?oauthToken=%s&operation=deletePod", host, authToken);
+ fromF("kubernetes-pods://%s?oauthToken=%s&namespace=default&labelKey=this&labelValue=rocks", host, authToken).process(new KubernertesProcessor())
+ .to(mockResultEndpoint);
}
};
}
@@ -131,8 +125,7 @@ public class KubernetesPodsConsumerTest extends KubernetesTestSupport {
public void process(Exchange exchange) throws Exception {
Message in = exchange.getIn();
Pod pod = exchange.getIn().getBody(Pod.class);
- log.info("Got event with pod name: " + pod.getMetadata().getName() + " and action "
- + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ log.info("Got event with pod name: " + pod.getMetadata().getName() + " and action " + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumerTest.java
index 41f7e93..28fe9bc 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumerTest.java
@@ -48,8 +48,7 @@ public class KubernetesReplicationControllersConsumerTest extends KubernetesTest
return;
}
- mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED",
- "DELETED", "MODIFIED", "MODIFIED", "MODIFIED");
+ mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED", "DELETED", "MODIFIED", "MODIFIED", "MODIFIED");
Exchange ex = template.request("direct:createReplicationController", new Processor() {
@Override
@@ -62,10 +61,8 @@ public class KubernetesReplicationControllersConsumerTest extends KubernetesTest
ReplicationControllerSpec rcSpec = new ReplicationControllerSpec();
rcSpec.setReplicas(2);
PodTemplateSpecBuilder builder = new PodTemplateSpecBuilder();
- PodTemplateSpec t = builder.withNewMetadata().withName("nginx-template")
- .addToLabels("server", "nginx").endMetadata().withNewSpec().addNewContainer()
- .withName("wildfly").withImage("jboss/wildfly").addNewPort().withContainerPort(80).endPort()
- .endContainer().endSpec().build();
+ PodTemplateSpec t = builder.withNewMetadata().withName("nginx-template").addToLabels("server", "nginx").endMetadata().withNewSpec().addNewContainer()
+ .withName("wildfly").withImage("jboss/wildfly").addNewPort().withContainerPort(80).endPort().endContainer().endSpec().build();
rcSpec.setTemplate(t);
Map<String, String> selectorMap = new HashMap<>();
selectorMap.put("server", "nginx");
@@ -101,23 +98,12 @@ public class KubernetesReplicationControllersConsumerTest extends KubernetesTest
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("direct:list").toF(
- "kubernetes-replication-controllers://%s?oauthToken=%s&operation=listReplicationControllers",
- host, authToken);
- from("direct:listByLabels").toF(
- "kubernetes-replication-controllers://%s?oauthToken=%s&operation=listReplicationControllersByLabels",
- host, authToken);
- from("direct:getReplicationController").toF(
- "kubernetes-replication-controllers://%s?oauthToken=%s&operation=getReplicationController",
- host, authToken);
- from("direct:createReplicationController").toF(
- "kubernetes-replication-controllers://%s?oauthToken=%s&operation=createReplicationController",
- host, authToken);
- from("direct:deleteReplicationController").toF(
- "kubernetes-replication-controllers://%s?oauthToken=%s&operation=deleteReplicationController",
- host, authToken);
- fromF("kubernetes-replication-controllers://%s?oauthToken=%s&resourceName=wildfly", host, authToken)
- .process(new KubernertesProcessor()).to(mockResultEndpoint);
+ from("direct:list").toF("kubernetes-replication-controllers://%s?oauthToken=%s&operation=listReplicationControllers", host, authToken);
+ from("direct:listByLabels").toF("kubernetes-replication-controllers://%s?oauthToken=%s&operation=listReplicationControllersByLabels", host, authToken);
+ from("direct:getReplicationController").toF("kubernetes-replication-controllers://%s?oauthToken=%s&operation=getReplicationController", host, authToken);
+ from("direct:createReplicationController").toF("kubernetes-replication-controllers://%s?oauthToken=%s&operation=createReplicationController", host, authToken);
+ from("direct:deleteReplicationController").toF("kubernetes-replication-controllers://%s?oauthToken=%s&operation=deleteReplicationController", host, authToken);
+ fromF("kubernetes-replication-controllers://%s?oauthToken=%s&resourceName=wildfly", host, authToken).process(new KubernertesProcessor()).to(mockResultEndpoint);
}
};
}
@@ -126,8 +112,7 @@ public class KubernetesReplicationControllersConsumerTest extends KubernetesTest
@Override
public void process(Exchange exchange) throws Exception {
Message in = exchange.getIn();
- log.info("Got event with body: " + in.getBody() + " and action "
- + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ log.info("Got event with body: " + in.getBody() + " and action " + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumerTest.java
index 7a04505..dea6ee5 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumerTest.java
@@ -51,8 +51,7 @@ public class KubernetesServicesConsumerTest extends KubernetesTestSupport {
}
mockResultEndpoint.expectedMessageCount(2);
- mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED",
- "DELETED");
+ mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED", "DELETED");
Exchange ex = template.request("direct:createService", new Processor() {
@Override
@@ -104,19 +103,12 @@ public class KubernetesServicesConsumerTest extends KubernetesTestSupport {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("direct:list").toF("kubernetes-services://%s?oauthToken=%s&operation=listServices", host,
- authToken);
- from("direct:listByLabels").toF(
- "kubernetes-services://%s?oauthToken=%s&operation=listServicesByLabels", host,
- authToken);
- from("direct:getServices").toF("kubernetes-services://%s?oauthToken=%s&operation=getService",
- host, authToken);
- from("direct:createService").toF(
- "kubernetes-services://%s?oauthToken=%s&operation=createService", host, authToken);
- from("direct:deleteService").toF(
- "kubernetes-services://%s?oauthToken=%s&operation=deleteService", host, authToken);
- fromF("kubernetes-services://%s?oauthToken=%s&labelKey=this&labelValue=rocks", host, authToken)
- .process(new KubernertesProcessor()).to(mockResultEndpoint);
+ from("direct:list").toF("kubernetes-services://%s?oauthToken=%s&operation=listServices", host, authToken);
+ from("direct:listByLabels").toF("kubernetes-services://%s?oauthToken=%s&operation=listServicesByLabels", host, authToken);
+ from("direct:getServices").toF("kubernetes-services://%s?oauthToken=%s&operation=getService", host, authToken);
+ from("direct:createService").toF("kubernetes-services://%s?oauthToken=%s&operation=createService", host, authToken);
+ from("direct:deleteService").toF("kubernetes-services://%s?oauthToken=%s&operation=deleteService", host, authToken);
+ fromF("kubernetes-services://%s?oauthToken=%s&labelKey=this&labelValue=rocks", host, authToken).process(new KubernertesProcessor()).to(mockResultEndpoint);
}
};
}
@@ -125,8 +117,7 @@ public class KubernetesServicesConsumerTest extends KubernetesTestSupport {
@Override
public void process(Exchange exchange) throws Exception {
Message in = exchange.getIn();
- log.info("Got event with body: " + in.getBody() + " and action "
- + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ log.info("Got event with body: " + in.getBody() + " and action " + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildConfigsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildConfigsProducerTest.java
index 14bf4bd..83c97a4 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildConfigsProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildConfigsProducerTest.java
@@ -43,30 +43,18 @@ public class OpenshiftBuildConfigsProducerTest extends KubernetesTestSupport {
@BindToRegistry("client")
public NamespacedOpenShiftClient loadClient() throws Exception {
- server.expect().withPath("/apis/build.openshift.io/v1/namespaces/test/buildconfigs").andReturn(200, new BuildConfigListBuilder().build()).once();
+ server.expect().withPath("/apis/build.openshift.io/v1/namespaces/test/buildconfigs").andReturn(200, new BuildConfigListBuilder().build()).once();
- server.expect().withPath("/apis").andReturn(200, new APIGroupListBuilder()
- .addNewGroup()
- .withApiVersion("v1")
- .withName("autoscaling.k8s.io")
- .endGroup()
- .addNewGroup()
- .withApiVersion("v1")
- .withName("security.openshift.io")
- .endGroup()
- .build()).always();
+ server.expect().withPath("/apis").andReturn(200, new APIGroupListBuilder().addNewGroup().withApiVersion("v1").withName("autoscaling.k8s.io").endGroup().addNewGroup()
+ .withApiVersion("v1").withName("security.openshift.io").endGroup().build()).always();
- server.expect().withPath("/apis/build.openshift.io/v1/namespaces/test/buildconfigs").andReturn(200, new BuildConfigListBuilder()
- .addNewItem().and()
- .addNewItem().and().build()).once();
+ server.expect().withPath("/apis/build.openshift.io/v1/namespaces/test/buildconfigs")
+ .andReturn(200, new BuildConfigListBuilder().addNewItem().and().addNewItem().and().build()).once();
- server.expect().withPath("/apis/build.openshift.io/v1/buildconfigs").andReturn(200, new BuildConfigListBuilder()
- .addNewItem().and()
- .addNewItem().and()
- .addNewItem()
- .and().build()).once();
-
- return server.getOpenshiftClient();
+ server.expect().withPath("/apis/build.openshift.io/v1/buildconfigs")
+ .andReturn(200, new BuildConfigListBuilder().addNewItem().and().addNewItem().and().addNewItem().and().build()).once();
+
+ return server.getOpenshiftClient();
}
@Test
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildsProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildsProducerTest.java
index bd95242..33ed996 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildsProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/openshift/producer/OpenshiftBuildsProducerTest.java
@@ -42,20 +42,12 @@ public class OpenshiftBuildsProducerTest extends KubernetesTestSupport {
@BindToRegistry("client")
public OpenShiftClient loadClient() throws Exception {
- server.expect().withPath("/apis/build.openshift.io/v1/builds").andReturn(200, new BuildListBuilder().addNewItem().and().addNewItem().and().build()).once();
+ server.expect().withPath("/apis/build.openshift.io/v1/builds").andReturn(200, new BuildListBuilder().addNewItem().and().addNewItem().and().build()).once();
server.expect().withPath("/apis/build.openshift.io/v1/builds?labelSelector=" + toUrlEncoded("key1=value1,key2=value2"))
- .andReturn(200, new BuildListBuilder().addNewItem().and().addNewItem().and().build()).once();
- server.expect().withPath("/apis").andReturn(200, new APIGroupListBuilder()
- .addNewGroup()
- .withApiVersion("v1")
- .withName("autoscaling.k8s.io")
- .endGroup()
- .addNewGroup()
- .withApiVersion("v1")
- .withName("security.openshift.io")
- .endGroup()
- .build()).always();
- return server.getOpenshiftClient();
+ .andReturn(200, new BuildListBuilder().addNewItem().and().addNewItem().and().build()).once();
+ server.expect().withPath("/apis").andReturn(200, new APIGroupListBuilder().addNewGroup().withApiVersion("v1").withName("autoscaling.k8s.io").endGroup().addNewGroup()
+ .withApiVersion("v1").withName("security.openshift.io").endGroup().build()).always();
+ return server.getOpenshiftClient();
}
@Test