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 0b818aea947e8eb36ed78d3df9f5281113ec71cb
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Sep 20 16:04:00 2019 +0200

    Regen docs
---
 .../pages/kubernetes-deployments-component.adoc    | 51 ++++++++++++++++++++++
 1 file changed, 51 insertions(+)

diff --git 
a/docs/components/modules/ROOT/pages/kubernetes-deployments-component.adoc 
b/docs/components/modules/ROOT/pages/kubernetes-deployments-component.adoc
index 3f71c82..6b5d103 100644
--- a/docs/components/modules/ROOT/pages/kubernetes-deployments-component.adoc
+++ b/docs/components/modules/ROOT/pages/kubernetes-deployments-component.adoc
@@ -120,3 +120,54 @@ The component supports 2 options, which are listed below.
 - deleteDeployment
 - scaleDeployment
 
+== Kubernetes Deployments Producer Examples
+
+- listDeployments: this operation list the deployments on a kubernetes cluster
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:list").
+    
toF("kubernetes-deployments:///?kubernetesClient=#kubernetesClient&operation=listDeployments").
+    to("mock:result");
+--------------------------------------------------------------------------------
+
+This operation return a List of Deployment from your cluster
+
+- listDeploymentsByLabels:  this operation list the deployments by labels on a 
kubernetes cluster
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:listByLabels").process(new Processor() {
+
+            @Override
+            public void process(Exchange exchange) throws Exception {
+                Map<String, String> labels = new HashMap<>();
+                labels.put("key1", "value1");
+                labels.put("key2", "value2");
+                
exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_DEPLOYMENTS_LABELS, 
labels);
+            }
+        });
+    
toF("kubernetes-deployments:///?kubernetesClient=#kubernetesClient&operation=listDeploymentsByLabels").
+    to("mock:result");
+--------------------------------------------------------------------------------
+
+This operation return a List of Deployments from your cluster, using a label 
selector (with key1 and key2, with value value1 and value2)
+
+== Kubernetes Deployments Consumer Example
+
+[source,java]
+--------------------------------------------------------------------------------
+fromF("kubernetes-deployments://%s?oauthToken=%s&namespace=default&resourceName=test",
 host, authToken).process(new KubernertesProcessor()).to("mock:result");
+
+    public class KubernertesProcessor implements Processor {
+        @Override
+        public void process(Exchange exchange) throws Exception {
+            Message in = exchange.getIn();
+            Deployment dp = exchange.getIn().getBody(Deployment.class);
+            log.info("Got event with configmap name: " + 
dp.getMetadata().getName() + " and action " + 
in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+        }
+    }
+--------------------------------------------------------------------------------
+
+This consumer will return a list of events on the namespace default for the 
deployment test.
+

Reply via email to