subscriber

Documentation

Index

• Variables
• type Config
• type TransactionSubscriber
  • func NewTransactionSubscriber(cfg *Config, log logger.Logger, sub message.Subscriber, router *message.Router, ...) (*TransactionSubscriber, error)
  • func (s *TransactionSubscriber) RegisterFailedTransactionHandler()
  • func (s *TransactionSubscriber) RegisterSucceededTransactionHandler()
  • func (s *TransactionSubscriber) Run(ctx context.Context) error
• type TransactionSubscriberError
  • func NewTransactionSubscriberError(msg string, err error) *TransactionSubscriberError
  • func (e TransactionSubscriberError) Error() string

Variables

var ErrNilConfig = errors.New("cannot override nil config")

Types

type Config

type Config struct {
	FailedTransactionTopic    string
	SucceededTransactionTopic string
}

Config represents the subscriber configuration structure.

type TransactionSubscriber

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

TransactionSubscriber represents a service that subscribes to transaction-related messages and handles them based on their type (succeeded or failed).

func NewTransactionSubscriber

func NewTransactionSubscriber(
	cfg *Config,
	log logger.Logger,
	sub message.Subscriber,
	router *message.Router,
	transactionRepo repository.TransactionRepo,
) (*TransactionSubscriber, error)

NewTransactionSubscriber creates a new TransactionSubscriber instance with the provided dependencies.

func (*TransactionSubscriber) RegisterFailedTransactionHandler

func (s *TransactionSubscriber) RegisterFailedTransactionHandler()

RegisterFailedTransactionHandler registers a handler for failed transaction messages.

func (*TransactionSubscriber) RegisterSucceededTransactionHandler

func (s *TransactionSubscriber) RegisterSucceededTransactionHandler()

RegisterSucceededTransactionHandler registers a handler for succeeded transaction messages.

func (*TransactionSubscriber) Run

func (s *TransactionSubscriber) Run(ctx context.Context) error

Run starts the transaction subscriber's router.

type TransactionSubscriberError

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

TransactionSubscriberError represents an error type specific to the creation of transaction subscribers.

func NewTransactionSubscriberError

func NewTransactionSubscriberError(msg string, err error) *TransactionSubscriberError

NewTransactionSubscriberError creates a new TransactionSubscriberError instance.

func (TransactionSubscriberError) Error

func (e TransactionSubscriberError) Error() string