handlers

Documentation

Index

• type AlertHandler
  • func NewAlertHandler(stocksModel model.StocksModel, stockRecordsModel model.StockRecordsModel) *AlertHandler
  • func (h *AlertHandler) Handle(ctx context.Context, msg amqp.Delivery) error
• type LockHandler
  • func NewLockHandler(stocksModel model.StocksModel, stockLocksModel model.StockLocksModel, ...) *LockHandler
  • func (h *LockHandler) Handle(ctx context.Context, msg amqp.Delivery) error
• type OrderHandler
  • func NewOrderHandler(stocksModel model.StocksModel, stockLocksModel model.StockLocksModel, ...) *OrderHandler
  • func (h *OrderHandler) Handle(ctx context.Context, msg amqp.Delivery) error
• type PaymentFailedHandler
  • func NewPaymentFailedHandler(stocksModel model.StocksModel, stockLocksModel model.StockLocksModel, ...) *PaymentFailedHandler
  • func (h *PaymentFailedHandler) Handle(ctx context.Context, msg amqp.Delivery) error
• type PaymentSuccessHandler
  • func NewPaymentSuccessHandler(stocksModel model.StocksModel, stockLocksModel model.StockLocksModel, ...) *PaymentSuccessHandler
  • func (h *PaymentSuccessHandler) Handle(ctx context.Context, msg amqp.Delivery) error
• type UpdateHandler
  • func NewUpdateHandler(stocksModel model.StocksModel, stockRecordsModel model.StockRecordsModel) *UpdateHandler
  • func (h *UpdateHandler) Handle(ctx context.Context, msg amqp.Delivery) error

Types

type AlertHandler

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

func NewAlertHandler

func NewAlertHandler(
	stocksModel model.StocksModel,
	stockRecordsModel model.StockRecordsModel,
) *AlertHandler

func (*AlertHandler) Handle

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

type LockHandler

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

func NewLockHandler

func NewLockHandler(
	stocksModel model.StocksModel,
	stockLocksModel model.StockLocksModel,
	stockRecordsModel model.StockRecordsModel,
) *LockHandler

func (*LockHandler) Handle

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

type OrderHandler

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

func NewOrderHandler

func NewOrderHandler(
	stocksModel model.StocksModel,
	stockLocksModel model.StockLocksModel,
	stockRecordsModel model.StockRecordsModel,
) *OrderHandler

func (*OrderHandler) Handle

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

type PaymentFailedHandler

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

func NewPaymentFailedHandler

func NewPaymentFailedHandler(
	stocksModel model.StocksModel,
	stockLocksModel model.StockLocksModel,
	stockRecordsModel model.StockRecordsModel,
) *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(
	stocksModel model.StocksModel,
	stockLocksModel model.StockLocksModel,
	stockRecordsModel model.StockRecordsModel,
) *PaymentSuccessHandler

func (*PaymentSuccessHandler) Handle

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

type UpdateHandler

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

func NewUpdateHandler

func NewUpdateHandler(
	stocksModel model.StocksModel,
	stockRecordsModel model.StockRecordsModel,
) *UpdateHandler

func (*UpdateHandler) Handle

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