Versions in this module Expand all Collapse all v0 v0.3.0 Feb 7, 2026 v0.2.0 Jan 24, 2026 Changes in this version + const OpDelete + const OpSetInline + const OpSetRID + const Version + var ErrCorrupt = errors.New("commitlog: corrupt record") + var ErrRecordTooLarge = errors.New("commitlog: record too large") + type Options struct + Compress bool + MaxSegmentSize int64 + type Reader struct + func NewReader(path string) (*Reader, error) + func NewReaderWithOptions(path string, opts Options) (*Reader, error) + func (r *Reader) Close() error + func (r *Reader) ReadBatch() ([]Record, error) + type Record struct + Key []byte + Op byte + RID uint64 + Seq uint64 + Value []byte + type Writer struct + func NewWriter(path string) (*Writer, error) + func NewWriterWithOptions(path string, opts Options) (*Writer, error) + func (w *Writer) Append(record Record) error + func (w *Writer) AppendBatch(records []Record) error + func (w *Writer) Close() error + func (w *Writer) Flush() error + func (w *Writer) RotateTo(path string) error + func (w *Writer) Size() int64 + func (w *Writer) Sync() error
Go to main page