eventbus

package
v2.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 10, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Close

func Close() error

Close 关闭事件总线

func Publish

func Publish(ctx context.Context, topic string, message any) error

Publish 发布事件

func SetEventbus

func SetEventbus(eb Eventbus)

SetEventbus 设置事件总线

func Subscribe

func Subscribe(ctx context.Context, topic string, handler EventHandler) error

Subscribe 订阅事件

func Unsubscribe

func Unsubscribe(ctx context.Context, topic string, handler EventHandler) error

Unsubscribe 取消订阅

Types

type Event

type Event = internal.Event

type EventHandler

type EventHandler = internal.EventHandler

type Eventbus

type Eventbus interface {
	// Close 关闭事件总线
	Close() error
	// Publish 发布事件
	Publish(ctx context.Context, topic string, message any) error
	// Subscribe 订阅事件
	Subscribe(ctx context.Context, topic string, handler EventHandler) error
	// Unsubscribe 取消订阅
	Unsubscribe(ctx context.Context, topic string, handler EventHandler) error
}

func GetEventbus

func GetEventbus() Eventbus

GetEventbus 获取事件总线

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL