Versions in this module Expand all Collapse all v1 v1.4.1 Mar 1, 2023 Changes in this version + func CacheRemove(ctx context.Context, keys ...interface{}) + func NewSubPub() *subPub + func ProcessMetricMsg(sub *rpc.Subscription, metrics []prometheus.Metric) (send bool, out map[string]interface{}) + type INotifier interface + Err func() <-chan error + Notify func(key string, data interface{}) error + type Notifier struct + func NewNotifier(n *rpc.Notifier, sub *rpc.Subscription) *Notifier + func (n *Notifier) Err() <-chan error + func (n *Notifier) Notify(_ string, data interface{}) error + type NotifierWithDelay struct + func NewNotifierWithDelay(notifier *rpc.Notifier, sub *rpc.Subscription, delay int, sendArray bool) *NotifierWithDelay + func (n *NotifierWithDelay) Err() <-chan error + func (n *NotifierWithDelay) Notify(key string, data interface{}) error + type NotifierWithMsgChan struct + ErrChan chan error + MsgChan chan interface{} + func NewNotifierWithMsgChan() *NotifierWithMsgChan + func (n *NotifierWithMsgChan) Err() <-chan error + func (n *NotifierWithMsgChan) Notify(_ string, data interface{}) error + type SubPub interface + Publish func(nameSpace string, kind string, param string, message interface{}) error + PublishArray func(nameSpace string, kind string, field string, messageList []interface{}) error + Subscribe func(iNotifier INotifier, nameSpace string, kind string, param string) error
Go to main page