append method

Future<int> append(
  1. WalOp op,
  2. String table,
  3. Map<String, dynamic> payload, {
  4. int? txnId,
})

Implementation

Future<int> append(
  WalOp op,
  String table,
  Map<String, dynamic> payload, {
  int? txnId,
}) async {
  if (_closed) throw StateError('WAL is closed');
  _lsn++;
  final record = WalRecord(
    op:       op,
    table:    table,
    payload:  payload,
    lsn:      _lsn,
    txnId:    txnId ?? _currentTxnId,
    checksum: 0,
  );
  _bufferRecord(record);
  await _flush();
  _flushedLsn = _lsn;
  return _lsn;
}