initial commit.

Author: jcchavezs

Dockerfile

@@ -0,0 +1,25 @@
+FROM golang:1.15-alpine AS build-stage
+
+RUN apk add --update make
+RUN mkdir -p /go/src/github.com/hypertrace/collector
+WORKDIR /go/src/github.com/hypertrace/collector
+
+COPY . /go/src/github.com/hypertrace/collector
+
+ARG GIT_COMMIT
+ARG VERSION
+
+RUN make build
+
+FROM alpine
+# Following folder conventions described in https://unix.stackexchange.com/a/11552
+RUN apk --update add ca-certificates
+RUN mkdir /usr/local/bin/hypertrace
+WORKDIR /usr/local/bin/hypertrace
+
+COPY --from=build-stage /go/src/github.com/hypertrace/collector/collector .
+COPY default-config.yml /etc/opt/hypertrace/config.yml
+
+EXPOSE 9411
+
+ENTRYPOINT ./collector --config /etc/opt/hypertrace/config.yml

Makefile

@@ -0,0 +1,14 @@
+BIN_NAME=xfiles
+
+VERSION ?= dev
+GIT_HASH ?=$(shell git rev-parse HEAD)
+IMAGE_NAME := "hypertrace/collector"
+
+build:
+	go build -ldflags "-w -X main.GitHash=${GIT_HASH} -X main.Version=${VERSION}" ./cmd/collector
+
+run:
+	go run cmd/collector/main.go --config ./config.yml
+
+package:
+	docker build --build-arg VERSION=${VERSION} --build-arg GIT_COMMIT=$(GIT_COMMIT) -t $(IMAGE_NAME):${VERSION} -t $(IMAGE_NAME):latest .

cmd/collector/main.go

@@ -0,0 +1,53 @@
+package main
+
+import (
+	"fmt"
+	"log"
+
+	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/component/componenterror"
+	"go.opentelemetry.io/collector/service"
+	"go.opentelemetry.io/collector/service/defaultcomponents"
+)
+
+func main() {
+	factories, err := components()
+	if err != nil {
+		log.Fatalf("failed to build default components: %v", err)
+	}
+
+	info := component.ApplicationStartInfo{
+		ExeName:  "collector",
+		LongName: "Hypertrace Collector",
+		Version:  Version,
+		GitHash:  GitHash,
+	}
+
+	if err := run(service.Parameters{ApplicationStartInfo: info, Factories: factories}); err != nil {
+		log.Fatal(err)
+	}
+}
+
+func components() (component.Factories, error) {
+	var errs []error
+	factories, err := defaultcomponents.Components()
+	if err != nil {
+		return component.Factories{}, err
+	}
+
+	return factories, componenterror.CombineErrors(errs)
+}
+
+func run(params service.Parameters) error {
+	app, err := service.New(params)
+	if err != nil {
+		return fmt.Errorf("failed to construct the application: %w", err)
+	}
+
+	err = app.Run()
+	if err != nil {
+		return fmt.Errorf("application run finished with error: %w", err)
+	}
+
+	return nil
+}

cmd/collector/version.go

@@ -0,0 +1,8 @@
+package main
+
+// GitHash that was compiled. This will be filled in by the compiler.
+// Version number that is being run at the moment.
+var (
+	GitHash string
+	Version string
+)

default-config.yml

@@ -0,0 +1,53 @@
+extensions:
+  health_check:
+  pprof:
+    endpoint: 0.0.0.0:1777
+  zpages:
+    endpoint: 0.0.0.0:55679
+
+receivers:
+  otlp:
+    protocols:
+      grpc:
+      http:
+
+  opencensus:
+
+  # Collect own metrics
+  prometheus:
+    config:
+      scrape_configs:
+        - job_name: "otel-collector"
+          scrape_interval: 10s
+          static_configs:
+            - targets: ["0.0.0.0:8888"]
+
+  jaeger:
+    protocols:
+      grpc:
+      thrift_binary:
+      thrift_compact:
+      thrift_http:
+
+  zipkin:
+
+processors:
+  batch:
+
+exporters:
+  logging:
+    logLevel: debug
+
+service:
+  pipelines:
+    traces:
+      receivers: [otlp, opencensus, jaeger, zipkin]
+      processors: [batch]
+      exporters: [logging]
+
+    metrics:
+      receivers: [otlp, opencensus, prometheus]
+      processors: [batch]
+      exporters: [logging]
+
+  extensions: [health_check, pprof, zpages]

go.mod

@@ -0,0 +1,5 @@
+module github.com/hypertrace/collector
+
+go 1.15
+
+require go.opentelemetry.io/collector v0.14.0