producer

Documentation

Index

• type Producer
  • func NewProducer(topics Topics, brokers ...string) *Producer
  • func (p *Producer) NewAccountEvent(ctx context.Context, account *repository.Account) error
  • func (p *Producer) NewTransactionEvent(ctx context.Context, trx *repository.Transaction) error
• type Topics

Types

type Producer

type Producer struct {
	BankAccountsTopic string
	// contains filtered or unexported fields
}

func NewProducer

func NewProducer(topics Topics, brokers ...string) *Producer

func (*Producer) NewAccountEvent

func (p *Producer) NewAccountEvent(ctx context.Context, account *repository.Account) error

func (*Producer) NewTransactionEvent

func (p *Producer) NewTransactionEvent(ctx context.Context, trx *repository.Transaction) error

type Topics

type Topics struct {
	BankAccountsTopic string
}