micro/bus/global.go

package bus

import "context"

var (
	Default Bus
)

func init() {
	Default = NewInPrcBus(context.Background())
}

func SetGlobal(bus Bus) {
	Default = bus
}

func GetGlobal() Bus {
	return Default
}

func Publish(e *Event) {
	Default.Publish(e)
}

func Dispatch(e *Event) (err error) {
	return Default.Dispatch(e)
}

func DispatchCtx(ctx context.Context, e *Event) (err error) {
	return Default.DispatchCtx(ctx, e)
}

func Subscribe(sub Subscriber) (err error) {
	return Default.Subscribe(sub)
}

func UnSubscribe(sub Subscriber) (err error) {
	return Default.UnSubscribe(sub)
}