Function TestSpanClassifier

modules/sentry/storage_test.go:363–418

(t *testing.T)

}

func TestSpanClassifier(t *testing.T) {
	tests := []struct {
		name         string
		span         RawSpan
		wantType     string
		wantAddress  string
	}{
		{
			name:        "db.query",
			span:        RawSpan{Op: "db.query", Data: map[string]string{"server.address": "db.host.com"}},
			wantType:    "db",
			wantAddress: "db.host.com",
		},
		{
			name:        "db with db.name fallback",
			span:        RawSpan{Op: "db.redis", Data: map[string]string{"db.name": "cache-0"}},
			wantType:    "db",
			wantAddress: "cache-0",
		},
		{
			name:        "http.client",
			span:        RawSpan{Op: "http.client", Data: map[string]string{"http.url": "https://api.example.com:8080/path"}},
			wantType:    "http",
			wantAddress: "api.example.com:8080",
		},
		{
			name:        "cache.get",
			span:        RawSpan{Op: "cache.get", Data: map[string]string{"server.address": "redis.local"}},
			wantType:    "cache",
			wantAddress: "redis.local",
		},
		{
			name:        "queue.publish",
			span:        RawSpan{Op: "queue.publish", Data: map[string]string{"messaging.destination": "orders-queue"}},
			wantType:    "queue",
			wantAddress: "orders-queue",
		},
		{
			name:     "unknown op",
			span:     RawSpan{Op: "custom.op"},
			wantType: "unknown",
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			peerType, peerAddress := classifySpan(tt.span)
			if peerType != tt.wantType {
				t.Errorf("peerType = %q, want %q", peerType, tt.wantType)
			}
			if peerAddress != tt.wantAddress {
				t.Errorf("peerAddress = %q, want %q", peerAddress, tt.wantAddress)
			}
		})
	}
}

func TestEnvelopeParser(t *testing.T) {