event

package

v0.3.1 Latest Latest Go to latest Published: Jun 7, 2025 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dysodeng/app

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Bus
- func New(opts ...Option) Bus
type DispatchOption
- func WithQueue() DispatchOption
type Dispatcher
type Listener
type Option
- func WithEventQueue(queuePrefixKey string, queue contract.Consumer, ...) Option

Constants ¶

View Source

const DispatchQueueKey = "event_dispatch"

DispatchQueueKey 事件调度队列key

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Bus ¶

type Bus interface {
	// Register 注册事件监听器
	Register(dispatcher Dispatcher, listeners ...Listener)
	// Dispatch 事件调度
	Dispatch(dispatcher Dispatcher, data map[string]interface{}, opts ...DispatchOption)
}

Bus 事件总线接口

func New ¶

func New(opts ...Option) Bus

New 初始化事件总线

type DispatchOption ¶

type DispatchOption func(*dispatchOption)

func WithQueue ¶

func WithQueue() DispatchOption

type Dispatcher ¶

type Dispatcher string

Dispatcher 事件调度类型

type Listener ¶

type Listener interface {
	Handle(data map[string]interface{})
}

Listener 事件监听器

type Option ¶

type Option func(*bus)

func WithEventQueue ¶

func WithEventQueue(queuePrefixKey string, queue contract.Consumer, queueProducer contract.Producer) Option

Source Files ¶

View all Source files

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