event

package

v0.1.2 Latest Latest Go to latest Published: May 15, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

EventBus represents a simple event bus for inter-extension communication

func NewEventBus() *EventBus

NewEventBus creates a new EventBus

func (eb *EventBus) GetMetrics() map[string]any

GetMetrics returns metrics

func (eb *EventBus) Publish(eventName string, data any)

Publish sends an event to all subscribers

func (eb *EventBus) PublishWithRetry(eventName string, data any, maxRetries int)

PublishWithRetry retry publish event

func (eb *EventBus) Subscribe(eventName string, handler func(any))

Subscribe adds a subscriber for a specific event