manager

Documentation

Overview

Package manager is is the main coordinator for the ONOS RAN subsystem.

Index

• Variables
• type Manager
  • func GetManager() *Manager
  • func InitializeManager(indicationsStore indications.Store, requestsStore requests.Store, ...) *Manager
  • func NewManager(topoEndPoint string, opts []grpc.DialOption) (*Manager, error)
  • 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

Variables

var ClusterFactory = func(configuration config.Config) (cluster.Cluster, error) {
	client, err := atomix.GetClient(configuration.Atomix)
	if err != nil {
		return nil, err
	}
	return cluster.New(client)
}

ClusterFactory creates the cluster

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(cluster cluster.Cluster, configuration config.Config) (mastership.Store, error) {
	return mastership.NewDistributedStore(cluster, configuration)
}

MastershipStoreFactory creates the mastership store

var RequestsStoreFactory = func(configuration config.Config) (requests.Store, error) {
	return requests.NewDistributedStore(configuration)
}

RequestsStoreFactory creates the requests store

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

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

func (m *Manager) DeleteTelemetry(plmnid string, ecid string, crnti string) error

DeleteTelemetry deletes telemetry when a handover happens

func (*Manager) DeleteUEAdmissionRequest

func (m *Manager) DeleteUEAdmissionRequest(plmnid string, ecid string, crnti string) error

DeleteUEAdmissionRequest deletes UpdateControls

func (*Manager) GetIndications

func (m *Manager) GetIndications() ([]e2ap.RicIndication, error)

GetIndications gets update indications

func (*Manager) GetUEAdmissionByID

func (m *Manager) GetUEAdmissionByID(ecgi *sb.ECGI, crnti string) (*e2ap.RicIndication, error)

GetUEAdmissionByID retrieve a single value from the updates store

func (*Manager) ListIndications

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

func (m *Manager) StoreRicControlRequest(deviceID device.ID, request *e2ap.RicControlRequest) error

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

func (m *Manager) SubscribeIndications(ch chan<- indications.Event, opts ...indications.WatchOption) error

SubscribeIndications subscribes the given channel to control updates