handlers

Documentation

Index

• type BatchMessageHandler
  • func NewBatchMessageHandler(messagesModel model.MessagesModel, messageSendsModel model.MessageSendsModel, ...) *BatchMessageHandler
  • func (h *BatchMessageHandler) Handle(ctx context.Context, msg amqp.Delivery) error
• type EventMessageHandler
  • func NewEventMessageHandler(messagesModel model.MessagesModel, messageSendsModel model.MessageSendsModel, ...) *EventMessageHandler
  • func (h *EventMessageHandler) Handle(ctx context.Context, msg amqp.Delivery) error
• type PaymentFailedHandler
  • func NewPaymentFailedHandler(messagesModel model.MessagesModel, messageSendsModel model.MessageSendsModel, ...) *PaymentFailedHandler
  • func (h *PaymentFailedHandler) Handle(ctx context.Context, msg amqp.Delivery) error
• type PaymentSuccessHandler
  • func NewPaymentSuccessHandler(messagesModel model.MessagesModel, messageSendsModel model.MessageSendsModel, ...) *PaymentSuccessHandler
  • func (h *PaymentSuccessHandler) Handle(ctx context.Context, msg amqp.Delivery) error
• type TemplateMessageHandler
  • func NewTemplateMessageHandler(messagesModel model.MessagesModel, messageSendsModel model.MessageSendsModel, ...) *TemplateMessageHandler
  • func (h *TemplateMessageHandler) Handle(ctx context.Context, msg amqp.Delivery) error

Types

type BatchMessageHandler

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

func NewBatchMessageHandler

func NewBatchMessageHandler(
	messagesModel model.MessagesModel,
	messageSendsModel model.MessageSendsModel,
	templatesModel model.MessageTemplatesModel,
	settingsModel model.NotificationSettingsModel,
) *BatchMessageHandler

func (*BatchMessageHandler) Handle

func (h *BatchMessageHandler) Handle(ctx context.Context, msg amqp.Delivery) error

type EventMessageHandler

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

func NewEventMessageHandler

func NewEventMessageHandler(
	messagesModel model.MessagesModel,
	messageSendsModel model.MessageSendsModel,
	templatesModel model.MessageTemplatesModel,
	settingsModel model.NotificationSettingsModel,
) *EventMessageHandler

func (*EventMessageHandler) Handle

func (h *EventMessageHandler) Handle(ctx context.Context, msg amqp.Delivery) error

type PaymentFailedHandler

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

func NewPaymentFailedHandler

func NewPaymentFailedHandler(
	messagesModel model.MessagesModel,
	messageSendsModel model.MessageSendsModel,
	templatesModel model.MessageTemplatesModel,
	settingsModel model.NotificationSettingsModel,
) *PaymentFailedHandler

func (*PaymentFailedHandler) Handle

func (h *PaymentFailedHandler) Handle(ctx context.Context, msg amqp.Delivery) error

type PaymentSuccessHandler

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

func NewPaymentSuccessHandler

func NewPaymentSuccessHandler(
	messagesModel model.MessagesModel,
	messageSendsModel model.MessageSendsModel,
	templatesModel model.MessageTemplatesModel,
	settingsModel model.NotificationSettingsModel,
) *PaymentSuccessHandler

func (*PaymentSuccessHandler) Handle

func (h *PaymentSuccessHandler) Handle(ctx context.Context, msg amqp.Delivery) error

type TemplateMessageHandler

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

func NewTemplateMessageHandler

func NewTemplateMessageHandler(
	messagesModel model.MessagesModel,
	messageSendsModel model.MessageSendsModel,
	templatesModel model.MessageTemplatesModel,
	settingsModel model.NotificationSettingsModel,
) *TemplateMessageHandler

func (*TemplateMessageHandler) Handle

func (h *TemplateMessageHandler) Handle(ctx context.Context, msg amqp.Delivery) error