cqrs

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

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

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

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

type Command interface {
	ID() CommandID
	Request() CommandRequest
}

type CommandFactory func(CommandRequest) (Command, error)

type CommandHandler interface {
	Handle(context.Context, Command) error
}

type CommandHandlerFunc func(context.Context, Command) error

type CommandID string

type CommandMiddleware func(next CommandHandler) CommandHandler

type CommandRequest interface {
}

type CommandResult interface {
	Command() Command
}

type CommandResultFactory func(Command) (CommandResult, error)

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

type MatchFunc func(interface{}) (bool, error)

type Option struct {
	CommandFactory       CommandFactory
	QueryFactory         QueryFactory
	CommandResultFactory CommandResultFactory
	QueryResultFactory   QueryResultFactory
}

type OptionFunc func(*Option)

type Query interface {
	ID() QueryID
	Request() QueryRequest
}

type QueryFactory func(QueryRequest) (Query, error)

type QueryHandler interface {
	Handle(context.Context, Query) (interface{}, error)
}

type QueryHandlerFunc func(context.Context, Query) (interface{}, error)

type QueryID string

type QueryMiddleware func(next QueryHandler) QueryHandler

type QueryRequest interface{}

type QueryResult interface {
	Query() Query
	Data() interface{}
}

type QueryResultFactory func(Query, interface{}) (QueryResult, error)

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