camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [camel] 02/02: Regen docs
Date Mon, 23 Sep 2019 08:24:46 GMT
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 4a26e41ea6976ad8476e02beaaada252656a6a0b
Author: Andrea Cosentino <ancosen@gmail.com>
AuthorDate: Mon Sep 23 10:24:04 2019 +0200

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

diff --git a/docs/components/modules/ROOT/pages/kubernetes-namespaces-component.adoc b/docs/components/modules/ROOT/pages/kubernetes-namespaces-component.adoc
index e31a4a6..8f11531 100644
--- a/docs/components/modules/ROOT/pages/kubernetes-namespaces-component.adoc
+++ b/docs/components/modules/ROOT/pages/kubernetes-namespaces-component.adoc
@@ -120,3 +120,55 @@ The component supports 2 options, which are listed below.
 - createNamespace
 - deleteNamespace
 
+== Kubernetes Namespaces Producer Examples
+
+- listNamespaces: this operation list the namespaces on a kubernetes cluster
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:list").
+    toF("kubernetes-deployments:///?kubernetesClient=#kubernetesClient&operation=listNamespaces").
+    to("mock:result");
+--------------------------------------------------------------------------------
+
+This operation return a List of namespaces from your cluster
+
+- listNamespacesByLabels:  this operation list the namespaces 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_NAMESPACES_LABELS,
labels);
+            }
+        });
+    toF("kubernetes-deployments:///?kubernetesClient=#kubernetesClient&operation=listNamespacesByLabels").
+    to("mock:result");
+--------------------------------------------------------------------------------
+
+This operation return a List of Namespaces from your cluster, using a label selector (with
key1 and key2, with value value1 and value2)
+
+== Kubernetes Namespaces Consumer Example
+
+[source,java]
+--------------------------------------------------------------------------------
+fromF("kubernetes-namespaces://%s?oauthToken=%s&namespace=default", 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();
+            Namespace ns = exchange.getIn().getBody(Namespace.class);
+            log.info("Got event with configmap name: " + ns.getMetadata().getName() + " and
action " + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+        }
+    }
+--------------------------------------------------------------------------------
+
+This consumer will return a list of events on the namespace default.
+
+


Mime
View raw message