event

package

v0.1.13 Latest Latest Go to latest Published: Jul 4, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Dispatcher handles event publishing and subscription

func NewEventDispatcher() *Dispatcher

NewEventDispatcher creates a new event dispatcher

func (d *Dispatcher) GetMetrics() map[string]any

GetMetrics returns comprehensive metrics

func (d *Dispatcher) Publish(eventName string, data any)

Publish sends event to all subscribers

func (d *Dispatcher) PublishWithRetry(eventName string, data any, maxRetries int)

PublishWithRetry publishes event with retry

func (d *Dispatcher) Subscribe(eventName string, handler func(any))

Subscribe adds a handler for specific event