event

Documentation

Index

• Constants
• type Transactional
  • func NewTransactional(ctx context.Context, producer event.Producer) *Transactional
  • func (t *Transactional) Begin(opt ...*sql.TxOptions) (db uow.Txn, err error)
  • func (t *Transactional) Commit() error
  • func (t *Transactional) Rollback() error
  • func (t *Transactional) Send(msg ...event.Event) error

Constants

const (
	UowKind = "event"
)

Types

type Transactional

type Transactional struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewTransactional

func NewTransactional(ctx context.Context, producer event.Producer) *Transactional

func (*Transactional) Begin

func (t *Transactional) Begin(opt ...*sql.TxOptions) (db uow.Txn, err error)

func (*Transactional) Commit

func (t *Transactional) Commit() error

func (*Transactional) Rollback

func (t *Transactional) Rollback() error

func (*Transactional) Send

func (t *Transactional) Send(msg ...event.Event) error