+ 1
− 1
+ 3
− 3
@@ -5,9 +5,9 @@ import (
+ 32
− 10
@@ -12,10 +12,24 @@ import (
@@ -117,12 +131,12 @@ func (m *manager) processObsEvent(event interface{}) {
@@ -147,14 +161,14 @@ func (m *manager) Close() error {
@@ -173,11 +187,10 @@ func (m *manager) UpdateConn(c ObsConf) error {
@@ -197,20 +210,29 @@ func NewManager(c ObsConf, logger *zap.Logger, signalsCh chan<- core.Signal) (*m