qbit/go
1
0
Fork 0
mirror of https://github.com/golang/go synced 2024-11-18 16:34:51 -07:00
Code Releases Activity

internal/telemetry: move the benchmarks to the main package

Browse Source 
Change-Id: I9aabed798951ffba775c2255c8baafd56b009636
Reviewed-on: https://go-review.googlesource.com/c/tools/+/221738
Run-TryBot: Ian Cottrell <iancottrell@google.com>
TryBot-Result: Gobot Gobot <gobot@golang.org>
Reviewed-by: Robert Findley <rfindley@google.com>
Reviewed-by: Emmanuel Odeke <emm.odeke@gmail.com>
This commit is contained in:
Ian Cottrell 2020-03-01 18:39:15 -05:00
parent 046aa1cdaf
commit 3e346efd93
1 changed files with 48 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
internal/telemetry/log/bench_test.go → internal/telemetry/bench_test.go
View File

@ -1,4 +1,4 @@
package log_test
package telemetry_test
import (
"context"
@ -6,9 +6,11 @@ import (
"strings"
"testing"
"golang.org/x/tools/internal/telemetry"
"golang.org/x/tools/internal/telemetry/export"
tellog "golang.org/x/tools/internal/telemetry/log"
"golang.org/x/tools/internal/telemetry/tag"
teltrace "golang.org/x/tools/internal/telemetry/trace"
)
func init() {
@ -55,6 +57,24 @@ func B_log(ctx context.Context, b string) int {
return len(b)
}
func A_trace(ctx context.Context, a int) int {
ctx, done := teltrace.StartSpan(ctx, "A")
defer done()
if a > 0 {
_ = 10 * 12
}
return B_trace(ctx, "Called from A")
}
func B_trace(ctx context.Context, b string) int {
ctx, done := teltrace.StartSpan(ctx, "B")
defer done()
b = strings.ToUpper(b)
if len(b) > 1024 {
b = strings.ToLower(b)
}
return len(b)
}
func A_log_stdlib(ctx context.Context, a int) int {
if a > 0 {
stdlog.Printf("a > 0 where a=%d", a)
@ -76,6 +96,32 @@ func B_log_stdlib(ctx context.Context, b string) int {
var values = []int{0, 10, 20, 100, 1000}
type loggingExporter struct {
logger export.Exporter
}
func newExporter() *loggingExporter {
return &loggingExporter{
logger: export.LogWriter(new(noopWriter), false),
}
}
func (e *loggingExporter) ProcessEvent(ctx context.Context, event telemetry.Event) context.Context {
return e.logger.ProcessEvent(ctx, event)
}
func (e *loggingExporter) Metric(ctx context.Context, data telemetry.MetricData) {
e.logger.Metric(ctx, data)
}
func (e *loggingExporter) StartSpan(ctx context.Context, span *telemetry.Span) {
e.logger.StartSpan(ctx, span)
}
func (e *loggingExporter) FinishSpan(ctx context.Context, span *telemetry.Span) {
e.logger.FinishSpan(ctx, span)
}
func BenchmarkBaseline(b *testing.B) {
ctx := context.Background()
b.ReportAllocs()
@ -105,7 +151,7 @@ func BenchmarkLoggingNoExporter(b *testing.B) {
func BenchmarkLogging(b *testing.B) {
ctx := context.Background()
export.SetExporter(export.LogWriter(new(noopWriter), false))
export.SetExporter(newExporter())
b.ReportAllocs()
b.ResetTimer()
for i := 0; i < b.N; i++ {