publisher

Documentation

Index

• Variables
• type Config
• type PublishProcessedTransactionError
  • func NewPublishProcessedTransactionError(msg string, err error) *PublishProcessedTransactionError
  • func (e PublishProcessedTransactionError) Error() string
• type TransactionPublisher
  • func NewTransactionPublisher(cfg *Config, log logger.Logger, pub message.Publisher) (TransactionPublisher, error)
• type TransactionPublisherError
  • func NewTransactionPublisherError(msg string, err error) *TransactionPublisherError
  • func (e TransactionPublisherError) Error() string

Variables

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

Types

type Config

type Config struct {
	ProcessedTransactionTopic string
	ProcessMonitorTopic       string
}

Config represents the publisher configuration structure.

type PublishProcessedTransactionError

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

PublishSucceededTransactionError represents an error when attempting to publish a successful transaction.

func NewPublishProcessedTransactionError

func NewPublishProcessedTransactionError(msg string, err error) *PublishProcessedTransactionError

NewPublishProcessedTransactionError creates and returns a new instance of PublishSucceededTransactionError.

func (PublishProcessedTransactionError) Error

func (e PublishProcessedTransactionError) Error() string

type TransactionPublisher

type TransactionPublisher interface {
	PublishProcessedTransaction(transaction *dto.ProcessedTransaction) error
}

TransactionPublisher is an interface for publishing processed transactions.

func NewTransactionPublisher

func NewTransactionPublisher(
	cfg *Config,
	log logger.Logger,
	pub message.Publisher,
) (TransactionPublisher, error)

NewTransactionPublisher creates a new TransactionPublisher instance.

type TransactionPublisherError

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

TransactionPublisherError represents an error that occurred during the creation transaction publishing.

func NewTransactionPublisherError

func NewTransactionPublisherError(msg string, err error) *TransactionPublisherError

NewTransactionPublisherError creates and returns a new instance of TransactionPublisherError.

func (TransactionPublisherError) Error

func (e TransactionPublisherError) Error() string