X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=adapter%2Fcmd%2Fadapter.go;h=bd491a520753541b74c19efa5d70cc6fc4e54108;hb=61bdef5fe4a22986832d1e51846cbb011ac04074;hp=3f24dced688bb4a5d680121d6fd2581bbb613fb2;hpb=4e7e71265c9a5b85d56478267b0a6ed44f6a80fb;p=ric-plt%2Falarm-go.git diff --git a/adapter/cmd/adapter.go b/adapter/cmd/adapter.go index 3f24dce..bd491a5 100755 --- a/adapter/cmd/adapter.go +++ b/adapter/cmd/adapter.go @@ -65,17 +65,21 @@ var Hash string // Main function func main() { - NewAlarmAdapter(0).Run(true) + NewAlarmAdapter("", 0).Run(true) } -func NewAlarmAdapter(alertInterval int) *AlarmAdapter { +func NewAlarmAdapter(amHost string, alertInterval int) *AlarmAdapter { if alertInterval == 0 { alertInterval = viper.GetInt("promAlertManager.alertInterval") } + if amHost == "" { + amHost = viper.GetString("promAlertManager.address") + } + return &AlarmAdapter{ rmrReady: false, - amHost: viper.GetString("promAlertManager.address"), + amHost: amHost, amBaseUrl: viper.GetString("promAlertManager.baseUrl"), amSchemes: []string{viper.GetString("promAlertManager.schemes")}, alertInterval: alertInterval, @@ -88,6 +92,9 @@ func (a *AlarmAdapter) Run(sdlcheck bool) { app.SetReadyCB(func(d interface{}) { a.rmrReady = true }, true) app.Resource.InjectStatusCb(a.StatusCB) + app.Resource.InjectRoute("/ric/v1/alarm", a.GetActiveAlarms, "GET") + app.Resource.InjectRoute("/ric/v1/alarm", a.GenerateAlarm, "POST") + // Start background timer for re-raising alerts go a.StartAlertTimer()