Versions in this module Expand all Collapse all v0 v0.12.1 Apr 26, 2026 v0.12.0 Apr 25, 2026 Changes in this version + const HeaderSize + const OffsetInvalid + const OffsetNewest + const OffsetOldest + var ErrCorrupted = errors.New("log corrupted") + var ErrInvalidOffset = errors.New("invalid offset") + var ErrNotFound = errors.New("not found") + var Invalid = Message + var V1 = Version + var V2 = Version + var VLast Version = V2 + var VUnknown = Version + func MinOffset(offsets map[int64]struct{}) int64 + func Size(m Message, v Version) int64 + type Message struct + Key []byte + Offset int64 + Time time.Time + Value []byte + func Gen(count int) []Message + type Reader struct + Path string + func OpenReader(path string, offset int64) (r *Reader, retErr error) + func OpenReaderMem(path string, offset int64) (r *Reader, retErr error) + func (r *Reader) Close() error + func (r *Reader) Consume(position, maxPosition int64, maxCount int64) ([]Message, error) + func (r *Reader) Get(position int64) (msg Message, err error) + func (r *Reader) InitialPosition() int64 + func (r *Reader) Read(position int64) (msg Message, nextPosition int64, err error) + func (r *Reader) Version() Version + type Version struct + func (v Version) String() string + type Writer struct + Path string + func OpenWriter(path string, offset int64, newVersion Version) (w *Writer, retErr error) + func (w *Writer) Close() error + func (w *Writer) Size() int64 + func (w *Writer) Sync() error + func (w *Writer) SyncAndClose() error + func (w *Writer) Version() Version + func (w *Writer) Write(m Message) (int64, error)
Go to main page