X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fnbi%2Ftypes.go;h=f538ac4921d1ffb5fd731e7278775d6da39b59af;hb=cb93dbf2fac19dd49332847327b364be27d8bb71;hp=e02c30de67e41414ae47ac1b03873f49b763ddc3;hpb=871fa393844ce1b61b8d5218d27687d9fc05803a;p=ric-plt%2Frtmgr.git diff --git a/pkg/nbi/types.go b/pkg/nbi/types.go index e02c30d..f538ac4 100644 --- a/pkg/nbi/types.go +++ b/pkg/nbi/types.go @@ -14,28 +14,45 @@ 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). + ================================================================================== */ /* Mnemonic: nbi.go - Abstract: Containes NBI (NorthBound Interface) specific types + Abstract: Contains NBI (NorthBound Interface) specific types Date: 12 March 2019 */ package nbi -import "rtmgr" - -type batchFetch func(url string) (*[]rtmgr.XApp, error) - -type NbiEngine struct { - Name string - Version string - Protocol string +import ( + "routing-manager/pkg/models" + "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 RecvNewE2TdataHandler func(<-chan *models.E2tData) (*rtmgr.E2TInstance, string, error) +type LaunchRestHandler func(*string, chan<- *models.XappCallbackData, chan<- *models.XappSubscriptionData, chan<- *rtmgr.XappList, chan<- *models.XappSubscriptionData, chan<- *models.E2tData, chan<- models.RanE2tMap, chan<- models.RanE2tMap, chan<- *models.E2tDeleteData) +type ProvideXappHandleHandlerImpl func(chan<- *models.XappCallbackData, *models.XappCallbackData) error +type RetrieveStartupDataHandler func(string, string, string, string, string, sdl.Engine) error + +type EngineConfig struct { + Name string + Version string + Protocol string + Instance Engine + IsAvailable bool } -type NbiEngineConfig struct { - Engine NbiEngine - BatchFetch batchFetch - IsAvailable bool +type Engine interface { + Initialize(string, string, string, string, string, sdl.Engine, rpe.Engine, chan<- bool, *sync.Mutex) error + Terminate() error }