cqrs

Sep 12, 2024

Changes in this version

+ var ErrArgsNil = errors.New("cqrs: arguments is nil")

+ var ErrBusClosed = errors.New("cqrs: bus was closed")

+ var ErrHandlerNil = errors.New("cqrs: handler is nil")

+ var ErrRegistered = errors.New("cqrs: handler registered")

+ var ErrUnimplemented = errors.New("cqrs: handler is not implement CommandHandler or QueryHandler")

+ var ErrUnregistered = errors.New("cqrs: handler unregistered")

+ type Bus interface

+ AsyncExec func(ctx context.Context, args any) (Future, error)

+ AsyncQuery func(ctx context.Context, args any) (Future, error)

+ Close func(ctx context.Context) error

+ Exec func(ctx context.Context, args any) error

+ Query func(ctx context.Context, args any) (any, error)

+ RegisterCommand func(handler any) error

+ RegisterQuery func(handler any) error

+ func NewBus(opts ...Option) Bus

+ type Future interface

+ Get func(ctx context.Context) (any, error)

+ type NoopCommand struct

+ func (NoopCommand[Args]) Handle(context.Context, Args) error

type NoopQuery

+ func (NoopQuery[Args, Result]) Handle(context.Context, Args) (Result, error)

+ type Option func(*option)

+ func Pool(pool gopher.Gopher) Option

Jul 30, 2023

Changes in this version

+ func CommandEndpoint(h CommandHandler[C]) endpoint.Endpoint[C, emptyResponse]

+ func QueryEndpoint(h QueryHandler[Q, R]) endpoint.Endpoint[Q, R]

+ type CommandMiddleware interface

+ Decorate func(handler CommandHandler[C]) CommandHandler[C]

+ type CommandMiddlewareFunc func(handler CommandHandler[C]) CommandHandler[C]

+ func (f CommandMiddlewareFunc[C]) Decorate(handler CommandHandler[C]) CommandHandler[C]

+ type NoopQuery struct

+ func (NoopQuery[Q, R]) Invoke(context.Context, Q) (R, error)

+ type QueryMiddleware interface

+ Decorate func(QueryHandler[Q, R]) QueryHandler[Q, R]

+ type QueryMiddlewareFunc func(QueryHandler[Q, R]) QueryHandler[Q, R]

+ func (f QueryMiddlewareFunc[Q, R]) Decorate(handler QueryHandler[Q, R]) QueryHandler[Q, R]

Jan 30, 2023

Changes in this version

+ type CommandHandler interface

+ Handle func(ctx context.Context, cmd C) error

+ func ChainCommandHandler(handler CommandHandler[C], middlewares ...CommandHandlerMiddleware[C]) CommandHandler[C]

+ type CommandHandlerFunc func(ctx context.Context, cmd C) error

+ func (f CommandHandlerFunc[C]) Handle(ctx context.Context, cmd C) error

+ type CommandHandlerMiddleware interface

+ Decorate func(handler CommandHandler[C]) CommandHandler[C]

+ type CommandHandlerMiddlewareFunc func(handler CommandHandler[C]) CommandHandler[C]

+ func (f CommandHandlerMiddlewareFunc[C]) Decorate(handler CommandHandler[C]) CommandHandler[C]

+ type QueryHandler interface

+ Handle func(ctx context.Context, q Q) (R, error)

+ func ChainQueryHandler(handler QueryHandler[Q, R], middlewares ...QueryHandlerMiddleware[Q, R]) QueryHandler[Q, R]

+ type QueryHandlerFunc func(ctx context.Context, q Q) (R, error)

+ func (f QueryHandlerFunc[Q, R]) Handle(ctx context.Context, q Q) (R, error)

+ type QueryHandlerMiddleware interface

+ Decorate func(QueryHandler[Q, R]) QueryHandler[Q, R]

+ type QueryHandlerMiddlewareFunc func(QueryHandler[Q, R]) QueryHandler[Q, R]

+ func (f QueryHandlerMiddlewareFunc[Q, R]) Decorate(handler QueryHandler[Q, R]) QueryHandler[Q, R]