X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fclients%2Frouting_manager_client.go;h=52e925034c99f1a4f8eb6acf69b6a1d2654b4609;hb=refs%2Fchanges%2F19%2F2119%2F1;hp=c584f5bac9c00527324d3b7ab5afb5ba1dd0c4eb;hpb=372a275602ae05da22130a4601709291c7fbbaa6;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/clients/routing_manager_client.go b/E2Manager/clients/routing_manager_client.go index c584f5b..52e9250 100644 --- a/E2Manager/clients/routing_manager_client.go +++ b/E2Manager/clients/routing_manager_client.go @@ -65,7 +65,7 @@ func (c *RoutingManagerClient) AddE2TInstance(e2tAddress string) error { func (c *RoutingManagerClient) AssociateRanToE2TInstance(e2tAddress string, ranName string) error { - data := models.NewRoutingManagerE2TData(e2tAddress, ranName) + data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(e2tAddress, ranName)} url := c.config.RoutingManager.BaseUrl + AssociateRanToE2TInstanceApiSuffix return c.PostMessage(data, url) @@ -73,13 +73,21 @@ func (c *RoutingManagerClient) AssociateRanToE2TInstance(e2tAddress string, ranN func (c *RoutingManagerClient) DissociateRanE2TInstance(e2tAddress string, ranName string) error { - data := models.NewRoutingManagerE2TData(e2tAddress, ranName) + data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(e2tAddress, ranName)} url := c.config.RoutingManager.BaseUrl + DissociateRanE2TInstanceApiSuffix return c.PostMessage(data, url) } -func (c *RoutingManagerClient) PostMessage(data *models.RoutingManagerE2TData, url string) error { +func (c *RoutingManagerClient) DissociateAllRans(e2tAddresses []string) error { + + data := mapE2TAddressesToE2DataList(e2tAddresses) + url := c.config.RoutingManager.BaseUrl + DissociateRanE2TInstanceApiSuffix + + return c.PostMessage(data, url) +} + +func (c *RoutingManagerClient) PostMessage(data interface{}, url string) error { marshaled, err := json.Marshal(data) if err != nil { @@ -105,4 +113,14 @@ func (c *RoutingManagerClient) PostMessage(data *models.RoutingManagerE2TData, u c.logger.Errorf("[Routing Manager -> E2M] #RoutingManagerClient.PostMessage - failure. http status code: %d", resp.StatusCode) return e2managererrors.NewRoutingManagerError() -} \ No newline at end of file +} + +func mapE2TAddressesToE2DataList(e2tAddresses []string) models.RoutingManagerE2TDataList { + e2tDataList := make(models.RoutingManagerE2TDataList, len(e2tAddresses)) + + for i, v := range e2tAddresses { + e2tDataList[i] = models.NewRoutingManagerE2TData(v) + } + + return e2tDataList +}