Versions in this module Expand all Collapse all v1 v1.0.5 Apr 8, 2024 v1.0.3 Apr 8, 2024 Changes in this version + var ErrBufferClosed = errors.New("transaction buffer already closed") + var ErrNotTransaction = errors.New("oplog entry is not a transaction") + var ErrTxnAborted = errors.New("transaction aborted") + type Buffer struct + func NewBuffer() *Buffer + func (b *Buffer) AddOp(m Meta, op db.Oplog) error + func (b *Buffer) GetTxnStream(m Meta) (<-chan db.Oplog, <-chan error) + func (b *Buffer) OldestOpTime() db.OpTime + func (b *Buffer) PurgeTxn(m Meta) error + func (b *Buffer) Stop() error + type ID struct + func (id ID) String() string + type Meta struct + func NewMeta(op db.Oplog) (Meta, error) + func (m Meta) IsAbort() bool + func (m Meta) IsCommit() bool + func (m Meta) IsData() bool + func (m Meta) IsFinal() bool + func (m Meta) IsMultiOp() bool + func (m Meta) IsTxn() bool
Go to main page