segment

Oct 20, 2023

Changes in this version

type Writer

+ func (w *Writer) ForceSeal() (uint64, error)

Mar 31, 2023

Changes in this version

type Filer

+ func (f *Filer) DumpLogs(after, before uint64, ...) error

+ func (f *Filer) DumpSegment(baseIndex uint64, ID uint64, after, before uint64, ...) error

Nov 22, 2022

Changes in this version

+ const FrameCommit

+ const FrameEntry

+ const FrameIndex

+ const FrameInvalid

+ const MaxEntrySize

+ var ErrTooBig = errors.New("entries larger than 64MiB are not supported")

+ func FileName(i types.SegmentInfo) string

+ type Filer struct

+ func NewFiler(dir string, vfs types.VFS) *Filer

+ func (f *Filer) Create(info types.SegmentInfo) (types.SegmentWriter, error)

+ func (f *Filer) Delete(baseIndex uint64, ID uint64) error

+ func (f *Filer) List() (map[uint64]uint64, error)

+ func (f *Filer) Open(info types.SegmentInfo) (types.SegmentReader, error)

+ func (f *Filer) RecoverTail(info types.SegmentInfo) (types.SegmentWriter, error)

+ type Reader struct

+ func (r *Reader) Close() error

+ func (r *Reader) GetLog(idx uint64) (*types.PooledBuffer, error)

+ type Writer struct

+ func (w *Writer) Append(entries []types.LogEntry) error

+ func (w *Writer) Close() error

+ func (w *Writer) GetLog(idx uint64) (*types.PooledBuffer, error)

+ func (w *Writer) LastIndex() uint64

+ func (w *Writer) OffsetForFrame(idx uint64) (uint32, error)

+ func (w *Writer) Sealed() (bool, uint64, error)