Searched refs:txnBuffer (Results 1 – 1 of 1) sorted by relevance
35 txnBuffer *txn.Buffer member72 txnBuffer: txn.NewBuffer(),75 defer oplogCtx.txnBuffer.Stop()151 err := oplogCtx.txnBuffer.AddOp(meta, op)157 err := oplogCtx.txnBuffer.PurgeTxn(meta)169 ops, errs := oplogCtx.txnBuffer.GetTxnStream(meta)190 err = oplogCtx.txnBuffer.PurgeTxn(meta)