event

type AsyncEventListener struct {
	BaseEventListener
	// contains filtered or unexported fields
}

type AsyncListener interface {
	Listener

	// ShouldProcess 检查是否应该异步处理
	ShouldProcess() bool
}

type AsyncListenerFunc struct {
	ListenerFunc
	// contains filtered or unexported fields
}

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

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

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

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

type Dispatcher interface {
	// Dispatch 分发事件
	Dispatch(event Event) error
	// DispatchAsync 异步分发事件
	DispatchAsync(event Event) error
	// AddListener 添加事件监听器
	AddListener(eventName string, listener Listener) error
	// AddListenerFunc 添加函数形式的事件监听器
	AddListenerFunc(eventName string, listenerFunc func(event Event) error) error
	// RemoveListener 移除事件监听器
	RemoveListener(eventName string, listener Listener) error
	// GetListeners 获取指定事件的所有监听器
	GetListeners(eventName string) []Listener
	// HasListeners 检查事件是否有监听器
	HasListeners(eventName string) bool
}

type Event interface {
	// GetName 获取事件名称
	GetName() string
	// GetTimestamp 获取事件时间戳
	GetTimestamp() time.Time
	// GetPayload 获取事件负载数据
	GetPayload() map[string]interface{}
	// SetPayload 设置事件负载数据
	SetPayload(payload map[string]interface{})
	// GetPayloadValue 获取特定的负载值
	GetPayloadValue(key string) (interface{}, bool)
	// SetPayloadValue 设置特定的负载值
	SetPayloadValue(key string, value interface{})
	// GetContext 获取事件上下文
	GetContext() interface{}
	// SetContext 设置事件上下文
	SetContext(ctx interface{})
	// IsPropagationStopped 事件传播是否已停止
	IsPropagationStopped() bool
	// StopPropagation 停止事件传播
	StopPropagation()
}

type EventDispatcher interface {
	// Dispatch 分发事件
	Dispatch(event Event) error
	// Listen 添加事件监听器
	Listen(eventName string, listener EventListener)
	// HasListeners 检查事件是否有监听器
	HasListeners(eventName string) bool
	// GetListeners 获取指定事件的所有监听器
	GetListeners(eventName string) []EventListener
	// RemoveListener 移除监听器
	RemoveListener(listener EventListener)
}

type EventListener interface {
	// Handle 处理事件
	Handle(event Event) error
	// GetEvents 获取该监听器关注的事件列表
	GetEvents() []string
	// GetPriority 获取监听器优先级
	GetPriority() int
}

type EventMap map[string][]Listener

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

type EventSubscriber interface {
	// Subscribe 返回事件到监听器的映射
	Subscribe() EventMap
}

type Listener interface {
	// Handle 处理事件
	Handle(event Event) error

	// ShouldHandle 检查是否应该处理此事件
	ShouldHandle(event Event) bool
}

type ListenerFunc func(event Event) error

type ListenerManager interface {
	// AddListener 添加监听器
	AddListener(listener EventListener)
	// RemoveListener 移除监听器
	RemoveListener(listener EventListener)
	// GetListeners 获取指定事件的所有监听器
	GetListeners(eventName string) []EventListener
	// HasListeners 检查是否有监听器关注指定事件
	HasListeners(eventName string) bool
}

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

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

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

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