Documentation ¶
Index ¶
- type Topic
- func (t *Topic) RegisterCallback(id ulid.ULID, callback func(data interface{}))
- func (t *Topic) RegisterChannel(id ulid.ULID, channel chan interface{})
- func (t *Topic) Send(data interface{})
- func (t *Topic) SendExcept(data interface{}, filterOutIDs map[ulid.ULID]bool)
- func (t *Topic) SendTo(data interface{}, sendToIDs map[ulid.ULID]bool)
- func (t *Topic) UnregisterCallback(id ulid.ULID)
- func (t *Topic) UnregisterChannel(id ulid.ULID)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Topic ¶
type Topic struct { Callbacks map[ulid.ULID]func(interface{}) CallbacksMux *sync.RWMutex Channels map[ulid.ULID]chan interface{} ChannelsMux *sync.RWMutex }
func (*Topic) RegisterCallback ¶
func (*Topic) RegisterChannel ¶
func (*Topic) SendExcept ¶
func (*Topic) UnregisterCallback ¶
func (*Topic) UnregisterChannel ¶
Click to show internal directories.
Click to hide internal directories.