wal

Oct 5, 2022

Changes in this version

+ const WblDirName

type WAL

+ func (w *WAL) NextSegmentSync() (int, error)

+ func (w *WAL) Sync() error

Aug 16, 2022

Changes in this version

type CheckpointStats

+ DroppedMetadata int

+ TotalMetadata int

Apr 21, 2022

Changes in this version

+ const DefaultSegmentSize

+ func DeleteCheckpoints(dir string, maxIndex int) error

+ func LastCheckpoint(dir string) (string, int, error)

+ func NewSegmentBufReader(segs ...*Segment) *segmentBufReader

+ func NewSegmentBufReaderWithOffset(offset int, segs ...*Segment) (sbr *segmentBufReader, err error)

+ func NewSegmentsRangeReader(sr ...SegmentRange) (io.ReadCloser, error)

+ func NewSegmentsReader(dir string) (io.ReadCloser, error)

+ func SegmentName(dir string, i int) string

+ func Segments(walDir string) (first, last int, err error)

+ type CheckpointStats struct

+ DroppedExemplars int

+ DroppedSamples int

+ DroppedSeries int

+ DroppedTombstones int

+ TotalExemplars int

+ TotalSamples int

+ TotalSeries int

+ TotalTombstones int

+ func Checkpoint(logger log.Logger, w *WAL, from, to int, ...) (*CheckpointStats, error)

+ type CorruptionErr struct

+ Dir string

+ Err error

+ Offset int64

+ Segment int

+ func (e *CorruptionErr) Error() string

+ type LiveReader struct

+ func NewLiveReader(logger log.Logger, metrics *LiveReaderMetrics, r io.Reader) *LiveReader

+ func (r *LiveReader) Err() error

+ func (r *LiveReader) Next() bool

+ func (r *LiveReader) Offset() int64

+ func (r *LiveReader) Record() []byte

+ type LiveReaderMetrics struct

+ func NewLiveReaderMetrics(reg prometheus.Registerer) *LiveReaderMetrics

+ 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 SegmentFile interface

+ Stat func() (os.FileInfo, error)

+ Sync func() error

+ type SegmentRange struct

+ Dir string

+ First int

+ Last int

+ type WAL struct

+ func New(logger log.Logger, reg prometheus.Registerer, dir string, compress bool) (*WAL, error)

+ func NewSize(logger log.Logger, reg prometheus.Registerer, dir string, segmentSize int, ...) (*WAL, error)

+ func Open(logger log.Logger, dir string) (*WAL, error)

+ func (w *WAL) Close() (err error)

+ func (w *WAL) CompressionEnabled() bool

+ func (w *WAL) Dir() string

+ func (w *WAL) LastSegmentAndOffset() (seg, offset int, err error)

+ func (w *WAL) Log(recs ...[]byte) 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)

+ type Watcher struct

+ MaxSegment int

+ func NewWatcher(metrics *WatcherMetrics, readerMetrics *LiveReaderMetrics, logger log.Logger, ...) *Watcher

+ func (w *Watcher) Run() error

+ func (w *Watcher) SetStartTime(t time.Time)

+ func (w *Watcher) Start()

+ func (w *Watcher) Stop()

+ type WatcherMetrics struct

+ func NewWatcherMetrics(reg prometheus.Registerer) *WatcherMetrics

+ type WriteTo interface

+ Append func([]record.RefSample) bool

+ AppendExemplars func([]record.RefExemplar) bool

+ SeriesReset func(int)

+ StoreSeries func([]record.RefSeries, int)

+ UpdateSeriesSegment func([]record.RefSeries, int)