subscriber

Documentation

Index

• type TransactionSubscriber
  • func NewTransactionSubscriber(repo repository.TransactionRepository) *TransactionSubscriber
  • func (s *TransactionSubscriber) Handle(ctx context.Context, event *transactionPB.TransactionEvent) (err error)

Types

type TransactionSubscriber

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

func NewTransactionSubscriber

func NewTransactionSubscriber(repo repository.TransactionRepository) *TransactionSubscriber

NewTransactionSubscriber returns an instance of `TransactionSubscriber`.

func (*TransactionSubscriber) Handle

func (s *TransactionSubscriber) Handle(ctx context.Context, event *transactionPB.TransactionEvent) (err error)

Handle is a method to record transaction event, Method can be of any name