cqrs

Mar 19, 2025

Changes in this version

type CommandProcessorSubscriberConstructorParams

+ CommandName string

type EventProcessorSubscriberConstructorParams

+ EventName string

Mar 10, 2025

Changes in this version

type CommandProcessor

+ func (p *CommandProcessor) AddHandler(handler CommandHandler) (*message.Handler, error)

type EventProcessor

+ func (p *EventProcessor) AddHandler(handler EventHandler) (*message.Handler, error)

Jan 16, 2025

Changes in this version

+ type ProtoMarshaler struct

+ GenerateName func(v interface{}) string

+ NewUUID func() string

+ func (ProtoMarshaler) Unmarshal(msg *message.Message, v interface{}) (err error)

+ func (m ProtoMarshaler) Marshal(v interface{}) (*message.Message, error)

+ func (m ProtoMarshaler) Name(cmdOrEvent interface{}) string

+ func (m ProtoMarshaler) NameFromMessage(msg *message.Message) string

type ProtobufMarshaler

+ DisableStdProtoFallback bool

+ func (m ProtobufMarshaler) ToProtoMarshaler() ProtoMarshaler

Sep 24, 2023

Changes in this version

+ func CtxWithOriginalMessage(ctx context.Context, msg *message.Message) context.Context

+ func OriginalMessageFromCtx(ctx context.Context) *message.Message

type CommandBus

+ func (c CommandBus) SendWithModifiedMessage(ctx context.Context, cmd any, modify func(*message.Message) error) error

Jun 30, 2023

Changes in this version

type CommandBus

+ func NewCommandBusWithConfig(publisher message.Publisher, config CommandBusConfig) (*CommandBus, error)

+ type CommandBusConfig struct

+ GeneratePublishTopic CommandBusGeneratePublishTopicFn

+ Logger watermill.LoggerAdapter

+ Marshaler CommandEventMarshaler

+ OnSend CommandBusOnSendFn

+ func (c CommandBusConfig) Validate() error

+ type CommandBusGeneratePublishTopicFn func(CommandBusGeneratePublishTopicParams) (string, error)

+ type CommandBusGeneratePublishTopicParams struct

+ Command any

+ CommandName string

+ type CommandBusOnSendFn func(params CommandBusOnSendParams) error

+ type CommandBusOnSendParams struct

+ Command any

+ CommandName string

+ Message *message.Message

type CommandHandler

+ func NewCommandHandler(handlerName string, handleFunc func(ctx context.Context, cmd *Command) error) CommandHandler

type CommandProcessor

+ func NewCommandProcessorWithConfig(router *message.Router, config CommandProcessorConfig) (*CommandProcessor, error)

+ func (p *CommandProcessor) AddHandlers(handlers ...CommandHandler) error

+ type CommandProcessorConfig struct

+ AckCommandHandlingErrors bool

+ GenerateSubscribeTopic CommandProcessorGenerateSubscribeTopicFn

+ Logger watermill.LoggerAdapter

+ Marshaler CommandEventMarshaler

+ OnHandle CommandProcessorOnHandleFn

+ SubscriberConstructor CommandProcessorSubscriberConstructorFn

+ func (c CommandProcessorConfig) Validate() error

+ type CommandProcessorGenerateSubscribeTopicFn func(CommandProcessorGenerateSubscribeTopicParams) (string, error)

+ type CommandProcessorGenerateSubscribeTopicParams struct

+ CommandHandler CommandHandler

+ CommandName string

+ type CommandProcessorOnHandleFn func(params CommandProcessorOnHandleParams) error

+ type CommandProcessorOnHandleParams struct

+ Command any

+ CommandName string

+ Handler CommandHandler

+ Message *message.Message

+ type CommandProcessorSubscriberConstructorFn func(CommandProcessorSubscriberConstructorParams) (message.Subscriber, error)

+ type CommandProcessorSubscriberConstructorParams struct

+ Handler CommandHandler

+ HandlerName string

type EventBus

+ func NewEventBusWithConfig(publisher message.Publisher, config EventBusConfig) (*EventBus, error)

+ type EventBusConfig struct

+ GeneratePublishTopic GenerateEventPublishTopicFn

+ Logger watermill.LoggerAdapter

+ Marshaler CommandEventMarshaler

+ OnPublish OnEventSendFn

+ func (c EventBusConfig) Validate() error

