GitHub-Proxy/signoz
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz synced 2025-08-12 20:59:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: tests fixed

Browse Source
This commit is contained in:
nityanandagohain 2023-03-16 10:24:20 +05:30
parent bac717e9e6
commit 7367f8dd4b
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/query-service/app/opamp/logspipeline_test.go
View File

@ -27,7 +27,7 @@ var buildProcessorTestData = []struct {
outputConf: map[string]interface{}{ outputConf: map[string]interface{}{
"processors": map[string]interface{}{ "processors": map[string]interface{}{
constants.LogsPPLPfx + "b": struct{}{}, constants.LogsPPLPfx + "b": struct{}{},
"batch": struct{}{}, "batch": struct{}{},
}, },
}, },
}, },
@ -36,7 +36,7 @@ var buildProcessorTestData = []struct {
agentConf: map[string]interface{}{ agentConf: map[string]interface{}{
"processors": map[string]interface{}{ "processors": map[string]interface{}{
constants.LogsPPLPfx + "b": struct{}{}, constants.LogsPPLPfx + "b": struct{}{},
"batch": struct{}{}, "batch": struct{}{},
}, },
}, },
pipelineProcessor: map[string]interface{}{}, pipelineProcessor: map[string]interface{}{},
@ -52,7 +52,7 @@ var buildProcessorTestData = []struct {
"processors": map[string]interface{}{ "processors": map[string]interface{}{
constants.LogsPPLPfx + "a": struct{}{}, constants.LogsPPLPfx + "a": struct{}{},
constants.LogsPPLPfx + "b": struct{}{}, constants.LogsPPLPfx + "b": struct{}{},
"batch": struct{}{}, "batch": struct{}{},
}, },
}, },
pipelineProcessor: map[string]interface{}{ pipelineProcessor: map[string]interface{}{
@ -61,7 +61,7 @@ var buildProcessorTestData = []struct {
outputConf: map[string]interface{}{ outputConf: map[string]interface{}{
"processors": map[string]interface{}{ "processors": map[string]interface{}{
constants.LogsPPLPfx + "b": struct{}{}, constants.LogsPPLPfx + "b": struct{}{},
"batch": struct{}{}, "batch": struct{}{},
}, },
}, },
}, },
@ -72,7 +72,7 @@ var buildProcessorTestData = []struct {
"memorylimiter": struct{}{}, "memorylimiter": struct{}{},
constants.LogsPPLPfx + "a": struct{}{}, constants.LogsPPLPfx + "a": struct{}{},
constants.LogsPPLPfx + "b": struct{}{}, constants.LogsPPLPfx + "b": struct{}{},
"batch": struct{}{}, "batch": struct{}{},
}, },
}, },
pipelineProcessor: map[string]interface{}{ pipelineProcessor: map[string]interface{}{
@ -82,14 +82,14 @@ var buildProcessorTestData = []struct {
"processors": map[string]interface{}{ "processors": map[string]interface{}{
"memorylimiter": struct{}{}, "memorylimiter": struct{}{},
constants.LogsPPLPfx + "b": struct{}{}, constants.LogsPPLPfx + "b": struct{}{},
"batch": struct{}{}, "batch": struct{}{},
}, },
}, },
}, },
} }
func TestBuildLogParsingProcessors(t *testing.T) { func TestBuildLogParsingProcessors(t *testing.T) {
for , test := range buildProcessorTestData { for _, test := range buildProcessorTestData {
Convey(test.Name, t, func() { Convey(test.Name, t, func() {
err := buildLogParsingProcessors(test.agentConf, test.pipelineProcessor) err := buildLogParsingProcessors(test.agentConf, test.pipelineProcessor)
So(err, ShouldBeNil) So(err, ShouldBeNil)
@ -150,7 +150,7 @@ var BuildLogsPipelineTestData = []struct {
} }
func TestBuildLogsPipeline(t *testing.T) { func TestBuildLogsPipeline(t *testing.T) {
for , test := range BuildLogsPipelineTestData { for _, test := range BuildLogsPipelineTestData {
Convey(test.Name, t, func() { Convey(test.Name, t, func() {
v, err := buildLogsProcessors(test.currentPipeline, test.logsPipeline) v, err := buildLogsProcessors(test.currentPipeline, test.logsPipeline)
So(err, ShouldBeNil) So(err, ShouldBeNil)