Documentation
¶
Index ¶
- type Manager
- type Memory
- func (m *Memory) HandleCount(topic string) int
- func (m *Memory) Publish(ctx context.Context, topic string, msg *eventbus.Message) (err error)
- func (m *Memory) Subscribe(ctx context.Context, topic string, handle eventbus.SubscribeHandler) (err error)
- func (m *Memory) SubscribeOnce(ctx context.Context, topic string, handle eventbus.SubscribeHandler) (err error)
- func (m *Memory) Unsubscribe(ctx context.Context, topic string, handle eventbus.SubscribeHandler) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
Handles []eventbus.SubscribeHandler
HandlesOnce []eventbus.SubscribeHandler
// contains filtered or unexported fields
}
func NewManager ¶
func NewManager() *Manager
func (*Manager) SubscribeOnce ¶
func (e *Manager) SubscribeOnce(handle eventbus.SubscribeHandler)
func (*Manager) Unsubscribe ¶
func (e *Manager) Unsubscribe(handle eventbus.SubscribeHandler)
type Memory ¶
type Memory struct {
// contains filtered or unexported fields
}
func NewEventBusByMemory ¶
func NewEventBusByMemory() *Memory
func (*Memory) HandleCount ¶
func (*Memory) SubscribeOnce ¶
Source Files
Click to show internal directories.
Click to hide internal directories.