subscribe

type INotifier interface {
	Notify(key string, data interface{}) error
	Err() <-chan error
}

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

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

type NotifierWithMsgChan struct {
	MsgChan chan interface{} // msg will be sent to this chan
	ErrChan chan error       // close this chan if you want to unsubscribe
}

type SubPub interface {
	// Subscribe a subscription,creates a mapping from nameSpace_kind_param to INotifier
	Subscribe(iNotifier INotifier, nameSpace string, kind string, param string) error
	// Publish finds the notifier corresponding to the key nameSpace_kind_param, and then calls the Notify method of
	// notify to publish message
	Publish(nameSpace string, kind string, param string, message interface{}) error
	// PublishArray finds the notifier corresponding to the key nameSpace_kind_param, and then calls the Notify method of
	// notify to publish a group of message
	PublishArray(nameSpace string, kind string, field string, messageList []interface{}) error
}