)
type rNibWriterInstance struct {
- sdl common.ISdlInstance
+ sdl common.ISdlSyncStorage
rnibWriterConfig configuration.RnibWriterConfig
+ ns string
}
/*
AddEnb(nodebInfo *entities.NodebInfo) error
UpdateNbIdentities(nodeType entities.Node_Type, oldNbIdentities []*entities.NbIdentity, newNbIdentities []*entities.NbIdentity) error
}
+
/*
GetRNibWriter returns reference to RNibWriter
*/
-func GetRNibWriter(sdl common.ISdlInstance, rnibWriterConfig configuration.RnibWriterConfig) RNibWriter {
- return &rNibWriterInstance{sdl: sdl, rnibWriterConfig: rnibWriterConfig}
+func GetRNibWriter(sdl common.ISdlSyncStorage, rnibWriterConfig configuration.RnibWriterConfig) RNibWriter {
+ return &rNibWriterInstance{
+ sdl: sdl,
+ rnibWriterConfig: rnibWriterConfig,
+ ns: common.GetRNibNamespace(),
+ }
}
func getChannelsAndEventsPair(channel string, ranName string, event string) []string {
return common.NewInternalError(err)
}
- err = w.sdl.AddMember(nodeType.String(), nbIdData)
+ err = w.sdl.AddMember(w.ns, nodeType.String(), nbIdData)
if err != nil {
return common.NewInternalError(err)
func (w *rNibWriterInstance) RemoveServedNrCells(inventoryName string, servedNrCells []*entities.ServedNRCell) error {
cellKeysToRemove := buildServedNRCellKeysToRemove(inventoryName, servedNrCells)
- err := w.sdl.Remove(cellKeysToRemove)
+ err := w.sdl.Remove(w.ns, cellKeysToRemove)
if err != nil {
return common.NewInternalError(err)
func (w *rNibWriterInstance) RemoveServedCells(inventoryName string, servedCells []*entities.ServedCellInfo) error {
cellKeysToRemove := buildServedCellInfoKeysToRemove(inventoryName, servedCells)
- err := w.sdl.Remove(cellKeysToRemove)
+ err := w.sdl.Remove(w.ns, cellKeysToRemove)
if err != nil {
return common.NewInternalError(err)
}
}
- err = w.sdl.Set(pairs)
+ err = w.sdl.Set(w.ns, pairs)
if err != nil {
return common.NewInternalError(err)
}
channelsAndEvents := getChannelsAndEventsPair(w.rnibWriterConfig.RanManipulationMessageChannel, nodebInfo.RanName, RanAddedEvent)
- err = w.sdl.SetAndPublish(channelsAndEvents, pairs)
+ err = w.sdl.SetAndPublish(w.ns, channelsAndEvents, pairs)
if err != nil {
return common.NewInternalError(err)
}
return err
}
- err = w.sdl.RemoveMember(nodeType.String(), nbIdIdentitiesToRemove[:]...)
+ err = w.sdl.RemoveMember(w.ns, nodeType.String(), nbIdIdentitiesToRemove[:]...)
if err != nil {
return err
}
return err
}
- err = w.sdl.AddMember(nodeType.String(), nbIdIdentitiesToAdd[:]...)
+ err = w.sdl.AddMember(w.ns, nodeType.String(), nbIdIdentitiesToAdd[:]...)
if err != nil {
return err
}
}
channelsAndEvents := getChannelsAndEventsPair(w.rnibWriterConfig.RanManipulationMessageChannel, nodebInfo.RanName, RanUpdatedEvent)
- err = w.sdl.SetAndPublish(channelsAndEvents, pairs)
+ err = w.sdl.SetAndPublish(w.ns, channelsAndEvents, pairs)
if err != nil {
return common.NewInternalError(err)
if err != nil {
return common.NewInternalError(err)
}
- err = w.sdl.RemoveMember(nodeType.String(), nbIdData)
+ err = w.sdl.RemoveMember(w.ns, nodeType.String(), nbIdData)
if err != nil {
return common.NewInternalError(err)
}
if publish {
channelsAndEvents := getChannelsAndEventsPair(w.rnibWriterConfig.RanManipulationMessageChannel, nodebInfo.RanName, RanUpdatedEvent)
- err = w.sdl.SetAndPublish(channelsAndEvents, pairs)
+ err = w.sdl.SetAndPublish(w.ns, channelsAndEvents, pairs)
} else {
- err = w.sdl.Set(pairs)
+ err = w.sdl.Set(w.ns, pairs)
}
if err != nil {
return w.updateNodebInfo(nodebInfo, true)
}
-
/*
SaveRanLoadInformation stores ran load information for the provided ran
*/
var pairs []interface{}
pairs = append(pairs, key, data)
- err = w.sdl.Set(pairs)
+ err = w.sdl.Set(w.ns, pairs)
if err != nil {
return common.NewInternalError(err)
var pairs []interface{}
pairs = append(pairs, key, data)
- err = w.sdl.Set(pairs)
+ err = w.sdl.Set(w.ns, pairs)
if err != nil {
return common.NewInternalError(err)
var pairs []interface{}
pairs = append(pairs, E2TAddressesKey, data)
- err = w.sdl.Set(pairs)
+ err = w.sdl.Set(w.ns, pairs)
if err != nil {
return common.NewInternalError(err)
if rNibErr != nil {
return rNibErr
}
- err := w.sdl.Remove([]string{key})
+ err := w.sdl.Remove(w.ns, []string{key})
if err != nil {
return common.NewInternalError(err)
var pairs []interface{}
pairs = append(pairs, key, data)
- err = w.sdl.Set(pairs)
+ err = w.sdl.Set(w.ns, pairs)
if err != nil {
return common.NewInternalError(err)
return err
}
- err = w.sdl.SetAndPublish([]string{w.rnibWriterConfig.StateChangeMessageChannel, event}, pairs)
+ err = w.sdl.SetAndPublish(w.ns, []string{w.rnibWriterConfig.StateChangeMessageChannel, event}, pairs)
if err != nil {
return common.NewInternalError(err)
}
channelsAndEvents := getChannelsAndEventsPair(w.rnibWriterConfig.RanManipulationMessageChannel, nodebInfo.RanName, RanDeletedEvent)
- err = w.sdl.RemoveAndPublish(channelsAndEvents, keysToRemove)
+ err = w.sdl.RemoveAndPublish(w.ns, channelsAndEvents, keysToRemove)
if err != nil {
return common.NewInternalError(err)
}
channelsAndEvents := getChannelsAndEventsPair(w.rnibWriterConfig.RanManipulationMessageChannel, nodebInfo.RanName, RanUpdatedEvent)
- err = w.sdl.SetAndPublish(channelsAndEvents, pairs)
+ err = w.sdl.SetAndPublish(w.ns, channelsAndEvents, pairs)
if err != nil {
return common.NewInternalError(err)
return nbIdIdentitiesMembers, nil
}
+
/*
Close the writer
*/