.

observer/observer.go

@@ -5,6 +5,13 @@ import (
 	"sync"
 )
 
+type Observer interface {
+	Add(id string, ch chan interface{}) error
+	Remove(id string, rch chan interface{}) error
+	Notify(id string, arg interface{}) error
+}
+
+
 type observer struct {
 	mtx    sync.Mutex
 	events map[string][]chan interface{}
@@ -80,6 +87,10 @@ func init() {
 
 // interface
 
+func GetInstance() Observer {
+	return _observer
+}
+
 func Add(id string, ch chan interface{}) error {
 	return _observer.Add(id, ch)
 }