First working implementation with elastic apm

Author: DaGeRe

.gitignore

@@ -19,6 +19,9 @@
 compile-results/
 frameworks/Kieker-python/kieker-lang-pack-python/
 
+# Do not store agents
+frameworks/elasticapm-java/elastic-apm-agent.jar
+
 # Do not store measurement results
 frameworks/OpenTelemetry-java/raw*
 frameworks/OpenTelemetry-java/results-OpenTelemetry-java/
@@ -28,3 +31,4 @@ frameworks/Kieker-java/raw*
 frameworks/Kieker-java/results-Kieker-java/
 frameworks/Kieker-python/raw*
 frameworks/Kieker-python/results-Kieker-python/
+frameworks/elasticapm-java/results-elasticapm-java/

frameworks/elasticapm-java/benchmark.sh

@@ -56,8 +56,8 @@ fi
 
 if [ -z "$MOOBENCH_CONFIGURATIONS" ]
 then
-	MOOBENCH_CONFIGURATIONS="0 1 2 4 5"
-	echo "Setting default configuration $MOOBENCH_CONFIGURATIONS (without TextLogStreamHandler)"
+	MOOBENCH_CONFIGURATIONS="0 1 2 3"
+	echo "Setting default configuration $MOOBENCH_CONFIGURATIONS"
 fi
 echo "Running configurations: $MOOBENCH_CONFIGURATIONS"
 
@@ -72,7 +72,10 @@ info "----------------------------------"
 cd "${BASE_DIR}"
 
 # load agent
-getAgent
+if [ ! -f $AGENT ]
+then
+	getAgent
+fi
 
 checkDirectory data-dir "${DATA_DIR}" create
 checkFile log "${DATA_DIR}/kieker.log" clean
@@ -97,8 +100,6 @@ JAVA_ARGS="-Xms1G -Xmx2G"
 
 LTW_ARGS="-javaagent:elastic-apm-agent.jar"
 
-KIEKER_ARGS="-Dlog4j.configuration=log4j.cfg -Dkieker.monitoring.name=KIEKER-BENCHMARK -Dkieker.monitoring.adaptiveMonitoring.enabled=false -Dkieker.monitoring.periodicSensorsExecutorPoolSize=0"
-
 # JAVA_ARGS used to configure and setup a specific writer
 declare -a WRITER_CONFIG
 # Receiver setup if necessary
@@ -109,9 +110,12 @@ declare -a TITLE
 #
 # Different writer setups
 #
-WRITER_CONFIG[0]=""
-WRITER_CONFIG[1]="-Delastic.apm.service_name=moobench-benchmark -Delastic.apm.application_packages=moobench.application -Delastic.apm.server_url=http://127.0.0.1:8200"
 
+ELASTIC_ARGS="-Delastic.apm.service_name=moobench-benchmark -Delastic.apm.service_name=moobench-benchmark -Delastic.apm.trace_methods=moobench.application.* -Delastic.apm.application_packages=moobench.application -Delastic.apm.server_url=http://127.0.0.1:8200"
+WRITER_CONFIG[0]=""
+WRITER_CONFIG[1]="-Delastic.apm.recording=false $ELASTIC_ARGS"
+WRITER_CONFIG[2]="$ELASTIC_ARGS"
+WRITER_CONFIG[3]="-Delastic.apm.sanitize_field_names= $ELASTIC_ARGS"
 
 
 writeConfiguration

frameworks/elasticapm-java/docker-compose.yaml

@@ -0,0 +1,23 @@
+services:
+    search:
+        image: elasticsearch:8.16.1
+        environment:
+            - cluster.name=es1
+            - discovery.type=single-node
+            - xpack.security.enabled=false
+            - ES_JAVA_OPTS=-Xms1g -Xmx1g
+        ports:
+            - 9200:9200
+            - 9300:9300
+    kibana:
+        image: kibana:8.16.1
+        environment:
+            - ELASTICSEARCH_HOSTS=http://search:9200
+            - ELASTIC_APM_SERVER_URL=http://telemetry:8200
+        ports:
+            - 5601:5601
+    telemetry:
+        image: elastic/apm-server:7.17.25
+        command: apm-server -e -E output.elasticsearch.hosts=http://search:9200
+        ports:
+            - 8200:8200

frameworks/elasticapm-java/functions.sh

@@ -51,7 +51,7 @@ function executeExperiment() {
         --total-calls "${TOTAL_NUM_OF_CALLS}" \
         --method-time "${METHOD_TIME}" \
         --total-threads $THREADS \
-        --recursion-depth "${recursion}"
+        --recursion-depth "${recursion}" &> "${LOG_FILE}"
 
     if [ ! -f "${RESULT_FILE}" ] ; then
         info "---------------------------------------------------"
@@ -99,7 +99,14 @@ function executeBenchmark() {
 
     for index in $MOOBENCH_CONFIGURATIONS
     do
-      executeBenchmarkBody $index $i $recursion
+      if (( $index > 0 ))
+      then
+        docker compose up -d
+        executeBenchmarkBody $index $i $recursion
+        docker compose down
+      else
+        executeBenchmarkBody $index $i $recursion
+      fi
     done
 }
 

frameworks/elasticapm-java/labels.sh

@@ -1,6 +1,4 @@
 TITLE[0]="No instrumentation"
 TITLE[1]="Deactivated probe"
-TITLE[2]="No logging"
-TITLE[3]="Text file"
-TITLE[4]="Binary file"
-TITLE[5]="Binary TCP"
+TITLE[2]="Regular Writing"
+TITLE[3]="Writing without sanitizing fields"