Change-Id: I650ed6aa6f34ea24a4d483b7f79a8bf29db164d0
Signed-off-by: zkoczka <zoltan.koczka@nokia.com>
type: "object"
properties:
id:
type: "object"
properties:
id:
- type: "integer"
- format: "int64"
event:
type: "string"
version:
event:
type: "string"
version:
maximum: 65535
subscription_id: #subscription sequence number
type: "integer"
maximum: 65535
subscription_id: #subscription sequence number
type: "integer"
xapp-list:
type: "array"
items:
xapp-list:
type: "array"
items:
// TODO: arguments should be validated (filename; xm-url; sbi-if; rest-url; rest-port)
args = make(map[string]*string)
args["configfile"] = flag.String("configfile", "/etc/rtmgrcfg.json", "Routing manager's configuration file path")
// TODO: arguments should be validated (filename; xm-url; sbi-if; rest-url; rest-port)
args = make(map[string]*string)
args["configfile"] = flag.String("configfile", "/etc/rtmgrcfg.json", "Routing manager's configuration file path")
- args["nbi"] = flag.String("nbi", "httpGetter", "Northbound interface module to be used. Valid values are: 'httpGetter | httpRESTful'")
+ args["nbi"] = flag.String("nbi", "httpRESTful", "Northbound interface module to be used. Valid values are: 'httpGetter | httpRESTful'")
args["sbi"] = flag.String("sbi", "nngpush", "Southbound interface module to be used. Valid values are: 'nngpush | nngpub'")
args["rpe"] = flag.String("rpe", "rmrpush", "Route Policy Engine to be used. Valid values are: 'rmrpush | rmrpub'")
args["sdl"] = flag.String("sdl", "file", "Datastore enginge to be used. Valid values are: 'file'")
args["sbi"] = flag.String("sbi", "nngpush", "Southbound interface module to be used. Valid values are: 'nngpush | nngpub'")
args["rpe"] = flag.String("rpe", "rmrpush", "Route Policy Engine to be used. Valid values are: 'rmrpush | rmrpub'")
args["sdl"] = flag.String("sdl", "file", "Datastore enginge to be used. Valid values are: 'file'")
server.Port, err = strconv.Atoi(nbiUrl.Port())
if err != nil {
server.Port, err = strconv.Atoi(nbiUrl.Port())
if err != nil {
- rtmgr.Logger.Error("Invalid NBI RestAPI port")
- os.Exit(1)
+ rtmgr.Logger.Error("Invalid NBI RestAPI port")
+ os.Exit(1)
- server.Host = nbiUrl.Hostname()
+ server.Host = "0.0.0.0"
// set handlers
api.HandleProvideXappHandleHandler = handle.ProvideXappHandleHandlerFunc(
func(params handle.ProvideXappHandleParams) middleware.Responder {
// set handlers
api.HandleProvideXappHandleHandler = handle.ProvideXappHandleHandlerFunc(
func(params handle.ProvideXappHandleParams) middleware.Responder {
XApps: *swag.String("[]"),
Version: *swag.Int64(1),
Event: *swag.String("any"),
XApps: *swag.String("[]"),
Version: *swag.Int64(1),
Event: *swag.String("any"),
- ID: *swag.Int64(123456),
+ ID: *swag.String("123456"),
}
ch := make(chan *models.XappCallbackData)
}
ch := make(chan *models.XappCallbackData)
XApps: *swag.String("[]"),
Version: *swag.Int64(1),
Event: *swag.String("someevent"),
XApps: *swag.String("[]"),
Version: *swag.Int64(1),
Event: *swag.String("someevent"),
- ID: *swag.Int64(123456)}
+ ID: *swag.String("123456")}
var httpRestful, _ = GetNbi("httpRESTful")
err := httpRestful.(*HttpRestful).ProvideXappHandleHandlerImpl(datach, &data)
if err != nil {
var httpRestful, _ = GetNbi("httpRESTful")
err := httpRestful.(*HttpRestful).ProvideXappHandleHandlerImpl(datach, &data)
if err != nil {
XApps: *swag.String("[]"),
Version: *swag.Int64(1),
Event: *swag.String("someevent"),
XApps: *swag.String("[]"),
Version: *swag.Int64(1),
Event: *swag.String("someevent"),
- ID: *swag.Int64(123456)}
+ ID: *swag.String("123456")}
err := validateXappCallbackData(&data)
if err != nil {
err := validateXappCallbackData(&data)
if err != nil {
XApps: *swag.String("{}"),
Version: *swag.Int64(1),
Event: *swag.String("someevent"),
XApps: *swag.String("{}"),
Version: *swag.Int64(1),
Event: *swag.String("someevent"),
- ID: *swag.Int64(123456)}
+ ID: *swag.String("123456")}
err := validateXappCallbackData(&data)
if err == nil {
err := validateXappCallbackData(&data)
if err == nil {
MessageType string
TxList EndpointList
RxGroups []EndpointList
MessageType string
TxList EndpointList
RxGroups []EndpointList
}
type Subscription struct {
}
type Subscription struct {
Fqdn string
Port uint16
}
Fqdn string
Port uint16
}