AddEndpoint(*rtmgr.Endpoint) error
DeleteEndpoint(*rtmgr.Endpoint) error
UpdateEndpoints(*rtmgr.RicComponents)
- CreateEndpoint(string) (*rtmgr.Endpoint)
- DistributeToEp(*[]string, *rtmgr.Endpoint) error
+ CheckEndpoint(string) *rtmgr.Endpoint
+ CreateEndpoint(string) (*string, int)
+ 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
}
-type CreateNewNngSocketHandler func() (NngSocket, error)
+type CreateNewNngSocketHandler func() (NngSocket, error)*/