Documentation
¶
Index ¶
- type Session
- type TxnManager
- func (tm *TxnManager) Abort(txnID string) error
- func (tm *TxnManager) Commit(txnID string) error
- func (tm *TxnManager) CreateTransaction(requestID string) (*Session, error)
- func (tm *TxnManager) GetSession(txnID string) *Session
- func (tm *TxnManager) Publish()
- func (tm *TxnManager) Run() error
- func (tm *TxnManager) Subscribe(ch chan<- *types.Transaction)
- func (tm *TxnManager) UnSubscribe(ch chan<- *types.Transaction)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TxnManager ¶
type TxnManager struct {
// contains filtered or unexported fields
}
func New ¶
func New(ctx context.Context, opt options.TransactionConfig, db mongobyc.Client, listen string) *TxnManager
func (*TxnManager) Abort ¶
func (tm *TxnManager) Abort(txnID string) error
func (*TxnManager) Commit ¶
func (tm *TxnManager) Commit(txnID string) error
func (*TxnManager) CreateTransaction ¶
func (tm *TxnManager) CreateTransaction(requestID string) (*Session, error)
func (*TxnManager) GetSession ¶
func (tm *TxnManager) GetSession(txnID string) *Session
func (*TxnManager) Publish ¶
func (tm *TxnManager) Publish()
func (*TxnManager) Run ¶
func (tm *TxnManager) Run() error
func (*TxnManager) Subscribe ¶
func (tm *TxnManager) Subscribe(ch chan<- *types.Transaction)
func (*TxnManager) UnSubscribe ¶
func (tm *TxnManager) UnSubscribe(ch chan<- *types.Transaction)
Source Files
Click to show internal directories.
Click to hide internal directories.