consumerHandler

Documentation

Index

• type Handler
  • func New(this *Handler) *Handler
  • func (h *Handler) Run(ctx context.Context) error
• type HandlerFunc
  • func (h HandlerFunc) HandleMessage(ctx context.Context, msg *pubsub.Message) (interface{}, error)
• type HandlerPubSub

Types

type Handler

type Handler struct {
	Cfg        *config.ServiceConfig
	Interactor *consumerRouters.ConsumerInteractor
	// contains filtered or unexported fields
}

func New

func New(this *Handler) *Handler

func (*Handler) Run

func (h *Handler) Run(ctx context.Context) error

type HandlerFunc

type HandlerFunc func(ctx context.Context, msg *pubsub.Message) (interface{}, error)

func (HandlerFunc) HandleMessage

func (h HandlerFunc) HandleMessage(ctx context.Context, msg *pubsub.Message) (interface{}, error)

type HandlerPubSub

type HandlerPubSub interface {
	HandleMessage(ctx context.Context, msg *pubsub.Message) (interface{}, error)
}