Versions in this module Expand all Collapse all v0 v0.2.0 Nov 16, 2018 v0.1.0 Nov 15, 2018 Changes in this version + func NewSegmentsRangeReader(dir string, first, last int) (io.ReadCloser, error) + func NewSegmentsReader(dir string) (io.ReadCloser, error) + func SegmentName(dir string, i int) string + type CorruptionErr struct + Err error + Offset int64 + Segment int + func (e *CorruptionErr) Error() string + type Reader struct + func NewReader(r io.Reader) *Reader + func (r *Reader) Err() error + func (r *Reader) Next() bool + func (r *Reader) Record() []byte + 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 WAL struct + func New(logger log.Logger, reg prometheus.Registerer, dir string) (*WAL, error) + func NewSize(logger log.Logger, reg prometheus.Registerer, dir string, segmentSize int) (*WAL, error) + func (w *WAL) Close() (err error) + func (w *WAL) Dir() string + func (w *WAL) Log(recs ...[]byte) 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)