Versions in this module Expand all Collapse all v0 v0.37.1 Jun 6, 2022 v0.37.0 Jun 6, 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)