var ErrEventNotFound = errors.New("event not found")	// ErrEventNotFound indicates an event was not found in the store

var ErrInvalidEvent = errors.New("invalid event")	// ErrInvalidEvent indicates an event failed validation

var ErrListenerNotFound = errors.New("listener not found")	// ErrListenerNotFound indicates a listener was not found

var ErrTopicNotFound = errors.New("topic not found")	// ErrTopicNotFound indicates a topic was not found

var ErrSubscriptionNotFound = errors.New("subscription not found")	// ErrSubscriptionNotFound indicates a subscription was not found

var ErrEmitterClosed = errors.New("emitter is closed")	// ErrEmitterClosed indicates the emitter has been closed

var ErrBusClosed = errors.New("bus is closed")	// ErrBusClosed indicates the bus has been closed

var ErrStoreReadOnly = errors.New("store is read-only")	// ErrStoreReadOnly indicates the store is in read-only mode

var ErrBufferFull = errors.New("buffer is full")	// ErrBufferFull indicates a buffer is full and cannot accept more events

var ErrRetryLimitExceeded = errors.New("retry limit exceeded")	// ErrRetryLimitExceeded indicates retry attempts have been exhausted

var ErrTimeout = errors.New("operation timed out")	// ErrTimeout indicates an operation timed out

var DefaultEventValidator = EventValidatorFunc(func(event Event) error {
	if event == nil {
		return NewValidationError("event", nil, "event cannot be nil")
	}
	if event.ID() == "" {
		return NewValidationError("id", event.ID(), "event ID cannot be empty")
	}
	if event.Type() == "" {
		return NewValidationError("type", event.Type(), "event type cannot be empty")
	}
	if event.Timestamp().IsZero() {
		return NewValidationError("timestamp", event.Timestamp(), "event timestamp cannot be zero")
	}
	return nil
})

// Create a new BaseEvent
baseevent := BaseEvent{

}

type BaseEvent struct {
}

func NewBaseEvent(id, eventType string, data any) *BaseEvent

func NewBaseEventWithMetadata(id, eventType string, data any, metadata map[string]string) *BaseEvent

func (*BaseEvent) Data() any

func (*BaseEvent) GetMetadata(key string) (string, bool)

func (*BaseListener) ID() string

func (*BaseEvent) Metadata() map[string]string

func (*BaseEvent) SetMetadata(key, value string)

func (*BaseEvent) Timestamp() time.Time

func (*BaseEvent) Type() string

// Create a new BaseListener
baselistener := BaseListener{

}

type BaseListener struct {
}

func NewBaseListener(id string, handler func(event Event) error) *BaseListener

func NewBaseListenerWithErrorHandler(id string, handler func(event Event) error, errorHandler func(event Event, err error) error) *BaseListener

func (*BaseListener) Handle(event Event) error

func (*BaseListener) ID() string

func (*BaseListener) OnError(event Event, err error) error

// Create a new BaseSubscription
basesubscription := BaseSubscription{

}

type BaseSubscription struct {
}

func NewBaseSubscription(id, topic string, listener Listener) *BaseSubscription

func NewBaseSubscriptionWithCallback(id, topic string, listener Listener, onClose func()) *BaseSubscription

func (*BaseSubscription) Active() bool

func (*BaseEvent) ID() string

func (*BaseSubscription) Listener() Listener

func (*BaseSubscription) Topic() string

func (*BaseSubscription) Unsubscribe() error

// Example implementation of Event
type MyEvent struct {
    // Add your fields here
}

func (m MyEvent) ID() string {
    // Implement your logic here
    return
}

func (m MyEvent) Type() string {
    // Implement your logic here
    return
}

func (m MyEvent) Timestamp() time.Time {
    // Implement your logic here
    return
}

func (m MyEvent) Data() any {
    // Implement your logic here
    return
}

func (m MyEvent) Metadata() map[string]string {
    // Implement your logic here
    return
}

type Event interface {
    ID() string
    Type() string
    Timestamp() time.Time
    Data() any
    Metadata() map[string]string
}

// Create a new EventError
eventerror := EventError{
    Event: Event{},
    Err: error{},
}

type EventError struct {
    Event Event
    Err error
}

func NewEventError(event Event, err error) *EventError

func (*ValidationError) Error() string

func (*ListenerError) Unwrap() error

// Example implementation of EventValidator
type MyEventValidator struct {
    // Add your fields here
}

func (m MyEventValidator) Validate(param1 Event) error {
    // Implement your logic here
    return
}

