Merge pull request #7875 from satnam6502/elasticsearch

examples/elasticsearch/Dockerfile

+FROM java:7-jre
+
+RUN apt-get update && \
+    apt-get install -y curl && \
+    apt-get clean
+
+RUN cd / && \
+    curl -O https://download.elastic.co/elasticsearch/elasticsearch/elasticsearch-1.5.2.tar.gz && \
+    tar xf elasticsearch-1.5.2.tar.gz && \
+    rm elasticsearch-1.5.2.tar.gz
+
+COPY elasticsearch.yml /elasticsearch-1.5.2/config/elasticsearch.yml
+COPY run.sh /
+COPY elasticsearch_discovery /
+
+EXPOSE 9200 9300
+
+CMD ["/run.sh"]
\ No newline at end of file

examples/elasticsearch/Makefile

+.PHONY: elasticsearch_discovery build push all
+
+TAG = 1.0
+
+build:
+	docker build -t kubernetes/elasticsearch:$(TAG) .
+
+push:
+	docker push kubernetes/elasticsearch:$(TAG)
+
+elasticsearch_discovery:	
+	go build elasticsearch_discovery.go
+
+all:	elasticsearch_discovery build push 

examples/elasticsearch/apiserver-secret.yaml

+apiVersion: v1beta3
+kind: Secret
+metadata:
+  name: apiserver-secret
+  namespace: NAMESPACE
+data:
+  token: "TOKEN"
+

examples/elasticsearch/elasticsearch_discovery.go

+/*
+Copyright 2015 The Kubernetes Authors All rights reserved.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package main
+
+import (
+	"flag"
+	"fmt"
+	"os"
+	"strings"
+	"time"
+
+	"github.com/GoogleCloudPlatform/kubernetes/pkg/api"
+	"github.com/GoogleCloudPlatform/kubernetes/pkg/client"
+	"github.com/GoogleCloudPlatform/kubernetes/pkg/fields"
+	"github.com/GoogleCloudPlatform/kubernetes/pkg/labels"
+	"github.com/golang/glog"
+)
+
+var (
+	token     = flag.String("token", "", "Bearer token for authentication to the API server.")
+	server    = flag.String("server", "", "The address and port of the Kubernetes API server")
+	namespace = flag.String("namespace", api.NamespaceDefault, "The namespace containing Elasticsearch pods")
+	selector  = flag.String("selector", "", "Selector (label query) for selecting Elasticsearch pods")
+)
+
+func main() {
+	flag.Parse()
+	glog.Info("Elasticsearch discovery")
+	apiServer := *server
+	if apiServer == "" {
+		kubernetesService := os.Getenv("KUBERNETES_SERVICE_HOST")
+		if kubernetesService == "" {
+			glog.Fatalf("Please specify the Kubernetes server with --server")
+		}
+		apiServer = fmt.Sprintf("https://%s:%s", kubernetesService, os.Getenv("KUBERNETES_SERVICE_PORT"))
+	}
+
+	glog.Infof("Server: %s", apiServer)
+	glog.Infof("Namespace: %q", *namespace)
+	glog.Infof("selector: %q", *selector)
+
+	config := client.Config{
+		Host:        apiServer,
+		BearerToken: *token,
+		Insecure:    true,
+	}
+
+	c, err := client.New(&config)
+	if err != nil {
+		glog.Fatalf("Failed to make client: %v", err)
+	}
+
+	l, err := labels.Parse(*selector)
+	if err != nil {
+		glog.Fatalf("Failed to parse selector %q: %v", *selector, err)
+	}
+	pods, err := c.Pods(*namespace).List(l, fields.Everything())
+	if err != nil {
+		glog.Fatalf("Failed to list pods: %v", err)
+	}
+
+	glog.Infof("Elasticsearch pods in namespace %s with selector %q", *namespace, *selector)
+	podIPs := []string{}
+	for i := range pods.Items {
+		p := &pods.Items[i]
+		for attempt := 0; attempt < 10; attempt++ {
+			glog.Infof("%d: %s PodIP: %s", i, p.Name, p.Status.PodIP)
+			if p.Status.PodIP != "" {
+				podIPs = append(podIPs, fmt.Sprintf(`"%s"`, p.Status.PodIP))
+				break
+			}
+			time.Sleep(1 * time.Second)
+			p, err = c.Pods(*namespace).Get(p.Name)
+			if err != nil {
+				glog.Warningf("Failed to get pod %s: %v", p.Name, err)
+			}
+		}
+		if p.Status.PodIP == "" {
+			glog.Warningf("Failed to obtain PodIP for %s", p.Name)
+		}
+	}
+	fmt.Printf("discovery.zen.ping.unicast.hosts: [%s]\n", strings.Join(podIPs, ", "))
+}

examples/elasticsearch/music-rc.yaml

+apiVersion: v1beta3
+kind: ReplicationController
+metadata:
+  labels:
+    name: music-db
+    namespace: mytunes
+  name: music-db
+spec:
+  replicas: 4
+  selector:
+    name: music-db
+  template:
+    metadata:
+      labels:
+         name: music-db
+    spec:
+      containers:
+      - name: es
+        image: kubernetes/elasticsearch:1.0
+        env:
+          - name: "CLUSTER_NAME"
+            value: "mytunes-db"
+          - name: "SELECTOR"
+            value: "name=music-db"
+          - name: "NAMESPACE"
+            value: "mytunes"
+        ports:
+        - name: es
+          containerPort: 9200
+        - name: es-transport
+          containerPort: 9300
+        volumeMounts:
+        - name: apiserver-secret
+          mountPath: /etc/apiserver-secret
+          readOnly: true
+      volumes:
+      - name: apiserver-secret
+        secret:
+          secretName: apiserver-secret

examples/elasticsearch/music-service.yaml

+apiVersion: v1beta3
+kind: Service
+metadata:
+  name: music-server
+  namespace: mytunes
+  labels:
+    name: music-db
+spec:
+  selector:
+    name: music-db
+  ports:
+  - name: db
+    port: 9200
+    targetPort: es
+  createExternalLoadBalancer: true

examples/elasticsearch/run.sh

+#!/bin/bash
+
+# Copyright 2015 The Kubernetes Authors All rights reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+export CLUSTER_NAME=${CLUSTER_NAME:-elasticsearch-default}
+export NODE_MASTER=${NODE_MASTER:-true}
+export NODE_DATA=${NODE_DATA:-true}
+export MULTICAST=${MULTICAST:-false}
+readonly TOKEN=$(cat /etc/apiserver-secret/token)
+/elasticsearch_discovery --namespace="${NAMESPACE}" --token="${TOKEN}" --selector="${SELECTOR}" >> /elasticsearch-1.5.2/config/elasticsearch.yml
+export HTTP_PORT=${HTTP_PORT:-9200}
+export TRANSPORT_PORT=${TRANSPORT_PORT:-9300}
+/elasticsearch-1.5.2/bin/elasticsearch