Add kafka jobs to DMaaP Mediator Producer 70/7470/6
authorelinuxhenrik <henrik.b.andersson@est.tech>
Thu, 23 Dec 2021 15:36:31 +0000 (16:36 +0100)
committerelinuxhenrik <henrik.b.andersson@est.tech>
Tue, 4 Jan 2022 09:33:26 +0000 (10:33 +0100)
commit6f5d3d1eccb8a1857c645ba6bd0b5e1b89ca7088
tree4618bbfdc447b02356352e60eb801133454b41f4
parent6b43426c2b52daa5ace5205b98d09e1871fa41d6
Add kafka jobs to DMaaP Mediator Producer

Issue-ID: NONRTRIC-702
Signed-off-by: elinuxhenrik <henrik.b.andersson@est.tech>
Change-Id: Ia7123240ad91449209afc4769b850cb0c8d9598f
17 files changed:
dmaap-mediator-producer/configs/typeSchemaDmaap.json [new file with mode: 0644]
dmaap-mediator-producer/configs/typeSchemaKafka.json [new file with mode: 0644]
dmaap-mediator-producer/configs/type_config.json
dmaap-mediator-producer/go.mod
dmaap-mediator-producer/go.sum
dmaap-mediator-producer/internal/config/config.go
dmaap-mediator-producer/internal/config/config_test.go
dmaap-mediator-producer/internal/config/registrator.go
dmaap-mediator-producer/internal/config/registrator_test.go
dmaap-mediator-producer/internal/jobs/jobs.go
dmaap-mediator-producer/internal/jobs/jobs_test.go
dmaap-mediator-producer/internal/kafkaclient/kafkaclient.go [new file with mode: 0644]
dmaap-mediator-producer/internal/server/server_test.go
dmaap-mediator-producer/main.go
dmaap-mediator-producer/mocks/KafkaConsumer.go [new file with mode: 0644]
dmaap-mediator-producer/mocks/KafkaFactory.go [new file with mode: 0644]
dmaap-mediator-producer/mocks/jobshandler/JobsHandler.go [moved from dmaap-mediator-producer/mocks/jobhandler/JobHandler.go with 66% similarity]