type EventValidator interface {
    Validate(event Event) error
}

// Example usage of EventValidatorFunc
var value EventValidatorFunc
// Initialize with appropriate value

type EventValidatorFunc func(event Event) error

func (EventValidatorFunc) Validate(event Event) error

// Example implementation of Listener
type MyListener struct {
    // Add your fields here
}

func (m MyListener) ID() string {
    // Implement your logic here
    return
}

func (m MyListener) Handle(param1 Event) error {
    // Implement your logic here
    return
}

func (m MyListener) OnError(param1 Event, param2 error) error {
    // Implement your logic here
    return
}

type Listener interface {
    ID() string
    Handle(event Event) error
    OnError(event Event, err error) error
}

// Create a new ListenerError
listenererror := ListenerError{
    ListenerID: "example",
    Event: Event{},
    Err: error{},
}

type ListenerError struct {
    ListenerID string
    Event Event
    Err error
}

func NewListenerError(listenerID string, event Event, err error) *ListenerError

func (*ValidationError) Error() string

func (*ListenerError) Unwrap() error

// Example implementation of MetricsCollector
type MyMetricsCollector struct {
    // Add your fields here
}

func (m MyMetricsCollector) IncEventsEmitted(param1 string, param2 string)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) IncEventsProcessed(param1 string, param2 string)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) ObserveListenerDuration(param1 string, param2 time.Duration)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) ObserveSagaDuration(param1 string, param2 string, param3 time.Duration)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) ObserveStoreAppendDuration(param1 time.Duration)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) ObserveStoreReadDuration(param1 time.Duration)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) SetQueueSize(param1 string, param2 int)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) SetActiveListeners(param1 string, param2 int)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) IncEventsDropped(param1 string, param2 string)  {
    // Implement your logic here
    return
}

type MetricsCollector interface {
    IncEventsEmitted(eventType string, result string)
    IncEventsProcessed(listenerID string, result string)
    ObserveListenerDuration(listenerID string, duration time.Duration)
    ObserveSagaDuration(sagaID string, step string, duration time.Duration)
    ObserveStoreAppendDuration(duration time.Duration)
    ObserveStoreReadDuration(duration time.Duration)
    SetQueueSize(component string, size int)
    SetActiveListeners(emitterID string, count int)
    IncEventsDropped(component string, reason string)
}

// Example implementation of Middleware
type MyMiddleware struct {
    // Add your fields here
}

func (m MyMiddleware) Before(param1 Event) error {
    // Implement your logic here
    return
}

func (m MyMiddleware) After(param1 Event, param2 error) error {
    // Implement your logic here
    return
}

type Middleware interface {
    Before(event Event) error
    After(event Event, err error) error
}

// Create a new MiddlewareFunc
middlewarefunc := MiddlewareFunc{
    BeforeFunc: /* value */,
    AfterFunc: /* value */,
}

type MiddlewareFunc struct {
    BeforeFunc func(event Event) error
    AfterFunc func(event Event, err error) error
}

func (MiddlewareFunc) After(event Event, err error) error

func (MiddlewareFunc) Before(event Event) error

// Create a new NoOpMetricsCollector
noopmetricscollector := NoOpMetricsCollector{

}

type NoOpMetricsCollector struct {
}

func (*SimpleMetricsCollector) IncEventsDropped(component string, reason string)

func (*SimpleMetricsCollector) IncEventsEmitted(eventType string, result string)

func (*SimpleMetricsCollector) IncEventsProcessed(listenerID string, result string)

func (*SimpleMetricsCollector) ObserveListenerDuration(listenerID string, duration time.Duration)

func (*SimpleMetricsCollector) ObserveSagaDuration(sagaID string, step string, duration time.Duration)

func (*SimpleMetricsCollector) ObserveStoreAppendDuration(duration time.Duration)

func (*SimpleMetricsCollector) ObserveStoreReadDuration(duration time.Duration)

func (*SimpleMetricsCollector) SetActiveListeners(emitterID string, count int)

func (*SimpleMetricsCollector) SetQueueSize(component string, size int)

// Create a new SimpleMetricsCollector
simplemetricscollector := SimpleMetricsCollector{
    EventsEmitted: 42,
    EventsProcessed: 42,
    EventsDropped: 42,
    ListenerDurations: 42,
    SagaDurations: 42,
    StoreAppends: 42,
    StoreReads: 42,
    QueueSizes: map[],
    ActiveListeners: map[],
}

