Versions in this module Expand all Collapse all v1 v1.0.2 Feb 8, 2024 Changes in this version + const DefaultSegmentSize + func NewSegmentBufReader(logger zerolog.Logger, segs ...*Segment) *segmentBufReader + func NewSegmentsRangeReader(logger zerolog.Logger, sr ...SegmentRange) (io.ReadCloser, error) + func NewSegmentsReader(logger zerolog.Logger, dir string) (io.ReadCloser, error) + func SegmentName(dir string, i int) string + func Segments(walDir string) (first, last int, err error) + type CorruptionErr struct + Dir string + Err error + Offset int64 + Segment int + func (e *CorruptionErr) Error() string + type LogLocation struct + Offset int + Segment int + type Reader struct + func NewReader(r io.Reader) *Reader + func (r *Reader) Err() error + func (r *Reader) Next() bool + func (r *Reader) Offset() int64 + func (r *Reader) Record() []byte + func (r *Reader) Segment() int + type Segment struct + func CreateSegment(dir string, k int) (*Segment, error) + func OpenReadSegment(fn string) (*Segment, error) + func OpenWriteSegment(logger log.Logger, dir string, k int) (*Segment, error) + func (s *Segment) Dir() string + func (s *Segment) Index() int + type SegmentRange struct + Dir string + First int + Last int + type WAL struct + func New(logger zerolog.Logger, reg prometheus.Registerer, dir string, compress bool) (*WAL, error) + func NewSize(logger zerolog.Logger, reg prometheus.Registerer, dir string, segmentSize int, ...) (*WAL, error) + func Open(logger zerolog.Logger, dir string) (*WAL, error) + func (w *WAL) Close() (err error) + func (w *WAL) CompressionEnabled() bool + func (w *WAL) Dir() string + func (w *WAL) Log(recs ...[]byte) ([]LogLocation, error) + func (w *WAL) NextSegment() error + func (w *WAL) Repair(origErr error) error + func (w *WAL) Size() (int64, error) + func (w *WAL) Truncate(i int) (err error)