wal

Documentation

Index

• type Storage
  • func NewStorage(logger log.Logger, registerer prometheus.Registerer, path string) (*Storage, error)
  • func (w *Storage) Appender() storage.Appender
  • func (w *Storage) Close() error
  • func (w *Storage) Directory() string
  • func (*Storage) StartTime() (int64, error)
  • func (w *Storage) Truncate(mint int64) error
  • func (w *Storage) WriteStalenessMarkers(remoteTsFunc func() int64) error

Types

type Storage

type Storage struct {
	// Embed Queryable for compatibility, but don't actually implement it.
	storage.Queryable
	// contains filtered or unexported fields
}

Storage implements storage.Storage, and just writes to the WAL.

func NewStorage

func NewStorage(logger log.Logger, registerer prometheus.Registerer, path string) (*Storage, error)

NewStorage makes a new Storage.

func (*Storage) Appender

func (w *Storage) Appender() storage.Appender

Appender returns a new appender against the storage.

func (*Storage) Close

func (w *Storage) Close() error

Close closes the storage and all its underlying resources.

func (*Storage) Directory

func (w *Storage) Directory() string

Directory returns the path where the WAL storage is held.

func (*Storage) StartTime

func (*Storage) StartTime() (int64, error)

StartTime always returns 0, nil. It is implemented for compatibility with Prometheus, but is unused in the agent.

func (*Storage) Truncate

func (w *Storage) Truncate(mint int64) error

Truncate removes all data from the WAL prior to the timestamp specified by mint.

func (*Storage) WriteStalenessMarkers

func (w *Storage) WriteStalenessMarkers(remoteTsFunc func() int64) error

WriteStalenessMarkers appends a staleness sample for all active series.