Added the jaeger-collector service which will save traces in Elasticsearch.

Author: Uzziah Eyee

docker-compose.dev.yml

@@ -46,6 +46,23 @@ services:
     env_file: log-shipper/.env
 
 
+  jaeger-collector:
+    build: jaeger-collector
+    environment:
+      # more options: https://www.jaegertracing.io/docs/1.11/deployment/#all-options-1
+      SPAN_STORAGE_TYPE: elasticsearch
+      ES_SERVER_URLS: http://elasticsearch:9200
+    restart: on-failure
+    # todo: eliminate duplication of health-check url in 'command'
+    command: wait.sh http://elasticsearch:9200 5 20 "jaeger-collector"
+    ports:
+      - "14269:14269" # healthcheck
+      - "14250:14250" # for receiving spans via grpc
+    networks:
+      - aparnet
+    depends_on:
+      - elasticsearch
+
   jaeger-query:
     build: jaeger-query
     environment:

jaeger-collector/Dockerfile

@@ -0,0 +1,8 @@
+FROM alpine:3.9.3
+
+# required by wait script
+RUN apk add --no-cache bash curl
+
+COPY jaeger-collector wait.sh /usr/local/bin/
+
+RUN chmod +x /usr/local/bin/wait.sh

jaeger-collector/jaeger-collector

@@ -0,0 +1,36 @@
+#!/bin/bash
+
+# Requires a container with Bash and Curl installed.
+
+is_healthy () {
+	retryInterval=${2:-5}
+	maxAttempts=${3:-1000000}
+
+	i=0
+	while [ $i -lt $maxAttempts ]
+	do
+		status=$(curl -s -L -o /dev/null -w %{http_code} $1)
+
+		# stop trying if we get a success response
+		if [ $status -ge 200 ] && [ $status -lt 300 ]
+		then
+			return 0
+		fi
+		
+		((i++))
+		echo "Attempt $i of $maxAttempts: Endpoint $1 returned code $status. Retrying in $retryInterval seconds."
+		sleep $retryInterval
+	done
+
+	return 1
+}
+
+# args: endpoint, retryInterval (secs), maxAttempts, command
+if is_healthy $1 $2 $3
+then
+	echo "Running command: $4"
+	# vulnerable to input-injection attacts (but I don't care :)
+	eval "$4"
+else
+	echo "Exiting: Cannot run command because health-check failed."
+fi