transaction

Documentation

Overview

Example

func SomeEndpoint(ctx context.COntext, req SomeRequest) error {
	// validation

	tx := transaction.Begin()
	defer tx.Rollback()

	// API Process
	if err := Process(); err != nil {
		return err
	}
	tx.PushRollback("Process", func() error {
		return InverseProcess()
	})

	tx.Done()

	return nil
}

Index

• type RollbackTask
• type Transaction
  • func Begin() *Transaction
  • func (tx *Transaction) Commit()
  • func (tx *Transaction) PopRollback() *RollbackTask
  • func (tx *Transaction) PushRollback(name string, f func() error)
  • func (tx *Transaction) Rollback() error
  • func (tx *Transaction) RollbackWithLog()

Types

type RollbackTask

type RollbackTask struct {
	Name string
	Func func() error
}

type Transaction

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

func Begin

func Begin() *Transaction

func (*Transaction) Commit

func (tx *Transaction) Commit()

func (*Transaction) PopRollback

func (tx *Transaction) PopRollback() *RollbackTask

func (*Transaction) PushRollback

func (tx *Transaction) PushRollback(name string, f func() error)

func (*Transaction) Rollback

func (tx *Transaction) Rollback() error

func (*Transaction) RollbackWithLog

func (tx *Transaction) RollbackWithLog()