cqrs

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

type CommandEventMarshaler interface {
	// Marshal marshals Command or Event to Watermill's message.
	Marshal(v interface{}) (*message.Message, error)

	// Unmarshal unmarshals watermill's message to v Command or Event.
	Unmarshal(msg *message.Message, v interface{}) (err error)

	// Name returns the name of Command or Event.
	// Name is used to determine, that received command or event is event which we want to handle.
	Name(v interface{}) string

	// NameFromMessage return the name of Command or Event from Watermill's message (generated by Marshal).
	//
	// When we have Commnad or Event marshaled to Watermill's message,
	// we should use NameFromMessage instead of Name to avoid unnecessary unmarshaling.
	NameFromMessage(msg *message.Message) string
}

type CommandHandler interface {
	NewCommand() interface{}
	Handle(cmd interface{}) error
}

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

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

type EventHandler interface {
	NewEvent() interface{}
	Handle(event interface{}) error
}

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

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

type FacadeConfig struct {
	CommandsTopic   string
	CommandHandlers func(commandBus *CommandBus, eventBus *EventBus) []CommandHandler
	CommandsPubSub  message.PubSub

	EventsTopic   string
	EventHandlers func(commandBus *CommandBus, eventBus *EventBus) []EventHandler
	EventsPubSub  message.PubSub

	Router                *message.Router
	Logger                watermill.LoggerAdapter
	CommandEventMarshaler CommandEventMarshaler
}

type JSONMarshaler struct {
	NewUUID func() string
}

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

type NonPointerError struct {
	Type reflect.Type
}

type ProtobufMarshaler struct {
	NewUUID func() string
}