cloud-run button

Author: tam7t

README.md

@@ -25,5 +25,9 @@ ss.AddSample([]string{"method", "const"}, 200)
 
 The [full example](example/main.go) can be run from a cloud shell console to test how metrics are collected and displayed.
 
+You can also try out the example using Cloud Run!
+
+[![Run on Google Cloud](https://storage.googleapis.com/cloudrun/button.svg)](https://console.cloud.google.com/cloudshell/editor?shellonly=true&cloudshell_image=gcr.io/cloudrun/button&cloudshell_git_repo=https://github.com/google/go-metrics-stackdriver.git&cloudshell_working_dir=example)
+
 
 __This is not an officially supported Google product.__

example/Dockerfile

@@ -0,0 +1,14 @@
+FROM golang:1.12 as build
+
+WORKDIR /go/src/app
+ADD . /go/src/app
+
+ENV GOPROXY https://proxy.golang.org
+RUN go get -d -v ./...
+RUN go build -v -o /go/bin/app
+
+# Now copy it into our base image.
+FROM gcr.io/distroless/base
+COPY --from=build /go/bin/app /
+CMD ["/app"]
+

example/main.go

@@ -15,8 +15,10 @@ package main
 
 import (
 	"context"
+	"fmt"
 	"log"
 	"math/rand"
+	"net/http"
 	"os"
 	"os/signal"
 	"time"
@@ -46,13 +48,38 @@ func main() {
 		projectID = os.Getenv("GOOGLE_CLOUD_PROJECT")
 	}
 
-	log.Printf("initializing sink")
+	log.Printf("initializing sink, project_id: %q", projectID)
 
 	// create sink
 	ss := stackdriver.NewSink(client, &stackdriver.Config{
 		ProjectID: projectID,
 		Location:  "us-east1-c",
 	})
+	cfg := metrics.DefaultConfig("go-metrics-stackdriver")
+	cfg.EnableHostname = false
+	metrics.NewGlobal(metrics.DefaultConfig("go-metrics-stackdriver"), ss)
+
+	// start listener
+	log.Printf("starting server")
+	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
+		defer metrics.MeasureSince([]string{"handler"}, time.Now())
+		metrics.IncrCounter([]string{"requests"}, 1.0)
+		fmt.Fprintf(w, "Hello from go-metrics-stackdriver")
+	})
+
+	port := os.Getenv("PORT")
+	if port == "" {
+		port = "8080"
+	}
+
+	srv := http.Server{
+		Addr: ":" + port,
+	}
+	go func() {
+		if err := srv.ListenAndServe(); err != nil {
+			log.Printf("server error: %s", err)
+		}
+	}()
 
 	// capture ctrl+c
 	c := make(chan os.Signal, 1)
@@ -61,6 +88,7 @@ func main() {
 		<-c
 		log.Printf("ctrl+c detected... shutting down")
 		cancel()
+		srv.Shutdown(ctx)
 	}()
 
 	// generate data