Go Spanner Client with OpenCensus

main.go

// Copyright 2018 Google Inc. All rights reserved.
// Use of this source code is governed by the Apache 2.0
// license that can be found in the LICENSE file.

// Sample contains a simple program that
// uses Google Spanner Go client, and reports metrics
// and traces for the outgoing requests.
package main

import (
	"log"

	"cloud.google.com/go/spanner"
	ss "go.opencensus.io/exporter/stats/stackdriver"
	ts "go.opencensus.io/exporter/trace/stackdriver"
	"go.opencensus.io/stats"
	"go.opencensus.io/trace"
	"golang.org/x/net/context"
)

func main() {
	ctx := context.Background()

	// Enable OpenCensus exporters to export traces and metrics
	// to Stackdriver Monitoring and Tracing.
	// Exporters use Application Default Credentials to authenticate.
	// See https://developers.google.com/identity/protocols/application-default-credentials
	// for more details.
	statsExporter, err := ss.NewExporter(ss.Options{ProjectID: "your-project-id"})
	if err != nil {
		log.Fatal(err)
	}
	traceExporter, err := ts.NewExporter(ts.Options{ProjectID: "your-project-id"})
	if err != nil {
		log.Fatal(err)
	}
	stats.RegisterExporter(statsExporter)
	trace.RegisterExporter(traceExporter)

	// This database must exist.
	databaseName := "projects/your-project-id/instances/your-instance-id/databases/your-database-id"

	client, err := spanner.NewClient(ctx, databaseName)
	if err != nil {
		log.Fatalf("Failed to create client %v", err)
	}
	defer client.Close()

	_, err = client.Apply(ctx, []*spanner.Mutation{
		spanner.Insert("Users",
			[]string{"name", "email"},
			[]interface{}{"alice", "[email protected]"})})
	if err != nil {
		log.Printf("Failed to insert: %v", err)
	}

	// Make sure data is uploaded before program finishes.
	statsExporter.Flush()
	traceExporter.Flush()
}