Versions in this module Expand all Collapse all v1 v1.0.1 Jan 18, 2024 v1.0.0 Jan 10, 2024 Changes in this version + const DefaultEventQueueSize + const DefaultPublishAuditEvents + const EnvKeyEventQueueSize + const EnvKeyPublishAuditEvents + func GetEventQueueSize() int + func HasListener(eventType string) bool + func Post(eventType string, event interface{}) + func PublishEventEnabled() bool + func RegisterListener(name string, listener Listener, eventTypes []string) error + func UnRegisterListener(name string, eventTypes []string) + type Context struct + func (ec *Context) GetEvent() interface{} + func (ec *Context) GetEventType() string + type Emitter struct + func (te *Emitter) HasListeners() bool + func (te *Emitter) Publish(evtCtx *Context) + func (te *Emitter) RegisterListener(name string, listener Listener) error + func (te *Emitter) UnRegisterListener(name string) error + type Listener interface + HandleEvent func(*Context) error
Go to main page