mirror of
https://github.com/hanzoai/krakend-otel.git
synced 2026-09-30 22:49:38 +00:00
Daniel OrtizGitHubdeepsource-autofix[bot] <62050782+deepsource-autofix[bot]@users.noreply.github.com>David Hontecillas* Fix io tests. Signed-off-by: Daniel Ortiz <[email protected]> * Fix failing tests. Signed-off-by: Daniel Ortiz <[email protected]> * style: format code with Go fmt and Gofumpt This commit fixes the style issues introduced in 6b81253 according to the output from Go fmt and Gofumpt. Details: https://github.com/krakend/krakend-otel/pull/12 * Fix unused method receiver and unused parameter in tests. Signed-off-by: Daniel Ortiz <[email protected]> * Remove receiver name from test struct. Signed-off-by: Daniel Ortiz <[email protected]> * fix makefile * add workflow to run tests * fix main branch in workflow * add missing go.sum and update to latest lura --------- Signed-off-by: Daniel Ortiz <[email protected]> Co-authored-by: deepsource-autofix[bot] <62050782+deepsource-autofix[bot]@users.noreply.github.com> Co-authored-by: David Hontecillas <[email protected]>
132 lines
3.0 KiB
Go
132 lines
3.0 KiB
Go
package kotel
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
lconfig "github.com/luraproject/lura/v2/config"
|
|
"github.com/luraproject/lura/v2/logging"
|
|
)
|
|
|
|
func TestGlobalConfig(t *testing.T) {
|
|
cfg := lconfig.ServiceConfig{
|
|
ExtraConfig: map[string]interface{}{
|
|
"telemetry/otel": map[string]interface{}{
|
|
"sample_rate": 2,
|
|
"reporting_period": 4,
|
|
"enabled_layers": map[string]interface{}{
|
|
"router": true,
|
|
"proxy": true,
|
|
"backend": true,
|
|
},
|
|
"exporters": map[string]interface{}{},
|
|
},
|
|
},
|
|
}
|
|
|
|
shuftdownFn, err := Register(context.Background(), logging.NoOp, cfg)
|
|
if err != nil {
|
|
t.Errorf("unexpected error %s", err.Error())
|
|
}
|
|
shuftdownFn()
|
|
}
|
|
|
|
/*
|
|
func TestGetAggregatedPathForMetrics(t *testing.T) {
|
|
for i, tc := range []struct {
|
|
cfg *config.EndpointConfig
|
|
expected string
|
|
}{
|
|
{
|
|
cfg: &config.EndpointConfig{Endpoint: "/api/:foo/:bar"},
|
|
expected: "/api/{foo}/{bar}",
|
|
},
|
|
{
|
|
cfg: &config.EndpointConfig{
|
|
Endpoint: "/api/:foo/:bar",
|
|
ExtraConfig: config.ExtraConfig{
|
|
Namespace: map[string]interface{}{"path_aggregation": "pattern"},
|
|
},
|
|
},
|
|
expected: "/api/{foo}/{bar}",
|
|
},
|
|
{
|
|
cfg: &config.EndpointConfig{
|
|
Endpoint: "/api/:foo/:bar",
|
|
ExtraConfig: config.ExtraConfig{
|
|
Namespace: map[string]interface{}{"path_aggregation": "lastparam"},
|
|
},
|
|
},
|
|
expected: "/api/foo/{bar}",
|
|
},
|
|
{
|
|
cfg: &config.EndpointConfig{
|
|
Endpoint: "/api/:foo/:bar",
|
|
ExtraConfig: config.ExtraConfig{
|
|
Namespace: map[string]interface{}{"path_aggregation": "off"},
|
|
},
|
|
},
|
|
expected: "/api/foo/bar",
|
|
},
|
|
{
|
|
expected: "/api/foo/bar",
|
|
},
|
|
} {
|
|
extractor := GetAggregatedPathForMetrics(tc.cfg)
|
|
r, _ := http.NewRequest("GET", "http://example.tld/api/foo/bar", nil)
|
|
if tag := extractor(r); tag != tc.expected {
|
|
t.Errorf("tc-%d: unexpected result: %s", i, tag)
|
|
}
|
|
}
|
|
}
|
|
|
|
func TestGetAggregatedPathForBackendMetrics(t *testing.T) {
|
|
for i, tc := range []struct {
|
|
cfg *config.Backend
|
|
expected string
|
|
}{
|
|
{
|
|
cfg: &config.Backend{URLPattern: "/api/{{.Foo}}/{{.Bar}}"},
|
|
expected: "/api/{foo}/{bar}",
|
|
},
|
|
{
|
|
cfg: &config.Backend{
|
|
URLPattern: "/api/{{.Foo}}/{{.Bar}}",
|
|
ExtraConfig: config.ExtraConfig{
|
|
Namespace: map[string]interface{}{"path_aggregation": "pattern"},
|
|
},
|
|
},
|
|
expected: "/api/{foo}/{bar}",
|
|
},
|
|
{
|
|
cfg: &config.Backend{
|
|
URLPattern: "/api/{{.Foo}}/{{.Bar}}",
|
|
ExtraConfig: config.ExtraConfig{
|
|
Namespace: map[string]interface{}{"path_aggregation": "lastparam"},
|
|
},
|
|
},
|
|
expected: "/api/foo/{bar}",
|
|
},
|
|
{
|
|
cfg: &config.Backend{
|
|
URLPattern: "/api/{{.Foo}}/{{.Bar}}",
|
|
ExtraConfig: config.ExtraConfig{
|
|
Namespace: map[string]interface{}{"path_aggregation": "off"},
|
|
},
|
|
},
|
|
expected: "/api/foo/bar",
|
|
},
|
|
{
|
|
expected: "/api/foo/bar",
|
|
},
|
|
} {
|
|
extractor := GetAggregatedPathForBackendMetrics(tc.cfg)
|
|
r, _ := http.NewRequest("GET", "http://example.tld/api/foo/bar", nil)
|
|
if tag := extractor(r); tag != tc.expected {
|
|
t.Errorf("tc-%d: unexpected result: %s", i, tag)
|
|
}
|
|
}
|
|
}
|
|
|
|
*/
|