+ type EventGroupProcessor struct

+ func NewEventGroupProcessorWithConfig(router *message.Router, config EventGroupProcessorConfig) (*EventGroupProcessor, error)

+ func (p *EventGroupProcessor) AddHandlersGroup(groupName string, handlers ...GroupEventHandler) error

+ type EventGroupProcessorConfig struct

+ AckOnUnknownEvent bool

+ GenerateSubscribeTopic EventGroupProcessorGenerateSubscribeTopicFn

+ Logger watermill.LoggerAdapter

+ Marshaler CommandEventMarshaler

+ OnHandle EventGroupProcessorOnHandleFn

+ SubscriberConstructor EventGroupProcessorSubscriberConstructorFn

+ func (c EventGroupProcessorConfig) Validate() error

+ type EventGroupProcessorGenerateSubscribeTopicFn func(EventGroupProcessorGenerateSubscribeTopicParams) (string, error)

+ type EventGroupProcessorGenerateSubscribeTopicParams struct

+ EventGroupHandlers []GroupEventHandler

+ EventGroupName string

+ type EventGroupProcessorOnHandleFn func(params EventGroupProcessorOnHandleParams) error

+ type EventGroupProcessorOnHandleParams struct

+ Event any

+ EventName string

+ GroupName string

+ Handler GroupEventHandler

+ Message *message.Message

+ type EventGroupProcessorSubscriberConstructorFn func(EventGroupProcessorSubscriberConstructorParams) (message.Subscriber, error)

+ type EventGroupProcessorSubscriberConstructorParams struct

+ EventGroupHandlers []GroupEventHandler

+ EventGroupName string

type EventHandler

+ func NewEventHandler(handlerName string, handleFunc func(ctx context.Context, event *T) error) EventHandler

type EventProcessor

+ func NewEventProcessorWithConfig(router *message.Router, config EventProcessorConfig) (*EventProcessor, error)

+ func (p *EventProcessor) AddHandlers(handlers ...EventHandler) error

+ type EventProcessorConfig struct

+ AckOnUnknownEvent bool

+ GenerateSubscribeTopic EventProcessorGenerateSubscribeTopicFn

+ Logger watermill.LoggerAdapter

+ Marshaler CommandEventMarshaler

+ OnHandle EventProcessorOnHandleFn

+ SubscriberConstructor EventProcessorSubscriberConstructorFn

+ func (c EventProcessorConfig) Validate() error

+ type EventProcessorGenerateSubscribeTopicFn func(EventProcessorGenerateSubscribeTopicParams) (string, error)

+ type EventProcessorGenerateSubscribeTopicParams struct

+ EventHandler EventHandler

+ EventName string

+ type EventProcessorOnHandleFn func(params EventProcessorOnHandleParams) error

+ type EventProcessorOnHandleParams struct

+ Event any

+ EventName string

+ Handler EventHandler

+ Message *message.Message

+ type EventProcessorSubscriberConstructorFn func(EventProcessorSubscriberConstructorParams) (message.Subscriber, error)

+ type EventProcessorSubscriberConstructorParams struct

+ EventHandler EventHandler

+ HandlerName string

+ type GenerateEventPublishTopicFn func(GenerateEventPublishTopicParams) (string, error)

+ type GenerateEventPublishTopicParams struct

+ Event any

+ EventName string

+ type GroupEventHandler interface

+ Handle func(ctx context.Context, event interface{}) error

+ NewEvent func() interface{}

+ func NewGroupEventHandler(handleFunc func(ctx context.Context, event *T) error) GroupEventHandler

+ type OnEventSendFn func(params OnEventSendParams) error

+ type OnEventSendParams struct

+ Event any

+ EventName string

+ Message *message.Message

Sep 24, 2019

Changes in this version

+ func FullyQualifiedStructName(v interface{}) string

+ func NamedStruct(fallback func(v interface{}) string) func(v interface{}) string

+ func StructName(v interface{}) string

type JSONMarshaler

+ GenerateName func(v interface{}) string

type ProtobufMarshaler

+ GenerateName func(v interface{}) string

May 14, 2019

Changes in this version

type CommandHandler

+ HandlerName func() string

+ type CommandsSubscriberConstructor func(handlerName string) (message.Subscriber, error)

+ type DuplicateCommandHandlerError struct

+ CommandName string

+ func (d DuplicateCommandHandlerError) Error() string

