consumer

Documentation

Index

• Variables
• type Consumer
  • func NewConsumer(mqConfig configs.MQ, logger *zap.Logger) (Consumer, error)
• type HandlerFunc

Variables

var WireSet = wire.NewSet(
	NewConsumer,
)

Types

type Consumer

type Consumer interface {
	Start(ctx context.Context) error
	RegisterHandler(queueName string, handlerFunc HandlerFunc)
}

func NewConsumer

func NewConsumer(
	mqConfig configs.MQ,
	logger *zap.Logger,
) (Consumer, error)

type HandlerFunc

type HandlerFunc func(ctx context.Context, payload []byte) error