GetE2TInstance(e2tAddress string) (*entities.E2TInstance, error)
GetE2TInstances() ([]*entities.E2TInstance, error)
GetE2TInstancesNoLogs() ([]*entities.E2TInstance, error)
- AddE2TInstance(e2tAddress string) error
+ AddE2TInstance(e2tAddress string, podName string) error
RemoveE2TInstance(e2tAddress string) error
SelectE2TInstance() (string, error)
AddRansToInstance(e2tAddress string, ranNames []string) error
return minInstance
}
-func (m *E2TInstancesManager) AddE2TInstance(e2tAddress string) error {
+func (m *E2TInstancesManager) AddE2TInstance(e2tAddress string, podName string) error {
m.mux.Lock()
defer m.mux.Unlock()
- e2tInstance := entities.NewE2TInstance(e2tAddress)
+ e2tInstance := entities.NewE2TInstance(e2tAddress, podName)
err := m.rnibDataService.SaveE2TInstance(e2tInstance)
if err != nil {
return err
}
- m.logger.Infof("#E2TInstancesManager.AddE2TInstance - E2T Instance address: %s - successfully added E2T instance", e2tInstance.Address)
+ m.logger.Infof("#E2TInstancesManager.AddE2TInstance - E2T Instance address: %s, pod name: %s - successfully added E2T instance", e2tInstance.Address, e2tInstance.PodName)
return nil
}
return err
}
- if e2tInstance.State == entities.ToBeDeleted || e2tInstance.State == entities.RoutingManagerFailure {
+ if e2tInstance.State == entities.ToBeDeleted {
m.logger.Warnf("#E2TInstancesManager.ResetKeepAliveTimestamp - Ignore. This Instance is about to be deleted")
return nil
return e2managererrors.NewRnibDbError()
}
- if (currentState != e2tInstance.State) {
+ if currentState != e2tInstance.State {
m.logger.Warnf("#E2TInstancesManager.SetE2tInstanceState - E2T Instance address: %s - Current state is not: %s", e2tAddress, currentState)
return e2managererrors.NewInternalError()
}
e2tInstance.State = newState
- if (newState == entities.Active) {
+ if newState == entities.Active {
e2tInstance.KeepAliveTimestamp = time.Now().UnixNano()
}