grouphandler

Documentation

Index

• type GroupEventHandler
  • func NewGroupEventHandler[T any](handleFunc func(ctx context.Context, event *T) error) GroupEventHandler
• type NoPublishingHandler
  • func NewNoPublishingHandler(marshaler cqrs.CommandEventMarshaler, metricMeter metric.Meter, ...) (*NoPublishingHandler, error)
  • func (h *NoPublishingHandler) AddHandler(handler GroupEventHandler)
  • func (h *NoPublishingHandler) Handle(msg *message.Message) error

Types

type GroupEventHandler

type GroupEventHandler = cqrs.GroupEventHandler

func NewGroupEventHandler

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

type NoPublishingHandler

type NoPublishingHandler struct {
	// contains filtered or unexported fields
}

func NewNoPublishingHandler

func NewNoPublishingHandler(marshaler cqrs.CommandEventMarshaler, metricMeter metric.Meter, groupHandlers ...GroupEventHandler) (*NoPublishingHandler, error)

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

func (*NoPublishingHandler) AddHandler

func (h *NoPublishingHandler) AddHandler(handler GroupEventHandler)

func (*NoPublishingHandler) Handle

func (h *NoPublishingHandler) Handle(msg *message.Message) error