cqrs

package

v0.22.1 Latest Latest Go to latest Published: May 7, 2026 License: Apache-2.0 Imports: 2 Imported by: 0

Details

View Source

const (
	Command = icqrs.Command
	Query   = icqrs.Query
)

View Source

var ErrHandlerNotFound = icqrs.ErrHandlerNotFound

func Register[TAction icqrs.Action, TResult any](bus Bus, handler Handler[TAction, TResult])

Register registers a type-safe handler for command type C. Panics if a handler is already registered for the same command type.

func Send[TAction icqrs.Action, TResult any](ctx context.Context, bus Bus, action TAction) (TResult, error)

Send dispatches a command through the behavior pipeline to its registered handler.

type Action = icqrs.Action

type ActionKind = icqrs.ActionKind

type BaseCommand = icqrs.BaseCommand

type BaseQuery = icqrs.BaseQuery

type Behavior = icqrs.Behavior

type BehaviorFunc = icqrs.BehaviorFunc

type Bus = icqrs.Bus

type Handler[TAction icqrs.Action, TResult any] = icqrs.Handler[TAction, TResult]

type HandlerFunc[TAction icqrs.Action, TResult any] = icqrs.HandlerFunc[TAction, TResult]

type Unit = icqrs.Unit