leafMQ

type Consumer interface {
	Ping(ctx context.Context) error
	Use(middlewareFunc ...MiddlewareFunc)
	Listen()
	Subscribe(topic string, dispatcher Dispatcher) error
	Close() error
}

type DispatchDTO struct {
	Type      DispatchType
	Source    string
	RequestID string
	MsgType   string
	Msg       Message
	Log       leafLogger.Logger
	Err       error
}

type DispatchType string

type Dispatcher interface {
	AddHandler(handler HandlerFunc, errorHandler ErrorHandlerFunc, msgType ...string)
	Use(middlewareFunc ...MiddlewareFunc)
	Dispatch(dto DispatchDTO, middlewareFunc ...MiddlewareFunc) error
}

type ErrorHandlerFunc func(ctx context.Context, msg Message, err error)

type HandlerFunc func(ctx context.Context, msg Message) error

type Job interface {
	Process(ctx context.Context, msg Message) error
	OnError(ctx context.Context, msg Message, err error)
}

type Message struct {
	Ordering   string            `json:"ordering"`
	Data       []byte            `json:"data"`
	Attributes map[string]string `json:"attributes"`
	// contains filtered or unexported fields
}

type MessageQueue interface {
	Publisher
	Consumer
	Publisher() Publisher
	Consumer() Consumer
}

type MiddlewareFunc func(MiddlewareHandlerFunc) MiddlewareHandlerFunc

type MiddlewareHandlerFunc func(ctx context.Context, dto DispatchDTO) error

type Publisher interface {
	Ping(ctx context.Context) error
	Publish(ctx context.Context, topic string, msg Message) error
	Close() error
}