dispatcher

type CallBackFunc func(e IEvent) error

type CallBackHandler interface {
	DataEvent(e IEvent) error
}

type Data struct {
	// contains filtered or unexported fields
}

type DataDispatchCenter struct {
	// contains filtered or unexported fields
}

type IDispatchCenter interface {
	io.Closer
	Register(handler CallBackFunc) (closeChan chan<- int)
	Listener() IListener
	Send(e IEvent)
}

type IEvent interface {
	Namespace() string
	Event() string
	Key() string
	Data() []byte
	All() map[string]map[string][]byte
}

type IListener interface {
	Leave()
	Event() <-chan IEvent
}

type InitEvent map[string]map[string][]byte