Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
Consumer is an abstraction for consumming messages for messaging pipeline.
func NewConsumer ¶
func NewConsumer(ctx context.Context, conf configuration.Consumption, logger logging.Logger, handler func(*bus.Message) (reply interface{}, err error)) (Consumer, error)
NewConsumer returns a valid event consumer.
Click to show internal directories.
Click to hide internal directories.