Versions in this module Expand all Collapse all v2 v2.13.1 Oct 8, 2023 Changes in this version + const DefaultSegmentSize + func DeleteCheckpoints(dir string, maxIndex int) error + func LastCheckpoint(dir string) (string, int, error) + func NewLiveReaderMetrics(reg prometheus.Registerer) *liveReaderMetrics + func NewSegmentBufReader(segs ...*Segment) *segmentBufReader + func NewSegmentsRangeReader(sr ...SegmentRange) (io.ReadCloser, error) + func NewSegmentsReader(dir string) (io.ReadCloser, error) + func SegmentName(dir string, i int) string + type CheckpointStats struct + DroppedSamples int + DroppedSeries int + DroppedTombstones int + TotalSamples int + TotalSeries int + TotalTombstones int + func Checkpoint(w *WAL, from, to int, keep func(id uint64) bool, mint int64) (*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 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 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, reg prometheus.Registerer, 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) error + func (w *WAL) NextSegment() error + func (w *WAL) Repair(origErr error) error + func (w *WAL) Segments() (first, last int, err error) + func (w *WAL) Truncate(i int) (err error) + type Watcher struct + MaxSegment int + StartTime int64 + func NewWatcher(reg prometheus.Registerer, metrics *WatcherMetrics, logger log.Logger, ...) *Watcher + func (w *Watcher) Run() error + 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 + SeriesReset func(int) + StoreSeries func([]record.RefSeries, int)
Go to main page