process

package

v2.6.0 Latest Latest Go to latest Published: Sep 29, 2026 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Eventbus struct {
	// contains filtered or unexported fields
}

func NewEventbus() *Eventbus

func (eb *Eventbus) Close() error

Close 停止监听

func (eb *Eventbus) Publish(ctx context.Context, topic string, payload any) error

Publish 发布事件

func (eb *Eventbus) Subscribe(ctx context.Context, topic string, handler eventbus.EventHandler, balance ...bool) (eventbus.Subscription, error)

Subscribe 订阅事件