Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrEventTypeNotFound = errors.New("event type not found")
)
Functions ¶
func RegisterChannelQueue ¶ added in v0.8.0
func RegisterChannelQueue(dp *di.DependencyProvider)
Types ¶
type ChannelQueue ¶
type ChannelQueue struct {
// contains filtered or unexported fields
}
func NewChannelQueue ¶
func NewChannelQueue() *ChannelQueue
func (ChannelQueue) Push ¶
func (q ChannelQueue) Push(e Event) error
type EventLogger ¶ added in v0.5.0
type EventLogger struct { }
func (*EventLogger) Context ¶ added in v0.5.0
func (e *EventLogger) Context(ctx context.Context) context.Context
func (*EventLogger) WithContext ¶ added in v0.5.0
func (e *EventLogger) WithContext(ctx context.Context)
type EventService ¶ added in v0.8.0
type EventService struct { Queue Queue `inject:""` Logger *slog.Logger `inject:""` DP *di.DependencyProvider `inject:""` // contains filtered or unexported fields }
func Service ¶ added in v0.8.0
func Service(listeners ...*Listener) *EventService
func (*EventService) Name ¶ added in v0.8.0
func (s *EventService) Name() string
type Listener ¶ added in v0.8.0
type Listener struct {
// contains filtered or unexported fields
}
func NewListener ¶ added in v0.8.0
Click to show internal directories.
Click to hide internal directories.