X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fservices%2Frnib_data_service.go;fp=E2Manager%2Fservices%2Frnib_data_service.go;h=e2b5dc41c4e3b9858178a1d1bed1a53f874a27f0;hb=69f1211bf4b73c8b61ccaf10b75de53a2a6dbc65;hp=7d3d6c5d2f8f43a17bdf5f6e5fdcf35f2deb8438;hpb=8421172ad7f749e00af600b5533ec7ab3d1ff3d1;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/services/rnib_data_service.go b/E2Manager/services/rnib_data_service.go index 7d3d6c5..e2b5dc4 100644 --- a/E2Manager/services/rnib_data_service.go +++ b/E2Manager/services/rnib_data_service.go @@ -33,6 +33,7 @@ import ( type RNibDataService interface { SaveNodeb(nodebInfo *entities.NodebInfo) error UpdateNodebInfo(nodebInfo *entities.NodebInfo) error + UpdateNodebInfoAndPublish(nodebInfo *entities.NodebInfo) error SaveRanLoadInformation(inventoryName string, ranLoadInformation *entities.RanLoadInformation) error GetNodeb(ranName string) (*entities.NodebInfo, error) GetListNodebIds() ([]*entities.NbIdentity, error) @@ -142,6 +143,17 @@ func (w *rNibDataService) UpdateNodebInfo(nodebInfo *entities.NodebInfo) error { return err } +func (w *rNibDataService) UpdateNodebInfoAndPublish(nodebInfo *entities.NodebInfo) error { + w.logger.Infof("#RnibDataService.UpdateNodebInfoAndPublish - nodebInfo: %s", nodebInfo) + + err := w.retry("UpdateNodebInfoAndPublish", func() (err error) { + err = w.rnibWriter.UpdateNodebInfoAndPublish(nodebInfo) + return + }) + + return err +} + func (w *rNibDataService) SaveNodeb(nodebInfo *entities.NodebInfo) error { w.logger.Infof("#RnibDataService.SaveNodeb - nodebInfo: %s", nodebInfo)