Versions in this module Expand all Collapse all v1 v1.4.2 Feb 15, 2026 Changes in this version + const IndexFileExtension + const SegmentFileExtension + const SegmentNameWidth + func FormatIndexName(baseOffset uint64) string + func FormatSegmentName(baseOffset uint64) string + func ParseIndexName(filename string) (uint64, error) + func ParseSegmentName(filename string) (uint64, error) + func ValidateSegmentSequence(segments []*SegmentInfo) error + type ActiveWriterStats struct + Age time.Duration + BaseOffset uint64 + BytesWritten uint64 + MessagesWritten uint64 + type CompactionResult struct + BytesFreed int64 + OldestSegmentAge time.Duration + SegmentsRemoved int + type Manager struct + func NewManager(opts *ManagerOptions) (*Manager, error) + func (m *Manager) Close() error + func (m *Manager) Compact() (*CompactionResult, error) + func (m *Manager) GetActiveSegment() *SegmentInfo + func (m *Manager) GetActiveWriterStats() *ActiveWriterStats + func (m *Manager) GetSegments() []*SegmentInfo + func (m *Manager) IsClosed() bool + func (m *Manager) OpenReader(baseOffset uint64) (*Reader, error) + func (m *Manager) Sync() error + func (m *Manager) Write(entry *format.Entry) (uint64, error) + type ManagerOptions struct + Directory string + MaxSegmentAge time.Duration + MaxSegmentMessages uint64 + MaxSegmentSize uint64 + RetentionPolicy *RetentionPolicy + RotationPolicy RotationPolicy + WriterOptions *WriterOptions + func DefaultManagerOptions(dir string) *ManagerOptions + type Reader struct + func NewReader(path string) (*Reader, error) + func (r *Reader) BaseOffset() uint64 + func (r *Reader) Close() error + func (r *Reader) FindByMessageID(msgID uint64) (*format.Entry, uint64, uint64, error) + func (r *Reader) FindByTimestamp(timestamp int64) (*format.Entry, uint64, uint64, error) + func (r *Reader) HasIndex() bool + func (r *Reader) Header() *format.SegmentHeader + func (r *Reader) Read() (*format.Entry, uint64, uint64, error) + func (r *Reader) ReadAt(offset uint64) (*format.Entry, uint64, error) + func (r *Reader) ScanAll(visitor func(*format.Entry, uint64) error) error + func (r *Reader) Seek(offset uint64) error + func (r *Reader) SeekToStart() error + func (r *Reader) Size() int64 + type RetentionPolicy struct + MaxAge time.Duration + MaxSegments int + MaxSize uint64 + MinSegments int + func DefaultRetentionPolicy() *RetentionPolicy + type RotationPolicy int + const RotateByBoth + const RotateByCount + const RotateBySize + const RotateByTime + type SegmentInfo struct + BaseOffset uint64 + IndexPath string + Path string + Size int64 + func DiscoverSegments(dir string) ([]*SegmentInfo, error) + type SyncPolicy int + const SyncImmediate + const SyncInterval + const SyncManual + type Writer struct + func NewWriter(dir string, baseOffset uint64, opts *WriterOptions) (*Writer, error) + func (w *Writer) BaseOffset() uint64 + func (w *Writer) BytesWritten() uint64 + func (w *Writer) Close() error + func (w *Writer) Flush() error + func (w *Writer) IsClosed() bool + func (w *Writer) MessagesWritten() uint64 + func (w *Writer) Sync() error + func (w *Writer) Write(entry *format.Entry) (uint64, error) + type WriterOptions struct + BufferSize int + IndexInterval int + SyncInterval time.Duration + SyncPolicy SyncPolicy + func DefaultWriterOptions() *WriterOptions
Go to main page