Documentation ¶
Overview ¶
Package manager is is the main coordinator for the ONOS RAN subsystem.
Index ¶
- Variables
- type Manager
- func (m *Manager) Close()
- func (m *Manager) DeleteTelemetry(plmnid string, ecid string, crnti string) error
- func (m *Manager) DeleteUEAdmissionRequest(plmnid string, ecid string, crnti string) error
- func (m *Manager) GetIndications() ([]e2ap.RicIndication, error)
- func (m *Manager) GetUEAdmissionByID(ecgi *sb.ECGI, crnti string) (*e2ap.RicIndication, error)
- func (m *Manager) ListIndications(ch chan<- e2ap.RicIndication) error
- func (m *Manager) Run()
- func (m *Manager) StoreControlUpdate(update e2ap.RicIndication) error
- func (m *Manager) StoreRicControlRequest(deviceID device.ID, request *e2ap.RicControlRequest) error
- func (m *Manager) StoreRicControlResponse(update e2ap.RicIndication) error
- func (m *Manager) StoreTelemetry(update e2ap.RicIndication) error
- func (m *Manager) SubscribeIndications(ch chan<- indications.Event, opts ...indications.WatchOption) error
Constants ¶
This section is empty.
Variables ¶
var DeviceStoreFactory = func(topoEndPoint string, opts ...grpc.DialOption) (device.Store, error) { return device.NewTopoStore(topoEndPoint, opts...) }
DeviceStoreFactory creates the device store
var IndicationsStoreFactory = func(configuration config.Config) (indications.Store, error) { return indications.NewDistributedStore(configuration) }
IndicationsStoreFactory creates the indications store
var MastershipStoreFactory = func(configuration config.Config) (mastership.Store, error) { return mastership.NewDistributedStore(configuration) }
MastershipStoreFactory creates the mastership store
var RequestsStoreFactory = func(configuration config.Config) (requests.Store, error) { return requests.NewDistributedStore(configuration) }
RequestsStoreFactory creates the requests store
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager single point of entry for the RAN system.
func GetManager ¶
func GetManager() *Manager
GetManager returns the initialized and running instance of manager. Should be called only after NewManager and Run are done.
func InitializeManager ¶ added in v0.6.1
func InitializeManager(indicationsStore indications.Store, requestsStore requests.Store, sessionMgr *e2.SessionManager) *Manager
InitializeManager initializes the manager structure with the given data
func NewManager ¶
func NewManager(topoEndPoint string, opts []grpc.DialOption) (*Manager, error)
NewManager initializes the RAN subsystem.
func (*Manager) Close ¶
func (m *Manager) Close()
Close kills the channels and manager related objects
func (*Manager) DeleteTelemetry ¶
DeleteTelemetry deletes telemetry when a handover happens
func (*Manager) DeleteUEAdmissionRequest ¶
DeleteUEAdmissionRequest deletes UpdateControls
func (*Manager) GetIndications ¶ added in v0.6.1
func (m *Manager) GetIndications() ([]e2ap.RicIndication, error)
GetIndications gets update indications
func (*Manager) GetUEAdmissionByID ¶
GetUEAdmissionByID retrieve a single value from the updates store
func (*Manager) ListIndications ¶ added in v0.6.1
func (m *Manager) ListIndications(ch chan<- e2ap.RicIndication) error
ListIndications lists control updates
func (*Manager) Run ¶
func (m *Manager) Run()
Run starts a synchronizer based on the devices and the northbound services.
func (*Manager) StoreControlUpdate ¶
func (m *Manager) StoreControlUpdate(update e2ap.RicIndication) error
StoreControlUpdate - put the control update in the atomix store
func (*Manager) StoreRicControlRequest ¶ added in v0.6.5
StoreRicControlRequest stores a RicControlRequest to the store
func (*Manager) StoreRicControlResponse ¶
func (m *Manager) StoreRicControlResponse(update e2ap.RicIndication) error
StoreRicControlResponse - write the RicControlResponse to store
func (*Manager) StoreTelemetry ¶
func (m *Manager) StoreTelemetry(update e2ap.RicIndication) error
StoreTelemetry - put the telemetry update in the atomix store Only handles MessageType_RADIO_MEAS_REPORT_PER_UE at the moment
func (*Manager) SubscribeIndications ¶ added in v0.6.1
func (m *Manager) SubscribeIndications(ch chan<- indications.Event, opts ...indications.WatchOption) error
SubscribeIndications subscribes the given channel to control updates