type SimpleMetricsCollector struct {
    EventsEmitted int64
    EventsProcessed int64
    EventsDropped int64
    ListenerDurations int64
    SagaDurations int64
    StoreAppends int64
    StoreReads int64
    QueueSizes map[string]int64
    ActiveListeners map[string]int64
}

func NewSimpleMetricsCollector() *SimpleMetricsCollector

func (*SimpleMetricsCollector) GetEventsDropped() int64

func (*SimpleMetricsCollector) GetEventsEmitted() int64

func (*SimpleMetricsCollector) GetEventsProcessed() int64

func (*SimpleMetricsCollector) IncEventsDropped(component string, reason string)

func (*SimpleMetricsCollector) IncEventsEmitted(eventType string, result string)

func (*SimpleMetricsCollector) IncEventsProcessed(listenerID string, result string)

func (*SimpleMetricsCollector) ObserveListenerDuration(listenerID string, duration time.Duration)

func (*SimpleMetricsCollector) ObserveSagaDuration(sagaID string, step string, duration time.Duration)

func (*SimpleMetricsCollector) ObserveStoreAppendDuration(duration time.Duration)

func (*SimpleMetricsCollector) ObserveStoreReadDuration(duration time.Duration)

func (*SimpleMetricsCollector) SetActiveListeners(emitterID string, count int)

func (*SimpleMetricsCollector) SetQueueSize(component string, size int)

// Example implementation of Subscription
type MySubscription struct {
    // Add your fields here
}

func (m MySubscription) ID() string {
    // Implement your logic here
    return
}

func (m MySubscription) Topic() string {
    // Implement your logic here
    return
}

func (m MySubscription) Listener() Listener {
    // Implement your logic here
    return
}

func (m MySubscription) Unsubscribe() error {
    // Implement your logic here
    return
}

func (m MySubscription) Active() bool {
    // Implement your logic here
    return
}

type Subscription interface {
    ID() string
    Topic() string
    Listener() Listener
    Unsubscribe() error
    Active() bool
}

// Create a new ValidationError
validationerror := ValidationError{
    Field: "example",
    Value: any{},
    Message: "example",
}

type ValidationError struct {
    Field string
    Value any
    Message string
}

func NewValidationError(field string, value any, message string) *ValidationError

func (*ValidationError) Error() string

var ErrEventNotFound = errors.New("event not found")	// ErrEventNotFound indicates an event was not found in the store

var ErrInvalidEvent = errors.New("invalid event")	// ErrInvalidEvent indicates an event failed validation

var ErrListenerNotFound = errors.New("listener not found")	// ErrListenerNotFound indicates a listener was not found

var ErrTopicNotFound = errors.New("topic not found")	// ErrTopicNotFound indicates a topic was not found

var ErrSubscriptionNotFound = errors.New("subscription not found")	// ErrSubscriptionNotFound indicates a subscription was not found

var ErrEmitterClosed = errors.New("emitter is closed")	// ErrEmitterClosed indicates the emitter has been closed

var ErrBusClosed = errors.New("bus is closed")	// ErrBusClosed indicates the bus has been closed

var ErrStoreReadOnly = errors.New("store is read-only")	// ErrStoreReadOnly indicates the store is in read-only mode

var ErrBufferFull = errors.New("buffer is full")	// ErrBufferFull indicates a buffer is full and cannot accept more events

var ErrRetryLimitExceeded = errors.New("retry limit exceeded")	// ErrRetryLimitExceeded indicates retry attempts have been exhausted

var ErrTimeout = errors.New("operation timed out")	// ErrTimeout indicates an operation timed out

var DefaultEventValidator = EventValidatorFunc(func(event Event) error {
	if event == nil {
		return NewValidationError("event", nil, "event cannot be nil")
	}
	if event.ID() == "" {
		return NewValidationError("id", event.ID(), "event ID cannot be empty")
	}
	if event.Type() == "" {
		return NewValidationError("type", event.Type(), "event type cannot be empty")
	}
	if event.Timestamp().IsZero() {
		return NewValidationError("timestamp", event.Timestamp(), "event timestamp cannot be zero")
	}
	return nil
})

// Create a new BaseEvent
baseevent := BaseEvent{

}

type BaseEvent struct {
}

func NewBaseEvent(id, eventType string, data any) *BaseEvent

func NewBaseEventWithMetadata(id, eventType string, data any, metadata map[string]string) *BaseEvent

func (*BaseEvent) Data() any

func (*BaseEvent) GetMetadata(key string) (string, bool)

func (*BaseListener) ID() string

func (*BaseEvent) Metadata() map[string]string

