Adds unit tests for tracing util

Signed-off-by: Michal Baczun <[email protected]>

Author: Michal Baczun

.github/dependabot.yml

@@ -4,6 +4,8 @@ updates:
     directory: "/"
     schedule:
       interval: "weekly"
+
+updates:
   - package-ecosystem: "gomod"
     directory: "/function-images/tests/chained-function-serving"
     schedule:
@@ -16,5 +18,8 @@ updates:
     directory: "/utils/benchmarking/eventing"
     schedule:
       interval: "weekly"
-
-# Use https://dependabot.com/docs/config-file/validator/ to check for errors.
+updates:
+  - package-ecosystem: "gomod"
+    directory: "/utils/tracing/go"
+    schedule:
+      interval: "weekly"

.github/workflows/unit_tests.yml

@@ -26,7 +26,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        module: [taps, misc, profile]
+        module: [taps, misc, profile, utils/tracing/go]
     steps:
     - name: Set up Go 1.15
       uses: actions/setup-go@v2

CHANGELOG.md

@@ -7,9 +7,10 @@
 - Added [script](./scripts/cloudlab/start_onenode_vhive_cluster.sh) to (re)start vHive single node cluster in a push-button.
 - CRI test logs are now stored as GitHub artifacts.
 - Added Knative Eventing Tutorial: [documentation](./docs/knative/eventing.md) and [example](./examples/knative-eventing-tutorial).
-- Added a chained functions microbenchmark that uses Knative Serving.
+- Added a chained functions microbenchmark that uses Knative Serving with tracing.
 - Added a linter for link checking in markdown files
 - Added documentation for adding benchmarks to vHive.
+- Added a utility for tracing using zipkin.
 
 ### Changed
 

utils/tracing/go/Makefile

@@ -0,0 +1,33 @@
+# MIT License
+#
+# Copyright (c) 2021 Michal Baczun and EASE lab
+#
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the "Software"), to deal
+# in the Software without restriction, including without limitation the rights
+# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+# copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice shall be included in all
+# copies or substantial portions of the Software.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+# SOFTWARE.
+
+EXTRAGOARGS:=-v -race -cover
+
+test:
+	# Need to pass GOROOT because GitHub-hosted runners may have several
+	# go versions installed so that calling go from root may fail
+	sudo env "PATH=$(PATH)" "GOROOT=$(GOROOT)" go test ./ $(EXTRAGOARGS)
+
+test-man:
+	echo "Nothing to test manually"
+
+.PHONY: test test-man

utils/tracing/go/tracing_test.go

@@ -0,0 +1,35 @@
+package tracing
+
+import (
+	"context"
+	"log"
+	"os"
+	"testing"
+	"time"
+
+	"go.opentelemetry.io/otel"
+	"go.opentelemetry.io/otel/attribute"
+)
+
+func TestInitBasicTracer(t *testing.T) {
+	InitBasicTracer("http://localhost:9999", "test-tracer")
+	tracer := otel.GetTracerProvider().Tracer("test-tracer")
+	_, traceSpan := tracer.Start(context.Background(), "test-span")
+	traceSpan.End()
+}
+
+func TestInitCustomTracer(t *testing.T) {
+	logger := log.New(os.Stderr, "tracer-log", log.Ldate|log.Ltime|log.Llongfile)
+	InitCustomTracer("http://localhost:9999", 1.0, logger, attribute.String("service.name", "custom tracer"))
+	tracer := otel.GetTracerProvider().Tracer("test-tracer")
+	_, traceSpan := tracer.Start(context.Background(), "test-span")
+	traceSpan.End()
+}
+
+func TestSpan(t *testing.T) {
+	InitBasicTracer("http://localhost:9999", "test-tracer")
+	span := Span{SpanName: "test-span", TracerName: "test-tracer"}
+	span.StartSpan(context.Background())
+	<-time.After(1 * time.Second)
+	span.EndSpan()
+}