Code Review
/
nonrtric.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Merge "NONRTRIC - Enrichment Coordinator Service, Changed error codes"
[nonrtric.git]
/
dmaap-mediator-producer
/
internal
/
jobs
/
jobs_test.go
diff --git
a/dmaap-mediator-producer/internal/jobs/jobs_test.go
b/dmaap-mediator-producer/internal/jobs/jobs_test.go
index
b301c2f
..
6ca39b2
100644
(file)
--- a/
dmaap-mediator-producer/internal/jobs/jobs_test.go
+++ b/
dmaap-mediator-producer/internal/jobs/jobs_test.go
@@
-31,6
+31,7
@@
import (
"time"
"github.com/stretchr/testify/require"
"time"
"github.com/stretchr/testify/require"
+ "oransc.org/nonrtric/dmaapmediatorproducer/internal/config"
)
const typeDefinition = `{"types": [{"id": "type1", "dmaapTopicUrl": "events/unauthenticated.SEC_FAULT_OUTPUT/dmaapmediatorproducer/type1"}]}`
)
const typeDefinition = `{"types": [{"id": "type1", "dmaapTopicUrl": "events/unauthenticated.SEC_FAULT_OUTPUT/dmaapmediatorproducer/type1"}]}`
@@
-51,11
+52,11
@@
func TestGetTypes_filesOkShouldReturnSliceOfTypesAndProvideSupportedTypes(t *tes
t.Errorf("Unable to create temporary config file for types due to: %v", err)
}
types, err := handlerUnderTest.GetTypes()
t.Errorf("Unable to create temporary config file for types due to: %v", err)
}
types, err := handlerUnderTest.GetTypes()
- wantedType := TypeDefinition{
+ wantedType :=
config.
TypeDefinition{
Id: "type1",
DmaapTopicURL: "events/unauthenticated.SEC_FAULT_OUTPUT/dmaapmediatorproducer/type1",
}
Id: "type1",
DmaapTopicURL: "events/unauthenticated.SEC_FAULT_OUTPUT/dmaapmediatorproducer/type1",
}
- wantedTypes := []TypeDefinition{wantedType}
+ wantedTypes := []
config.
TypeDefinition{wantedType}
assertions.EqualValues(wantedTypes, types)
assertions.Nil(err)
assertions.EqualValues(wantedTypes, types)
assertions.Nil(err)