Documentation ¶
Index ¶
- type Config
- type EventEmitter
- func (c *EventEmitter[T]) CountSubscriberByTopic(topic string) int
- func (c *EventEmitter[T]) GetTopicsBySubscriber(suber T) []string
- func (c *EventEmitter[T]) NewSubscriber() Subscriber[any]
- func (c *EventEmitter[T]) Publish(topic string, msg any)
- func (c *EventEmitter[T]) Subscribe(suber T, topic string, f func(subscriber T, msg any))
- func (c *EventEmitter[T]) UnSubscribe(suber T, topic string)
- func (c *EventEmitter[T]) UnSubscribeAll(suber T)
- type Int64Subscriber
- type Metadata
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventEmitter ¶
type EventEmitter[T Subscriber[T]] struct { // contains filtered or unexported fields }
func New ¶
func New[T Subscriber[T]](conf *Config) *EventEmitter[T]
New 创建事件发射器实例 Creating an EventEmitter Instance
func (*EventEmitter[T]) CountSubscriberByTopic ¶
func (c *EventEmitter[T]) CountSubscriberByTopic(topic string) int
CountSubscriberByTopic 获取主题订阅人数 Get the number of subscribers to a topic
func (*EventEmitter[T]) GetTopicsBySubscriber ¶ added in v0.1.0
func (c *EventEmitter[T]) GetTopicsBySubscriber(suber T) []string
GetTopicsBySubscriber 通过订阅者获取主题列表 Get a list of topics by subscriber
func (*EventEmitter[T]) NewSubscriber ¶
func (c *EventEmitter[T]) NewSubscriber() Subscriber[any]
NewSubscriber 生成订阅ID. 也可以使用自己的ID, 保证唯一即可. Generate a subscription ID. You can also use your own ID, just make sure it's unique.
func (*EventEmitter[T]) Publish ¶
func (c *EventEmitter[T]) Publish(topic string, msg any)
Publish 向主题发布消息 Publish a message to the topic
func (*EventEmitter[T]) Subscribe ¶
func (c *EventEmitter[T]) Subscribe(suber T, topic string, f func(subscriber T, msg any))
Subscribe 订阅主题消息. 注意: 回调函数必须是非阻塞的. Subscribe messages from the topic. Note: Callback functions must be non-blocking.
func (*EventEmitter[T]) UnSubscribe ¶
func (c *EventEmitter[T]) UnSubscribe(suber T, topic string)
UnSubscribe 取消订阅一个主题 Cancel a subscribed topic
func (*EventEmitter[T]) UnSubscribeAll ¶
func (c *EventEmitter[T]) UnSubscribeAll(suber T)
UnSubscribeAll 取消订阅所有主题 Cancel all subscribed topics
type Int64Subscriber ¶ added in v0.1.0
type Int64Subscriber struct {
// contains filtered or unexported fields
}
func (*Int64Subscriber) GetMetadata ¶ added in v0.2.0
func (c *Int64Subscriber) GetMetadata() Metadata
func (*Int64Subscriber) GetSubscriberID ¶ added in v0.1.0
func (c *Int64Subscriber) GetSubscriberID() int64
type Subscriber ¶ added in v0.1.0
Click to show internal directories.
Click to hide internal directories.