Code Review
/
ric-plt
/
rtmgr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Publish Route only once to the endpoint that requests it. Periodic/Event based distri...
[ric-plt/rtmgr.git]
/
pkg
/
sbi
/
types.go
diff --git
a/pkg/sbi/types.go
b/pkg/sbi/types.go
index
b6dfcd5
..
b52dcfa
100644
(file)
--- a/
pkg/sbi/types.go
+++ b/
pkg/sbi/types.go
@@
-14,6
+14,10
@@
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).
+
==================================================================================
*/
/*
==================================================================================
*/
/*
@@
-26,28
+30,31
@@
package sbi
import "routing-manager/pkg/rtmgr"
import "routing-manager/pkg/rtmgr"
-type
Sbi
EngineConfig struct {
+type EngineConfig struct {
Name string
Version string
Protocol string
Name string
Version string
Protocol string
- Instance
Sbi
Engine
+ Instance Engine
IsAvailable bool
}
IsAvailable bool
}
-type
Sbi
Engine interface {
+type Engine interface {
Initialize(string) error
Terminate() error
DistributeAll(*[]string) error
AddEndpoint(*rtmgr.Endpoint) error
DeleteEndpoint(*rtmgr.Endpoint) error
UpdateEndpoints(*rtmgr.RicComponents)
Initialize(string) error
Terminate() error
DistributeAll(*[]string) error
AddEndpoint(*rtmgr.Endpoint) error
DeleteEndpoint(*rtmgr.Endpoint) error
UpdateEndpoints(*rtmgr.RicComponents)
+ CreateEndpoint(string)(*string,int)
+ CheckEndpoint(string)*rtmgr.Endpoint
+ DistributeToEp(*[]string, string, int ) error
}
}
-type NngSocket interface {
+
/*
type NngSocket interface {
Listen(string) error
Send([]byte) error
Close() error
DialOptions(string, map[string]interface{}) error
}
Listen(string) error
Send([]byte) error
Close() error
DialOptions(string, map[string]interface{}) error
}
-type CreateNewNngSocketHandler func() (NngSocket, error)
+type CreateNewNngSocketHandler func() (NngSocket, error)
*/