Versions in this module Expand all Collapse all v0 v0.19.4 May 24, 2023 Changes in this version + type Event struct + Data interface{} + ID string + Name string + Retry time.Duration + func (e *Event) String() string + func (e *Event) WriteTo(w io.Writer) (int64, error) + type Manager struct + func GetManager() *Manager + func (m *Manager) Init() + func (m *Manager) Register(uid int64) <-chan *Event + func (m *Manager) Run(ctx context.Context) + func (m *Manager) SendMessage(uid int64, message *Event) + func (m *Manager) SendMessageBlocking(uid int64, message *Event) + func (m *Manager) Unregister(uid int64, channel <-chan *Event) + func (m *Manager) UnregisterAll() + type Messenger struct + func NewMessenger(uid int64) *Messenger + func (m *Messenger) Register() <-chan *Event + func (m *Messenger) SendMessage(message *Event) + func (m *Messenger) SendMessageBlocking(message *Event) + func (m *Messenger) Unregister(channel <-chan *Event) bool + func (m *Messenger) UnregisterAll()
Go to main page