event

Documentation

Index

• func Init(r dependency.IMQProducerRepository[po.MqMessage], ...)
• func InitDefault()
• func NewUnitOfWork(id string, event *po.MqMessage) dependency.IUnitOfWork
• type EventTransactionImpl
  • func (t EventTransactionImpl) Execute(ctx context.Context, fs ...dependency.DbAction) (e error)

Functions

func Init

func Init(r dependency.IMQProducerRepository[po.MqMessage], p func(ctx context.Context, topic, key string, msg []byte) error)

func InitDefault

func InitDefault()

func NewUnitOfWork

func NewUnitOfWork(id string, event *po.MqMessage) dependency.IUnitOfWork

Types

type EventTransactionImpl

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

func (EventTransactionImpl) Execute

func (t EventTransactionImpl) Execute(ctx context.Context, fs ...dependency.DbAction) (e error)