type EventHandler

+ HandlerName func() string

+ type EventsSubscriberConstructor func(handlerName string) (message.Subscriber, error)

type FacadeConfig

+ CommandsPublisher message.Publisher

+ CommandsSubscriberConstructor CommandsSubscriberConstructor

+ EventsPublisher message.Publisher

+ EventsSubscriberConstructor EventsSubscriberConstructor

+ GenerateCommandsTopic func(commandName string) string

+ GenerateEventsTopic func(eventName string) string

Feb 13, 2019

Changes in this version

+ func ObjectName(v interface{}) string

+ type CommandBus struct

+ func NewCommandBus(publisher message.Publisher, topic string, marshaler CommandEventMarshaler) *CommandBus

+ func (c CommandBus) Send(cmd interface{}) error

+ type CommandEventMarshaler interface

+ Marshal func(v interface{}) (*message.Message, error)

+ Name func(v interface{}) string

+ NameFromMessage func(msg *message.Message) string

+ Unmarshal func(msg *message.Message, v interface{}) (err error)

+ type CommandHandler interface

+ Handle func(cmd interface{}) error

+ NewCommand func() interface{}

+ type CommandProcessor struct

+ func NewCommandProcessor(handlers []CommandHandler, commandsTopic string, subscriber message.Subscriber, ...) *CommandProcessor

+ func (p CommandProcessor) AddHandlersToRouter(r *message.Router) error

+ func (p CommandProcessor) Handlers() []CommandHandler

+ func (p CommandProcessor) RouterHandlerFunc(handler CommandHandler) (message.HandlerFunc, error)

+ type EventBus struct

+ func NewEventBus(publisher message.Publisher, topic string, marshaler CommandEventMarshaler) *EventBus

+ func (c EventBus) Publish(event interface{}) error

+ type EventHandler interface

+ Handle func(event interface{}) error

+ NewEvent func() interface{}

+ type EventProcessor struct

+ func NewEventProcessor(handlers []EventHandler, eventsTopic string, subscriber message.Subscriber, ...) *EventProcessor

+ func (p EventProcessor) AddHandlersToRouter(r *message.Router) error

+ func (p EventProcessor) Handlers() []EventHandler

+ func (p EventProcessor) RouterHandlerFunc(handler EventHandler) (message.HandlerFunc, error)

+ type Facade struct

+ func NewFacade(config FacadeConfig) (*Facade, error)

+ func (f Facade) CommandBus() *CommandBus

+ func (f Facade) CommandEventMarshaler() CommandEventMarshaler

+ func (f Facade) CommandsTopic() string

+ func (f Facade) EventBus() *EventBus

+ func (f Facade) EventsTopic() string

+ type FacadeConfig struct

+ CommandEventMarshaler CommandEventMarshaler

+ CommandHandlers func(commandBus *CommandBus, eventBus *EventBus) []CommandHandler

+ CommandsPubSub message.PubSub

+ CommandsTopic string

+ EventHandlers func(commandBus *CommandBus, eventBus *EventBus) []EventHandler

+ EventsPubSub message.PubSub

+ EventsTopic string

+ Logger watermill.LoggerAdapter

+ Router *message.Router

+ func (c FacadeConfig) CommandsEnabled() bool

+ func (c FacadeConfig) EventsEnabled() bool

+ func (c FacadeConfig) Validate() error

+ type JSONMarshaler struct

+ NewUUID func() string

+ func (JSONMarshaler) Unmarshal(msg *message.Message, v interface{}) (err error)

+ func (m JSONMarshaler) Marshal(v interface{}) (*message.Message, error)

+ func (m JSONMarshaler) Name(cmdOrEvent interface{}) string

+ func (m JSONMarshaler) NameFromMessage(msg *message.Message) string

+ type NoProtoMessageError struct

+ func (e NoProtoMessageError) Error() string

+ type NonPointerError struct

+ Type reflect.Type

+ func (e NonPointerError) Error() string

+ type ProtobufMarshaler struct

+ NewUUID func() string

+ func (ProtobufMarshaler) Unmarshal(msg *message.Message, v interface{}) (err error)

+ func (m ProtobufMarshaler) Marshal(v interface{}) (*message.Message, error)

+ func (m ProtobufMarshaler) Name(cmdOrEvent interface{}) string

+ func (m ProtobufMarshaler) NameFromMessage(msg *message.Message) string