publisher

Documentation

Index

• func IsEnabled() bool
• func Module() fx.Option
• func NewEventPublisher(events *provider.EventWrapperProvider) cloudevents.Middleware
• type EventPublisher
  • func (p *EventPublisher) AfterAll(ctx context.Context, inouts []*cloudevents.InOut) (context.Context, error)

Functions

func IsEnabled

func IsEnabled() bool

func Module

func Module() fx.Option

func NewEventPublisher

func NewEventPublisher(events *provider.EventWrapperProvider) cloudevents.Middleware

Types

type EventPublisher

type EventPublisher struct {
	cloudevents.UnimplementedMiddleware
	// contains filtered or unexported fields
}

func (*EventPublisher) AfterAll

func (p *EventPublisher) AfterAll(ctx context.Context, inouts []*cloudevents.InOut) (context.Context, error)