Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventLabel ¶
type EventLabel string
type PublisherLabel ¶
type PublisherLabel string
type SubscriberLabel ¶
type SubscriberLabel string
type SupbInformer ¶
type SupbInformer struct {
SubscribeTable map[EventLabel]map[SubscriberLabel]chan interface{}
// contains filtered or unexported fields
}
func NewInformer ¶
func NewInformer(ctx context.Context, prefix string) *SupbInformer
func (*SupbInformer) Publish ¶
func (r *SupbInformer) Publish(label SubscriberLabel, event EventLabel, data interface{})
func (*SupbInformer) Subscribe ¶
func (r *SupbInformer) Subscribe(label SubscriberLabel, event EventLabel) <-chan interface{}
func (*SupbInformer) UnSubscribe ¶
func (r *SupbInformer) UnSubscribe(label SubscriberLabel, event EventLabel)
Source Files
Click to show internal directories.
Click to hide internal directories.