transaction

Documentation

Index

• type Manager
  • func New(ctx context.Context, opt options.TransactionConfig, db mongodb.Client, ...) *Manager
  • func (tm *Manager) Abort(txnID string) error
  • func (tm *Manager) Commit(txnID string) error
  • func (tm *Manager) CreateTransaction(requestID string) (*Session, error)
  • func (tm *Manager) GetSession(txnID string) *Session
  • func (tm *Manager) Publish()
  • func (tm *Manager) Run() error
  • func (tm *Manager) Subscribe(ch chan<- *types.Transaction)
  • func (tm *Manager) UnSubscribe(ch chan<- *types.Transaction)
• type Session

Types

type Manager

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

func New

func New(ctx context.Context, opt options.TransactionConfig, db mongodb.Client, listen string) *Manager

func (*Manager) Abort

func (tm *Manager) Abort(txnID string) error

func (*Manager) Commit

func (tm *Manager) Commit(txnID string) error

func (*Manager) CreateTransaction

func (tm *Manager) CreateTransaction(requestID string) (*Session, error)

func (*Manager) GetSession

func (tm *Manager) GetSession(txnID string) *Session

func (*Manager) Publish

func (tm *Manager) Publish()

func (*Manager) Run

func (tm *Manager) Run() error

func (*Manager) Subscribe

func (tm *Manager) Subscribe(ch chan<- *types.Transaction)

func (*Manager) UnSubscribe

func (tm *Manager) UnSubscribe(ch chan<- *types.Transaction)

type Session

type Session struct {
	mongodb.Session
	Txninst *types.Transaction
}

Session transaction session