+func (w *rNibDataService) GetE2TInstance(address string) (*entities.E2TInstance, error) {
+ w.logger.Infof("#RnibDataService.GetE2TInstance")
+
+ var e2tInstance *entities.E2TInstance = nil
+
+ err := w.retry("GetE2TInstance", func() (err error) {
+ e2tInstance, err = w.rnibReader.GetE2TInstance(address)
+ return
+ })
+
+ return e2tInstance, err
+}
+
+func (w *rNibDataService) GetE2TInstances(addresses []string) ([]*entities.E2TInstance, error) {
+ w.logger.Infof("#RnibDataService.GetE2TInstances")
+
+ var e2tInstances []*entities.E2TInstance = nil
+
+ err := w.retry("GetE2TInstance", func() (err error) {
+ e2tInstances, err = w.rnibReader.GetE2TInstances(addresses)
+ return
+ })
+
+ return e2tInstances, err
+}
+
+func (w *rNibDataService) GetE2TAddresses() ([]string, error) {
+ w.logger.Infof("#RnibDataService.GetE2TAddresses")
+
+ var e2tAddresses []string = nil
+
+ err := w.retry("GetE2TAddresses", func() (err error) {
+ e2tAddresses, err = w.rnibReader.GetE2TAddresses()
+ return
+ })
+
+ return e2tAddresses, err
+}
+
+func (w *rNibDataService) SaveE2TInstance(e2tInstance *entities.E2TInstance) error {
+ w.logger.Infof("#RnibDataService.SaveE2TInstance")
+
+ err := w.retry("SaveE2TInstance", func() (err error) {
+ err = w.rnibWriter.SaveE2TInstance(e2tInstance)
+ return
+ })
+
+ return err
+}
+
+func (w *rNibDataService) SaveE2TAddresses(addresses []string) error {
+ w.logger.Infof("#RnibDataService.SaveE2TAddresses")
+
+ err := w.retry("SaveE2TAddresses", func() (err error) {
+ err = w.rnibWriter.SaveE2TAddresses(addresses)
+ return
+ })
+
+ return err
+}
+
+func (w *rNibDataService) PingRnib() bool {
+ err := w.retry("GetListNodebIds", func() (err error) {
+ _, err = w.rnibReader.GetListNodebIds()
+ return
+ })
+
+ return !isRnibConnectionError(err)
+}
+