xevent

Documentation

Index

• func Register[Event any](registry Registry, name string, factory func() Event)
• type DefaultPayloadFactoryRegistry
  • func NewPayloadRegistry() *DefaultPayloadFactoryRegistry
  • func (r *DefaultPayloadFactoryRegistry) GetFactory(eventType string) (func() interface{}, error)
  • func (r *DefaultPayloadFactoryRegistry) Register(eventType string, factory func() interface{})
• type Registry

Functions

func Register

func Register[Event any](registry Registry, name string, factory func() Event)

Register registers a payload factory function for the given event type.

Types

type DefaultPayloadFactoryRegistry

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

DefaultPayloadFactoryRegistry is the default implementation of PayloadFactoryRegistry.

func NewPayloadRegistry

func NewPayloadRegistry() *DefaultPayloadFactoryRegistry

NewPayloadRegistry creates a new instance of DefaultPayloadFactoryRegistry.

func (*DefaultPayloadFactoryRegistry) GetFactory

func (r *DefaultPayloadFactoryRegistry) GetFactory(eventType string) (func() interface{}, error)

GetFactory retrieves the payload factory function for the given event type.

func (*DefaultPayloadFactoryRegistry) Register

func (r *DefaultPayloadFactoryRegistry) Register(eventType string, factory func() interface{})

Register adds a payload factory function for the given event type.

type Registry

type Registry interface {
	Register(eventType string, factory func() interface{})
	GetFactory(eventType string) (func() interface{}, error)
}

Registry defines the interface for registering and retrieving payload factories.