process

package

v2.6.2 Latest Latest Go to latest Published: Oct 7, 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 stops listening.

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

Publish publishes an event.

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

Subscribe subscribes to an event.