edgeexporter

README

edge-exporter

Currently, this project is in alpha state

edge-exporter is an opencensus exporter and provides tracing the tail latency span.

Example

package main

import (
  "context"
  "net/http"
  "os"
  "sync/atomic"
  "time"

  "contrib.go.opencensus.io/exporter/stackdriver"
  edgeexporter "github.com/takashabe/edge-exporter"
  "go.opencensus.io/trace"
)

func main() {
  sd, err := stackdriver.NewExporter(stackdriver.Options{
    ProjectID: os.Getenv("PROJECT_ID"),
  })
  if err != nil {
    panic(err)
  }

  edge := edgeexporter.New(edgeexporter.WithExportInterval(10*time.Second))
  edge.RegisterExporter(sd)

  trace.RegisterExporter(edge)
  trace.ApplyConfig(trace.Config{
    DefaultSampler: trace.AlwaysSample(),
  })

  http.HandleFunc("/", handler)

  http.ListenAndServe(":8080", nil)
}

var cnt int64

func handler(w http.ResponseWriter, req *http.Request) {
  _, span := trace.StartSpan(context.Background(), "handler")
  c := atomic.LoadInt64(&cnt)
  if c%5 == 0 {
    time.Sleep(50 * time.Millisecond)
  }
  span.End()
  atomic.AddInt64(&cnt, 1)
}

Documentation

Index

• Constants
• type EdgeExporter
  • func New(opts ...Option) *EdgeExporter
  • func (e *EdgeExporter) ExportSpan(sd *trace.SpanData)
  • func (e *EdgeExporter) RegisterExporter(exp trace.Exporter)
  • func (e *EdgeExporter) UnregisterExporter(exp trace.Exporter)
• type Option
  • func WithExportInterval(t time.Duration) Option

Constants

const DefaultExportInterval = time.Second

Types

type EdgeExporter

type EdgeExporter struct {
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) *EdgeExporter

func (*EdgeExporter) ExportSpan

func (e *EdgeExporter) ExportSpan(sd *trace.SpanData)

func (*EdgeExporter) RegisterExporter

func (e *EdgeExporter) RegisterExporter(exp trace.Exporter)

func (*EdgeExporter) UnregisterExporter

func (e *EdgeExporter) UnregisterExporter(exp trace.Exporter)

type Option

type Option func(*EdgeExporter)

func WithExportInterval

func WithExportInterval(t time.Duration) Option