cqrs

Documentation

Index

• func AsHandler(handler interface{}, handlerGroupName string) interface{}
• func IsCommand(obj interface{}) bool
• func IsInternalCommand(obj interface{}) bool
• func IsNotification(obj interface{}) bool
• func IsQuery(obj interface{}) bool
• func IsRequest(obj interface{}) bool
• type Command
  • func NewCommandByT[T any]() Command
• type CommandHandler
• type CommandHandlerVoid
• type HandlerRegisterer
• type InternalCommand
  • func NewInternalCommandByT[T any]() InternalCommand
• type Notification
  • func NewNotificationByT[T any]() Notification
• type Query
  • func NewQueryByT[T any]() Query
• type QueryHandler
• type Request
  • func NewRequest() Request
• type RequestHandlerWithRegisterer
• type TxRequest
• type TypeInfo
  • func NewTypeInfoT[T any]() TypeInfo

Functions

func AsHandler

func AsHandler(handler interface{}, handlerGroupName string) interface{}

AsHandler annotates the given constructor to state that it provides a handler to the "handlers" group.

func IsCommand

func IsCommand(obj interface{}) bool

func IsInternalCommand

func IsInternalCommand(obj interface{}) bool

func IsNotification

func IsNotification(obj interface{}) bool

func IsQuery

func IsQuery(obj interface{}) bool

func IsRequest

func IsRequest(obj interface{}) bool

Types

type Command

type Command interface {
	Request
	TypeInfo
	// contains filtered or unexported methods
}

func NewCommandByT

func NewCommandByT[T any]() Command

type CommandHandler

type CommandHandler[TCommand Command, TResponse any] interface {
	Handle(ctx context.Context, command TCommand) (TResponse, error)
}

type CommandHandlerVoid

type CommandHandlerVoid[TCommand Command] interface {
	Handle(ctx context.Context, command TCommand) (*mediatr.Unit, error)
}

type HandlerRegisterer

type HandlerRegisterer interface {
	RegisterHandler() error
}

HandlerRegisterer for registering `RequestHandler` to mediatr registry, if handler implements this interface it will be registered automatically

type InternalCommand

type InternalCommand interface {
	Command
	// contains filtered or unexported methods
}

func NewInternalCommandByT

func NewInternalCommandByT[T any]() InternalCommand

type Notification

type Notification interface {
	TypeInfo
	// contains filtered or unexported methods
}

func NewNotificationByT

func NewNotificationByT[T any]() Notification

type Query

type Query interface {
	Request
	TypeInfo
	// contains filtered or unexported methods
}

func NewQueryByT

func NewQueryByT[T any]() Query

type QueryHandler

type QueryHandler[TQuery Query, TResponse any] interface {
	Handle(ctx context.Context, query TQuery) (TResponse, error)
}

type Request

type Request interface {
	// contains filtered or unexported methods
}

func NewRequest

func NewRequest() Request

type RequestHandlerWithRegisterer

type RequestHandlerWithRegisterer[TRequest any, TResponse any] interface {
	HandlerRegisterer
	mediatr.RequestHandler[TRequest, TResponse]
}

RequestHandlerWithRegisterer for registering `RequestHandler` to mediatr registry and handling `RequestHandler`

type TxRequest

type TxRequest interface {
	Request
	// contains filtered or unexported methods
}

https://www.mohitkhare.com/blog/go-naming-conventions/ https://github.com/EventStore/EventStore-Client-Go/blob/master/esdb/position.go

type TypeInfo

type TypeInfo interface {
	ShortTypeName() string
	FullTypeName() string
	Type() reflect.Type
}

func NewTypeInfoT

func NewTypeInfoT[T any]() TypeInfo