mediatorfx

Documentation

Index

• func AddValidationPipeline(optFns ...func(options *pipelines.Options)) interface{}
• func AsNotificationHandler[TNotification mediator.Notification, ...](f any) []interface{}
• func AsPipelineBehavior(f any) interface{}
• func AsRequestHandler[TRequest mediator.Request[TResponse], TResponse interface{}](f any) []interface{}
• func NewModule() fx.Option
• func NewPublishContainer(param PublisherParams) mediator.PublishContainer
• func NewPublisher(container mediator.PublishContainer) mediator.Publisher
• func NewSendContainer(param SendContainerParams) mediator.SendContainer
• func NewSender(container mediator.SendContainer) mediator.Sender
• type PublisherParams
• type SendContainerParams

Functions

func AddValidationPipeline

func AddValidationPipeline(optFns ...func(options *pipelines.Options)) interface{}

func AsNotificationHandler

func AsNotificationHandler[TNotification mediator.Notification, TNotificationHandler mediator.NotificationHandler[TNotification]](f any) []interface{}

func AsPipelineBehavior

func AsPipelineBehavior(f any) interface{}

func AsRequestHandler

func AsRequestHandler[TRequest mediator.Request[TResponse], TResponse interface{}](f any) []interface{}

func NewModule

func NewModule() fx.Option

NewModule returns a new fx.Option that provides the mediator components A PublishStrategy can be provided by the user, otherwise a synchronous strategy is used

func NewPublishContainer

func NewPublishContainer(param PublisherParams) mediator.PublishContainer

func NewPublisher

func NewPublisher(container mediator.PublishContainer) mediator.Publisher

func NewSendContainer

func NewSendContainer(param SendContainerParams) mediator.SendContainer

func NewSender

func NewSender(container mediator.SendContainer) mediator.Sender

Types

type PublisherParams

type PublisherParams struct {
	fx.In

	NotificationHandlers []mediator.NotificationHandlerDefinition `group:"mediator_notification_handlers"`
	PublishStrategy      mediator.PublishStrategy                 `optional:"true"`
}

type SendContainerParams

type SendContainerParams struct {
	fx.In

	RequestHandlers []mediator.RequestHandlerDefinition `group:"mediator_request_handlers"`
	Pipelines       []mediator.PipelineBehavior         `group:"mediator_pipelines"`
}