func (*BaseEvent) SetMetadata(key, value string)

func (*BaseEvent) Timestamp() time.Time

func (*BaseEvent) Type() string

// Create a new BaseListener
baselistener := BaseListener{

}

type BaseListener struct {
}

func NewBaseListener(id string, handler func(event Event) error) *BaseListener

func NewBaseListenerWithErrorHandler(id string, handler func(event Event) error, errorHandler func(event Event, err error) error) *BaseListener

func (*BaseListener) Handle(event Event) error

func (*BaseListener) ID() string

func (*BaseListener) OnError(event Event, err error) error

// Create a new BaseSubscription
basesubscription := BaseSubscription{

}

type BaseSubscription struct {
}

func NewBaseSubscription(id, topic string, listener Listener) *BaseSubscription

func NewBaseSubscriptionWithCallback(id, topic string, listener Listener, onClose func()) *BaseSubscription

func (*BaseSubscription) Active() bool

func (*BaseEvent) ID() string

func (*BaseSubscription) Listener() Listener

func (*BaseSubscription) Topic() string

func (*BaseSubscription) Unsubscribe() error

// Example implementation of Event
type MyEvent struct {
    // Add your fields here
}

func (m MyEvent) ID() string {
    // Implement your logic here
    return
}

func (m MyEvent) Type() string {
    // Implement your logic here
    return
}

func (m MyEvent) Timestamp() time.Time {
    // Implement your logic here
    return
}

func (m MyEvent) Data() any {
    // Implement your logic here
    return
}

func (m MyEvent) Metadata() map[string]string {
    // Implement your logic here
    return
}

type Event interface {
    ID() string
    Type() string
    Timestamp() time.Time
    Data() any
    Metadata() map[string]string
}

// Create a new EventError
eventerror := EventError{
    Event: Event{},
    Err: error{},
}

type EventError struct {
    Event Event
    Err error
}

func NewEventError(event Event, err error) *EventError

func (*ValidationError) Error() string

func (*ListenerError) Unwrap() error

// Example implementation of EventValidator
type MyEventValidator struct {
    // Add your fields here
}

func (m MyEventValidator) Validate(param1 Event) error {
    // Implement your logic here
    return
}

type EventValidator interface {
    Validate(event Event) error
}

// Example usage of EventValidatorFunc
var value EventValidatorFunc
// Initialize with appropriate value

type EventValidatorFunc func(event Event) error

func (EventValidatorFunc) Validate(event Event) error

// Example implementation of Listener
type MyListener struct {
    // Add your fields here
}

func (m MyListener) ID() string {
    // Implement your logic here
    return
}

func (m MyListener) Handle(param1 Event) error {
    // Implement your logic here
    return
}

func (m MyListener) OnError(param1 Event, param2 error) error {
    // Implement your logic here
    return
}

type Listener interface {
    ID() string
    Handle(event Event) error
    OnError(event Event, err error) error
}

// Create a new ListenerError
listenererror := ListenerError{
    ListenerID: "example",
    Event: Event{},
    Err: error{},
}

type ListenerError struct {
    ListenerID string
    Event Event
    Err error
}

func NewListenerError(listenerID string, event Event, err error) *ListenerError

func (*ValidationError) Error() string

func (*ListenerError) Unwrap() error

// Example implementation of MetricsCollector
type MyMetricsCollector struct {
    // Add your fields here
}

func (m MyMetricsCollector) IncEventsEmitted(param1 string, param2 string)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) IncEventsProcessed(param1 string, param2 string)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) ObserveListenerDuration(param1 string, param2 time.Duration)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) ObserveSagaDuration(param1 string, param2 string, param3 time.Duration)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) ObserveStoreAppendDuration(param1 time.Duration)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) ObserveStoreReadDuration(param1 time.Duration)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) SetQueueSize(param1 string, param2 int)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) SetActiveListeners(param1 string, param2 int)  {
    // Implement your logic here
    return
}

func (m MyMetricsCollector) IncEventsDropped(param1 string, param2 string)  {
    // Implement your logic here
    return
}

type MetricsCollector interface {
    IncEventsEmitted(eventType string, result string)
    IncEventsProcessed(listenerID string, result string)
    ObserveListenerDuration(listenerID string, duration time.Duration)
    ObserveSagaDuration(sagaID string, step string, duration time.Duration)
    ObserveStoreAppendDuration(duration time.Duration)
    ObserveStoreReadDuration(duration time.Duration)
    SetQueueSize(component string, size int)
    SetActiveListeners(emitterID string, count int)
    IncEventsDropped(component string, reason string)
}

