eventbus

package

v1.0.0 Latest Latest Go to latest Published: Jun 21, 2025 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Package eventbus package eventbus

This section is empty.

This section is empty.

This section is empty.

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

Bus Bus.

func Get(route ...string) *Bus

Get if route is empty, return singleton.

func (c *Bus) PublishTopicEvent(topic string, arg ...interface{})

func (c *Bus) Subscribe(topic string, fn ...interface{})

Subscribe -.

func (c *Bus) SubscribeAsync(topic string, transactional bool, fn ...interface{})

SubscribeAsync Transactional determines whether subsequent callbacks for a topic are run serially (true) or concurrently (false).

func (c *Bus) UnSubscribe(topic string, fn ...interface{})