grouphandler

Documentation

Index

• func NewNoPublishingHandler(marshaler cqrs.CommandEventMarshaler, metricMeter metric.Meter, ...) (message.NoPublishHandlerFunc, error)
• type GroupEventHandler
  • func NewGroupEventHandler[T any](handleFunc func(ctx context.Context, event *T) error) GroupEventHandler

Functions

func NewNoPublishingHandler

func NewNoPublishingHandler(marshaler cqrs.CommandEventMarshaler, metricMeter metric.Meter, groupHandlers ...GroupEventHandler) (message.NoPublishHandlerFunc, error)

NewNoPublishingHandler creates a NoPublishHandlerFunc that will handle events with the provided GroupEventHandlers.

Types

type GroupEventHandler

type GroupEventHandler = cqrs.GroupEventHandler

func NewGroupEventHandler

func NewGroupEventHandler[T any](handleFunc func(ctx context.Context, event *T) error) GroupEventHandler