Open RMR connection in a new thread

[ric-plt/rtmgr.git] / pkg / nbi / types.go

diff --git a/pkg/nbi/types.go b/pkg/nbi/types.go
index 049fe45..722289e 100644 (file)
--- a/pkg/nbi/types.go
+++ b/pkg/nbi/types.go
@@ -14,6 +14,11 @@
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.

+
+
+   This source code is part of the near-RT RIC (RAN Intelligent Controller)
+   platform project (RICP).
+

 ==================================================================================
 */
 /*
 ==================================================================================
 */
 /*


@@ -29,13 +34,15 @@ import (
        "routing-manager/pkg/rpe"
        "routing-manager/pkg/rtmgr"
        "routing-manager/pkg/sdl"
        "routing-manager/pkg/rpe"
        "routing-manager/pkg/rtmgr"
        "routing-manager/pkg/sdl"

+       "sync"

 )
 
 type FetchAllXAppsHandler func(string) (*[]rtmgr.XApp, error)
 type RecvXappCallbackDataHandler func(<-chan *models.XappCallbackData) (*[]rtmgr.XApp, error)
 )
 
 type FetchAllXAppsHandler func(string) (*[]rtmgr.XApp, error)
 type RecvXappCallbackDataHandler func(<-chan *models.XappCallbackData) (*[]rtmgr.XApp, error)

-type LaunchRestHandler func(*string, chan<- *models.XappCallbackData, chan<- *models.XappSubscriptionData, chan<- *models.XappSubscriptionData)
+type RecvNewE2TdataHandler func(<-chan *models.E2tData) (*rtmgr.E2TInstance, string, error)
+type LaunchRestHandler func(*string)

 type ProvideXappHandleHandlerImpl func(chan<- *models.XappCallbackData, *models.XappCallbackData) error
 type ProvideXappHandleHandlerImpl func(chan<- *models.XappCallbackData, *models.XappCallbackData) error

-type RetrieveStartupDataHandler func(string, string, string, string, sdl.Engine) error
+type RetrieveStartupDataHandler func(string, string, string, string, string, sdl.Engine) error

 
 type EngineConfig struct {
        Name        string
 
 type EngineConfig struct {
        Name        string


@@ -46,6 +53,6 @@ type EngineConfig struct {
 }
 
 type Engine interface {
 }
 
 type Engine interface {

-       Initialize(string, string, string, string, sdl.Engine, rpe.Engine, chan<- bool) error
+       Initialize(string, string, string, string, string, sdl.Engine, rpe.Engine, *sync.Mutex) error

        Terminate() error
 }
        Terminate() error
 }