diff --git a/event/event_system.go b/event/event_system.go index 70554cd8..df512191 100755 --- a/event/event_system.go +++ b/event/event_system.go @@ -137,7 +137,7 @@ func (dis *Dispatcher) DispatchEvent(event *Event) error { } if matched { for _, listener := range listeners { - openlogging.GetLogger().Debugf("event generated for %s", regKey) + openlogging.GetLogger().Infof("event generated for %s", regKey) go listener.Event(event) } } diff --git a/source/manager.go b/source/manager.go index b65586cc..d8f14c8a 100755 --- a/source/manager.go +++ b/source/manager.go @@ -345,7 +345,7 @@ func (m *Manager) updateEvent(e *event.Event) error { if e == nil || e.EventSource == "" || e.Key == "" { return errors.New("nil or invalid event supplied") } - openlogging.GetLogger().Debugf("event received %s", e) + openlogging.GetLogger().Infof("event received %s", e) switch e.EventType { case event.Create, event.Update: m.configMapMux.Lock() @@ -360,6 +360,8 @@ func (m *Manager) updateEvent(e *event.Event) error { if prioritySrc != nil && prioritySrc.GetSourceName() == sourceName { // if event generated from less priority source then ignore m.configMapMux.Unlock() + openlogging.GetLogger().Infof("the event source %s's priority is less then %s's, ignore", + e.EventSource, sourceName) return nil } m.ConfigurationMap[e.Key] = e.EventSource diff --git a/source/remote/kie/kie_source.go b/source/remote/kie/kie_source.go index 94883a7d..cf788394 100644 --- a/source/remote/kie/kie_source.go +++ b/source/remote/kie/kie_source.go @@ -78,6 +78,10 @@ func NewKieSource(ci *archaius.RemoteInfo) (source.ConfigSource, error) { } else { ks.RefreshInterval = time.Second * time.Duration(ci.RefreshInterval) } + openlogging.Info("new kie source", openlogging.WithTags( + openlogging.Tags{ + "labels": ci.DefaultDimension, + })) return ks, nil }