X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Finternal%2Fconfig%2Fregistrator.go;h=37225eda5e850a8c9cdfa44837b2b3dda4dfb376;hb=63a42cacf9c52b7dff64431a3354f55c49bd6e4b;hp=eaf8752f1048718323a438c335331d35f6e4e9d7;hpb=64654a9b0e63b7e36249bef4f542cdf7fac56020;p=nonrtric.git diff --git a/dmaap-mediator-producer/internal/config/registrator.go b/dmaap-mediator-producer/internal/config/registrator.go index eaf8752f..37225eda 100644 --- a/dmaap-mediator-producer/internal/config/registrator.go +++ b/dmaap-mediator-producer/internal/config/registrator.go @@ -27,7 +27,7 @@ import ( log "github.com/sirupsen/logrus" - "oransc.org/nonrtric/dmaapmediatorproducer/internal/jobtypes" + "oransc.org/nonrtric/dmaapmediatorproducer/internal/jobs" "oransc.org/nonrtric/dmaapmediatorproducer/internal/restclient" ) @@ -35,7 +35,7 @@ const registerTypePath = "/data-producer/v1/info-types/" const registerProducerPath = "/data-producer/v1/info-producers/" type Registrator interface { - RegisterTypes(types []*jobtypes.Type) error + RegisterTypes(types []*jobs.Type) error RegisterProducer(producerId string, producerInfo *ProducerRegistrationInfo) } @@ -49,7 +49,7 @@ func NewRegistratorImpl(infoCoordAddr string) *RegistratorImpl { } } -func (r RegistratorImpl) RegisterTypes(jobTypes []*jobtypes.Type) error { +func (r RegistratorImpl) RegisterTypes(jobTypes []*jobs.Type) error { for _, jobType := range jobTypes { body := fmt.Sprintf(`{"info_job_data_schema": %v}`, jobType.Schema) if error := restclient.Put(r.infoCoordinatorAddress+registerTypePath+url.PathEscape(jobType.TypeId), []byte(body)); error != nil {