Versions in this module Expand all Collapse all v1 v1.0.0 Jun 15, 2026 Changes in this version + type InMemoryEventBus struct + func NewInMemoryEventBus() *InMemoryEventBus + func (bus *InMemoryEventBus) Publish(event pullrequest.Event) error + func (bus *InMemoryEventBus) Subscribe(eventType string, handler port.EventHandler) + type NotificationAggregator struct + func NewNotificationAggregator(flushInterval time.Duration, ...) *NotificationAggregator + func (a *NotificationAggregator) AddEvent(event pullrequest.Event) + func (a *NotificationAggregator) Flush() + func (a *NotificationAggregator) Stop() + func (a *NotificationAggregator) UpdateIgnoreConfig(cfg *pullrequest.IgnoreConfig) + type NotificationEventHandler struct + func NewNotificationEventHandler(notificationPort port.NotificationPort, authenticatedUser string) *NotificationEventHandler + func (h *NotificationEventHandler) Flush() + func (h *NotificationEventHandler) Handle(ctx context.Context, event pullrequest.Event) error + func (h *NotificationEventHandler) Stop() + func (h *NotificationEventHandler) UpdateIgnoreConfig(cfg *pullrequest.IgnoreConfig) + type TrackingEventHandler struct + func NewTrackingEventHandler(prTrackingRepo pullrequest.PRTrackingRepository) *TrackingEventHandler + func (h *TrackingEventHandler) Handle(ctx context.Context, event pullrequest.Event) error
Go to main page