+++ /dev/null
-// Copyright 2019 The Go Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style
-// license that can be found in the LICENSE file.
-
-package ocagent_test
-
-import (
- "bytes"
- "context"
- "encoding/json"
- "fmt"
- "io/ioutil"
- "net/http"
- "sync"
- "testing"
- "time"
-
- "golang.org/x/tools/internal/event"
- "golang.org/x/tools/internal/event/core"
- "golang.org/x/tools/internal/event/export"
- "golang.org/x/tools/internal/event/export/metric"
- "golang.org/x/tools/internal/event/export/ocagent"
- "golang.org/x/tools/internal/event/keys"
- "golang.org/x/tools/internal/event/label"
-)
-
-const testNodeStr = `{
- "node":{
- "identifier":{
- "host_name":"tester",
- "pid":1,
- "start_timestamp":"1970-01-01T00:00:00Z"
- },
- "library_info":{
- "language":4,
- "exporter_version":"0.0.1",
- "core_library_version":"x/tools"
- },
- "service_info":{
- "name":"ocagent-tests"
- }
- },`
-
-var (
- keyDB = keys.NewString("db", "the database name")
- keyMethod = keys.NewString("method", "a metric grouping key")
- keyRoute = keys.NewString("route", "another metric grouping key")
-
- key1DB = keys.NewString("1_db", "A test string key")
-
- key2aAge = keys.NewFloat64("2a_age", "A test float64 key")
- key2bTTL = keys.NewFloat32("2b_ttl", "A test float32 key")
- key2cExpiryMS = keys.NewFloat64("2c_expiry_ms", "A test float64 key")
-
- key3aRetry = keys.NewBoolean("3a_retry", "A test boolean key")
- key3bStale = keys.NewBoolean("3b_stale", "Another test boolean key")
-
- key4aMax = keys.NewInt("4a_max", "A test int key")
- key4bOpcode = keys.NewInt8("4b_opcode", "A test int8 key")
- key4cBase = keys.NewInt16("4c_base", "A test int16 key")
- key4eChecksum = keys.NewInt32("4e_checksum", "A test int32 key")
- key4fMode = keys.NewInt64("4f_mode", "A test int64 key")
-
- key5aMin = keys.NewUInt("5a_min", "A test uint key")
- key5bMix = keys.NewUInt8("5b_mix", "A test uint8 key")
- key5cPort = keys.NewUInt16("5c_port", "A test uint16 key")
- key5dMinHops = keys.NewUInt32("5d_min_hops", "A test uint32 key")
- key5eMaxHops = keys.NewUInt64("5e_max_hops", "A test uint64 key")
-
- recursiveCalls = keys.NewInt64("recursive_calls", "Number of recursive calls")
- bytesIn = keys.NewInt64("bytes_in", "Number of bytes in") //, unit.Bytes)
- latencyMs = keys.NewFloat64("latency", "The latency in milliseconds") //, unit.Milliseconds)
-
- metricLatency = metric.HistogramFloat64{
- Name: "latency_ms",
- Description: "The latency of calls in milliseconds",
- Keys: []label.Key{keyMethod, keyRoute},
- Buckets: []float64{0, 5, 10, 25, 50},
- }
-
- metricBytesIn = metric.HistogramInt64{
- Name: "latency_ms",
- Description: "The latency of calls in milliseconds",
- Keys: []label.Key{keyMethod, keyRoute},
- Buckets: []int64{0, 10, 50, 100, 500, 1000, 2000},
- }
-
- metricRecursiveCalls = metric.Scalar{
- Name: "latency_ms",
- Description: "The latency of calls in milliseconds",
- Keys: []label.Key{keyMethod, keyRoute},
- }
-)
-
-type testExporter struct {
- ocagent *ocagent.Exporter
- sent fakeSender
-}
-
-func registerExporter() *testExporter {
- exporter := &testExporter{}
- cfg := ocagent.Config{
- Host: "tester",
- Process: 1,
- Service: "ocagent-tests",
- Client: &http.Client{Transport: &exporter.sent},
- }
- cfg.Start, _ = time.Parse(time.RFC3339Nano, "1970-01-01T00:00:00Z")
- exporter.ocagent = ocagent.Connect(&cfg)
-
- metrics := metric.Config{}
- metricLatency.Record(&metrics, latencyMs)
- metricBytesIn.Record(&metrics, bytesIn)
- metricRecursiveCalls.SumInt64(&metrics, recursiveCalls)
-
- e := exporter.ocagent.ProcessEvent
- e = metrics.Exporter(e)
- e = spanFixer(e)
- e = export.Spans(e)
- e = export.Labels(e)
- e = timeFixer(e)
- event.SetExporter(e)
- return exporter
-}
-
-func timeFixer(output event.Exporter) event.Exporter {
- start, _ := time.Parse(time.RFC3339Nano, "1970-01-01T00:00:30Z")
- at, _ := time.Parse(time.RFC3339Nano, "1970-01-01T00:00:40Z")
- end, _ := time.Parse(time.RFC3339Nano, "1970-01-01T00:00:50Z")
- return func(ctx context.Context, ev core.Event, lm label.Map) context.Context {
- switch {
- case event.IsStart(ev):
- ev = core.CloneEvent(ev, start)
- case event.IsEnd(ev):
- ev = core.CloneEvent(ev, end)
- default:
- ev = core.CloneEvent(ev, at)
- }
- return output(ctx, ev, lm)
- }
-}
-
-func spanFixer(output event.Exporter) event.Exporter {
- return func(ctx context.Context, ev core.Event, lm label.Map) context.Context {
- if event.IsStart(ev) {
- span := export.GetSpan(ctx)
- span.ID = export.SpanContext{}
- }
- return output(ctx, ev, lm)
- }
-}
-
-func (e *testExporter) Output(route string) []byte {
- e.ocagent.Flush()
- return e.sent.get(route)
-}
-
-func checkJSON(t *testing.T, got, want []byte) {
- // compare the compact form, to allow for formatting differences
- g := &bytes.Buffer{}
- if err := json.Compact(g, got); err != nil {
- t.Fatal(err)
- }
- w := &bytes.Buffer{}
- if err := json.Compact(w, want); err != nil {
- t.Fatal(err)
- }
- if g.String() != w.String() {
- t.Fatalf("Got:\n%s\nWant:\n%s", g, w)
- }
-}
-
-type fakeSender struct {
- mu sync.Mutex
- data map[string][]byte
-}
-
-func (s *fakeSender) get(route string) []byte {
- s.mu.Lock()
- defer s.mu.Unlock()
- data, found := s.data[route]
- if found {
- delete(s.data, route)
- }
- return data
-}
-
-func (s *fakeSender) RoundTrip(req *http.Request) (*http.Response, error) {
- s.mu.Lock()
- defer s.mu.Unlock()
- if s.data == nil {
- s.data = make(map[string][]byte)
- }
- data, err := ioutil.ReadAll(req.Body)
- if err != nil {
- return nil, err
- }
- path := req.URL.EscapedPath()
- if _, found := s.data[path]; found {
- return nil, fmt.Errorf("duplicate delivery to %v", path)
- }
- s.data[path] = data
- return &http.Response{
- Status: "200 OK",
- StatusCode: 200,
- Proto: "HTTP/1.0",
- ProtoMajor: 1,
- ProtoMinor: 0,
- }, nil
-}
projects / dotfiles / .git / blobdiff