Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Module ¶
Module returns fx module for initialization of event publisher middleware. Which depends on event wrapper provider module.
The module is only loaded once.
func NewEventPublisher ¶
func NewEventPublisher(options *Options, events *provider.EventWrapperProvider) cloudevents.Middleware
NewEventPublisher creates an event publisher middleware.
Types ¶
type EventPublisher ¶
type EventPublisher struct { cloudevents.UnimplementedMiddleware // contains filtered or unexported fields }
EventPublisher represents an event publisher middleware.
func (*EventPublisher) AfterAll ¶
func (p *EventPublisher) AfterAll(ctx context.Context, inouts []*cloudevents.InOut) (context.Context, error)
AfterAll publishes all output events after processing all handlers.
Click to show internal directories.
Click to hide internal directories.