Source file src/github.com/go-kit/kit/tracing/opencensus/opencensus_test.go

Documentation: github.com/go-kit/kit/tracing/opencensus

     1  package opencensus_test
     2  
     3  import (
     4  	"sync"
     5  
     6  	"go.opencensus.io/trace"
     7  )
     8  
     9  type recordingExporter struct {
    10  	mu   sync.Mutex
    11  	data []*trace.SpanData
    12  }
    13  
    14  func (e *recordingExporter) ExportSpan(d *trace.SpanData) {
    15  	e.mu.Lock()
    16  	defer e.mu.Unlock()
    17  
    18  	e.data = append(e.data, d)
    19  }
    20  
    21  func (e *recordingExporter) Flush() (data []*trace.SpanData) {
    22  	e.mu.Lock()
    23  	defer e.mu.Unlock()
    24  
    25  	data = e.data
    26  	e.data = nil
    27  	return
    28  }
    29  

View as plain text