payments

Documentation

Index

• Constants
• func NewProcessor(messageConsumer messages.Consumer, eventsHandler EventsHandler, ...) *messages.Processor[EventsHandler]
• func NewRabbitMQProcessor(eventsHandler EventsHandler, queueName string, opts ...RabbitMQProcessorOpt) (*messages.Processor[EventsHandler], error)
• type BeneficiaryAccount
• type EventsDeserializer
  • func NewEventsDeserializer() *EventsDeserializer
  • func (d *EventsDeserializer) Deserialize(rawPayload []byte) (events.Event[EventsHandler], error)
• type EventsHandler
• type RabbitMQProcessorOpt
• type WithdrawalBeneficiary
• type WithdrawalCreatedEvent
  • func (w WithdrawalCreatedEvent) Accept(ctx context.Context, handler EventsHandler) errors.ProcessingError
  • func (w WithdrawalCreatedEvent) CorrelationID() string
  • func (w WithdrawalCreatedEvent) DataContentType() string
  • func (w WithdrawalCreatedEvent) ID() string
  • func (w WithdrawalCreatedEvent) Serialize() ([]byte, error)
  • func (w WithdrawalCreatedEvent) Type() string

Constants

const (
	RabbitMQExchangeName = "payments"
	RabbitMQExchangeType = "topic"
	RabbitMQRoutingKey   = "payments.events"
)

Functions

func NewProcessor

func NewProcessor(messageConsumer messages.Consumer, eventsHandler EventsHandler, opts ...messages.ProcessorOpt) *messages.Processor[EventsHandler]

NewProcessor returns a messages.Processor which is specific to payments events

func NewRabbitMQProcessor

func NewRabbitMQProcessor(
	eventsHandler EventsHandler,
	queueName string,
	opts ...RabbitMQProcessorOpt,
) (*messages.Processor[EventsHandler], error)

Types

type BeneficiaryAccount

type BeneficiaryAccount struct {
	Holder     string `json:"holder"`
	Number     int    `json:"number"`
	RoutingKey string `json:"routing_key"`
}

type EventsDeserializer

type EventsDeserializer struct {
}

func NewEventsDeserializer

func NewEventsDeserializer() *EventsDeserializer

func (*EventsDeserializer) Deserialize

func (d *EventsDeserializer) Deserialize(rawPayload []byte) (events.Event[EventsHandler], error)

type EventsHandler

type EventsHandler interface {
	HandleWithdrawalCreated(ctx context.Context, withdrawalCreated WithdrawalCreatedEvent) errors.ProcessingError
}

type RabbitMQProcessorOpt

type RabbitMQProcessorOpt struct {
	ProcessorOpt        messages.ProcessorOpt
	RabbitmqConsumerOpt rabbitmq.ConsumerOpt
}

type WithdrawalBeneficiary

type WithdrawalBeneficiary struct {
	Id          string             `json:"id"`
	Description string             `json:"description"`
	Account     BeneficiaryAccount `json:"account"`
}

type WithdrawalCreatedEvent

type WithdrawalCreatedEvent struct {
	Id          string                `json:"id"`
	UserId      string                `json:"user_id"`
	PspId       string                `json:"psp_id"`
	ExternalId  string                `json:"external_id"`
	Amount      float64               `json:"amount"`
	Currency    string                `json:"currency"`
	Status      string                `json:"status"`
	Beneficiary WithdrawalBeneficiary `json:"beneficiary"`
	// contains filtered or unexported fields
}

func (WithdrawalCreatedEvent) Accept

func (w WithdrawalCreatedEvent) Accept(ctx context.Context, handler EventsHandler) errors.ProcessingError

func (WithdrawalCreatedEvent) CorrelationID

func (w WithdrawalCreatedEvent) CorrelationID() string

func (WithdrawalCreatedEvent) DataContentType

func (w WithdrawalCreatedEvent) DataContentType() string

func (WithdrawalCreatedEvent) ID

func (w WithdrawalCreatedEvent) ID() string

func (WithdrawalCreatedEvent) Serialize

func (w WithdrawalCreatedEvent) Serialize() ([]byte, error)

func (WithdrawalCreatedEvent) Type

func (w WithdrawalCreatedEvent) Type() string