payment

package

v0.0.0-...-19dc864 Latest Latest Go to latest Published: Nov 17, 2025 License: GPL-3.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

PaymentConsumer represents payment Kafka consumer

func NewPaymentConsumer(brokers []string, groupID string, useCase *PaymentUseCase, logger *zerolog.Logger) *PaymentConsumer

NewPaymentConsumer creates new payment consumer

func (pc *PaymentConsumer) Start(ctx context.Context) error

Start starts the payment consumer

func (pc *PaymentConsumer) Stop() error

Stop stops the payment consumer

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

PaymentUseCase represents payment use case

func NewPaymentUseCase(paymentRepo *persistent.PaymentRepo, kafkaProd *kafka.Producer, logger *zerolog.Logger) *PaymentUseCase

NewPaymentUseCase creates new payment use case

func (uc *PaymentUseCase) GetPaymentByID(ctx context.Context, id int64) (*entity.PaymentResponse, error)

GetPaymentByID gets payment by ID

func (uc *PaymentUseCase) GetPaymentsByUserID(ctx context.Context, userID int64) ([]*entity.PaymentResponse, error)

GetPaymentsByUserID gets payments by user ID

func (uc *PaymentUseCase) ProcessPayment(ctx context.Context, paymentEvent *entity.PaymentEvent) error

ProcessPayment processes payment from Kafka message

func (uc *PaymentUseCase) RegisterPayment(ctx context.Context, req *entity.PaymentRequest) (*entity.PaymentResponse, error)

RegisterPayment registers a new payment and sends to Kafka