add default eventDispatch type and handle eventType is ptr

common/observer/dispatcher/direct_event_dispatcher.go

@@ -43,6 +43,10 @@ func NewDirectEventDispatcher() observer.EventDispatcher {
 }
 
 func (ded *DirectEventDispatcher) Dispatch(event observer.Event) {
+	if event == nil {
+		logger.Warnf("[DirectEventDispatcher] dispatch event nil")
+		return
+	}
 	eventType := reflect.TypeOf(event).Elem()
 	value, loaded := ded.ListenersCache.Load(eventType)
 	if !loaded {

common/observer/dispatcher/direct_event_dispatcher_test.go

@@ -29,6 +29,7 @@ func TestDirectEventDispatcher_Dispatch(t *testing.T) {
 	ded.AddEventListener(&TestEventListener{})
 	ded.AddEventListener(&TestEventListener1{})
 	ded.Dispatch(&TestEvent{})
+	ded.Dispatch(nil)
 }
 
 type TestEvent struct {
@@ -50,7 +51,7 @@ func (tel *TestEventListener) GetPriority() int {
 }
 
 func (tel *TestEventListener) GetEventType() reflect.Type {
-	return reflect.TypeOf(TestEvent{})
+	return reflect.TypeOf(&TestEvent{})
 }
 
 type TestEventListener1 struct {

common/observer/listenable.go

@@ -18,6 +18,7 @@
 package observer
 
 import (
+	"reflect"
 	"sort"
 	"sync"
 )
@@ -44,6 +45,9 @@ func NewBaseListenable() Listenable {
 // AddEventListener ...
 func (bl *BaseListenable) AddEventListener(listener EventListener) {
 	eventType := listener.GetEventType()
+	if eventType.Kind() == reflect.Ptr {
+		eventType = eventType.Elem()
+	}
 	var listenersSlice []EventListener
 	bl.Mutex.Lock()
 	defer bl.Mutex.Unlock()
@@ -72,6 +76,9 @@ func (bl *BaseListenable) AddEventListeners(listenersSlice []EventListener) {
 // RemoveEventListener ...
 func (bl *BaseListenable) RemoveEventListener(listener EventListener) {
 	eventType := listener.GetEventType()
+	if eventType.Kind() == reflect.Ptr {
+		eventType = eventType.Elem()
+	}
 	bl.Mutex.Lock()
 	defer bl.Mutex.Unlock()
 	value, loaded := bl.ListenersCache.Load(eventType)

config/base_config.go

@@ -46,7 +46,7 @@ type BaseConfig struct {
 	configCenterUrl     *common.URL
 	prefix              string
 	fatherConfig        interface{}
-	eventDispatcherType string        `yaml:"direct" json:"direct,omitempty"`
+	eventDispatcherType string        `default:"direct" yaml:"event_dispatcher_type" json:"event_dispatcher_type,omitempty"`
 	MetricConfig        *MetricConfig `yaml:"metrics" json:"metrics,omitempty"`
 	fileStream          *bytes.Buffer
 }