eq_translator

Documentation

Index

• type EqTranslator
  • func (t *EqTranslator) SendSuccessCallbackConsumed() error
  • func (t *EqTranslator) SendSuccessCallbackPublished() error
  • func (t *EqTranslator) Translate() *kafka.Message
• type ITranslator

Types

type EqTranslator

type EqTranslator struct {
	Eq   *eq_repo.Eq
	Repo eq_repo.IEqRepo
}

func (*EqTranslator) SendSuccessCallbackConsumed

func (t *EqTranslator) SendSuccessCallbackConsumed() error

func (*EqTranslator) SendSuccessCallbackPublished

func (t *EqTranslator) SendSuccessCallbackPublished() error

func (*EqTranslator) Translate

func (t *EqTranslator) Translate() *kafka.Message

type ITranslator

type ITranslator interface {
	SendSuccessCallbackPublished() error
	SendSuccessCallbackConsumed() error
	Translate() *kafka.Message
}