wal

Feb 1, 2024

Changes in this version

+ func ResetStats()

Jan 30, 2024

Changes in this version

type CompactingScanner

+ func (c *CompactingScanner) Bytes() ([]byte, error)

type WALHeader

+ func (h *WALHeader) Copy(b []byte)

Dec 21, 2023

Changes in this version

+ const WALFrameHeaderSize

+ const WALHeaderSize

+ const WALSupportedVersion

+ var ErrOpenTransaction = errors.New("open transaction at end of WAL file")

+ func WALChecksum(bo binary.ByteOrder, s0, s1 uint32, b []byte) (uint32, uint32)

+ type CompactingScanner struct

+ func NewCompactingScanner(r io.ReadSeeker, fullScan bool) (*CompactingScanner, error)

+ func NewFastCompactingScanner(r io.ReadSeeker) (*CompactingScanner, error)

+ func (c *CompactingScanner) Header() (*WALHeader, error)

+ func (c *CompactingScanner) Next() (*Frame, error)

+ type Frame struct

+ Commit uint32

+ Data []byte

+ Pgno uint32

+ type FullScanner struct

+ func NewFullScanner(r io.ReadSeeker) (*FullScanner, error)

+ func (f *FullScanner) Header() (*WALHeader, error)

+ func (f *FullScanner) Next() (*Frame, error)

+ type Reader struct

+ func NewReader(r io.ReadSeeker) *Reader

+ func (r *Reader) Offset() int64

+ func (r *Reader) PageSize() uint32

+ func (r *Reader) ReadFrame(data []byte) (pgno, commit uint32, err error)

+ func (r *Reader) ReadHeader() error

+ type WALHeader struct

+ Checksum1 uint32

+ Checksum2 uint32

+ Magic uint32

+ PageSize uint32

+ Salt1 uint32

+ Salt2 uint32

+ Seq uint32

+ Version uint32

+ type WALIterator interface

+ Header func() (*WALHeader, error)

+ Next func() (*Frame, error)

+ type Writer struct

+ func NewWriter(r WALIterator) (*Writer, error)

+ func (w *Writer) WriteTo(ww io.Writer) (n int64, retErr error)