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 + var ErrOffsetBeforeStart = fmt.Errorf("%w: offset before start", message.ErrNotFound) + var ErrOffsetRelative = fmt.Errorf("%w: get relative offset", message.ErrInvalidOffset) + func Backup(segments []Segment, target string) error + func BackupDir(dir, target string) error + func CheckDir(dir string, params index.Params) error + func Consume[S ~[]O, O Offsetter](segments S, offset int64) (O, int) + func Get[S ~[]O, O Offsetter](segments S, offset int64) (O, int, error) + func MigrateDir(dir string, mversion message.Version, iversion index.Version, ...) error + func RecoverDir(dir string, params index.Params) error + type Offsetter interface + GetOffset func() int64 + type RewriteSegment struct + DeletedMessages []message.Message + DeletedSize int64 + Stats Stats + SurviveOffsets map[int64]struct{} + func (r *RewriteSegment) GetNewSegment() Segment + type Segment struct + AutoSync bool + Dir string + Index string + Log string + Offset int64 + func Find(dir string, autoSync bool) ([]Segment, error) + func New(dir string, offset int64, autoSync bool) Segment + func (olds Segment) Override(news Segment) error + func (olds Segment) Rename(news Segment) error + func (s Segment) Backup(targetDir string) error + func (s Segment) Check(params index.Params) error + func (s Segment) GetOffset() int64 + func (s Segment) Migrate(mversion message.Version, iversion index.Version, params index.Params) error + func (s Segment) NeedsReindex() (bool, error) + func (s Segment) NewAt(offset int64) Segment + func (s Segment) Recover(params index.Params) error + func (s Segment) Reindex(params index.Params, version index.Version) ([]index.Item, error) + func (s Segment) ReindexAndReadIndex(params index.Params, version index.Version) ([]index.Item, error) + func (s Segment) ReindexReader(params index.Params, log *message.Reader, version index.Version) ([]index.Item, error) + func (s Segment) Remove() error + func (s Segment) Stat(params index.Params) (Stats, error) + func (src Segment) Rewrite(dropOffsets map[int64]struct{}, params index.Params, mversion message.Version, ...) (*RewriteSegment, error) + type Stats struct + Messages int + Segments int + Size int64 + func Stat(segments []Segment, params index.Params) (Stats, error) + func StatDir(dir string, params index.Params) (Stats, error)
Go to main page