// Example implementation of Middleware
type MyMiddleware struct {
    // Add your fields here
}

func (m MyMiddleware) Before(param1 Event) error {
    // Implement your logic here
    return
}

func (m MyMiddleware) After(param1 Event, param2 error) error {
    // Implement your logic here
    return
}

type Middleware interface {
    Before(event Event) error
    After(event Event, err error) error
}

// Create a new MiddlewareFunc
middlewarefunc := MiddlewareFunc{
    BeforeFunc: /* value */,
    AfterFunc: /* value */,
}

type MiddlewareFunc struct {
    BeforeFunc func(event Event) error
    AfterFunc func(event Event, err error) error
}

func (MiddlewareFunc) After(event Event, err error) error

func (MiddlewareFunc) Before(event Event) error

// Create a new NoOpMetricsCollector
noopmetricscollector := NoOpMetricsCollector{

}

type NoOpMetricsCollector struct {
}

func (*SimpleMetricsCollector) IncEventsDropped(component string, reason string)

func (*SimpleMetricsCollector) IncEventsEmitted(eventType string, result string)

func (*SimpleMetricsCollector) IncEventsProcessed(listenerID string, result string)

func (*SimpleMetricsCollector) ObserveListenerDuration(listenerID string, duration time.Duration)

func (*SimpleMetricsCollector) ObserveSagaDuration(sagaID string, step string, duration time.Duration)

func (*SimpleMetricsCollector) ObserveStoreAppendDuration(duration time.Duration)

func (*SimpleMetricsCollector) ObserveStoreReadDuration(duration time.Duration)

func (*SimpleMetricsCollector) SetActiveListeners(emitterID string, count int)

func (*SimpleMetricsCollector) SetQueueSize(component string, size int)

// Create a new SimpleMetricsCollector
simplemetricscollector := SimpleMetricsCollector{
    EventsEmitted: 42,
    EventsProcessed: 42,
    EventsDropped: 42,
    ListenerDurations: 42,
    SagaDurations: 42,
    StoreAppends: 42,
    StoreReads: 42,
    QueueSizes: map[],
    ActiveListeners: map[],
}

type SimpleMetricsCollector struct {
    EventsEmitted int64
    EventsProcessed int64
    EventsDropped int64
    ListenerDurations int64
    SagaDurations int64
    StoreAppends int64
    StoreReads int64
    QueueSizes map[string]int64
    ActiveListeners map[string]int64
}

func NewSimpleMetricsCollector() *SimpleMetricsCollector

func (*SimpleMetricsCollector) GetEventsDropped() int64

func (*SimpleMetricsCollector) GetEventsEmitted() int64

func (*SimpleMetricsCollector) GetEventsProcessed() int64

func (*SimpleMetricsCollector) IncEventsDropped(component string, reason string)

func (*SimpleMetricsCollector) IncEventsEmitted(eventType string, result string)

func (*SimpleMetricsCollector) IncEventsProcessed(listenerID string, result string)

func (*SimpleMetricsCollector) ObserveListenerDuration(listenerID string, duration time.Duration)

func (*SimpleMetricsCollector) ObserveSagaDuration(sagaID string, step string, duration time.Duration)

func (*SimpleMetricsCollector) ObserveStoreAppendDuration(duration time.Duration)

func (*SimpleMetricsCollector) ObserveStoreReadDuration(duration time.Duration)

func (*SimpleMetricsCollector) SetActiveListeners(emitterID string, count int)

func (*SimpleMetricsCollector) SetQueueSize(component string, size int)

// Example implementation of Subscription
type MySubscription struct {
    // Add your fields here
}

func (m MySubscription) ID() string {
    // Implement your logic here
    return
}

func (m MySubscription) Topic() string {
    // Implement your logic here
    return
}

func (m MySubscription) Listener() Listener {
    // Implement your logic here
    return
}

func (m MySubscription) Unsubscribe() error {
    // Implement your logic here
    return
}

func (m MySubscription) Active() bool {
    // Implement your logic here
    return
}

type Subscription interface {
    ID() string
    Topic() string
    Listener() Listener
    Unsubscribe() error
    Active() bool
}

// Create a new ValidationError
validationerror := ValidationError{
    Field: "example",
    Value: any{},
    Message: "example",
}

type ValidationError struct {
    Field string
    Value any
    Message string
}

func NewValidationError(field string, value any, message string) *ValidationError

func (*ValidationError) Error() string