proxystorage

Documentation

Index

• type ProxyStorage
  • func NewProxyStorage(NoStepSubqueryIntervalFn func(rangeMillis int64) int64) (*ProxyStorage, error)
  • func (p *ProxyStorage) Appender(context.Context) storage.Appender
  • func (p *ProxyStorage) ApplyConfig(c *proxyconfig.Config) error
  • func (p *ProxyStorage) ChunkQuerier(ctx context.Context, mint, maxt int64) (storage.ChunkQuerier, error)
  • func (p *ProxyStorage) CleanTombstones() (err error)
  • func (p *ProxyStorage) Close() error
  • func (p *ProxyStorage) ConfigHandler(w http.ResponseWriter, r *http.Request)
  • func (p *ProxyStorage) Delete(mint, maxt int64, ms ...*labels.Matcher) error
  • func (p *ProxyStorage) ExemplarQuerier(ctx context.Context) (storage.ExemplarQuerier, error)
  • func (p *ProxyStorage) GetState() *proxyStorageState
  • func (p *ProxyStorage) MetadataHandler(w http.ResponseWriter, r *http.Request)
  • func (p *ProxyStorage) NodeReplacer(ctx context.Context, s *parser.EvalStmt, node parser.Node, path []parser.Node) (parser.Node, error)
  • func (p *ProxyStorage) Querier(ctx context.Context, mint, maxt int64) (storage.Querier, error)
  • func (p *ProxyStorage) Snapshot(dir string, withHead bool) error
  • func (p *ProxyStorage) StartTime() (int64, error)
  • func (p *ProxyStorage) Stats(statsByLabelName string) (*tsdb.Stats, error)
  • func (p *ProxyStorage) WALReplayStatus() (tsdb.WALReplayStatus, error)

Types

type ProxyStorage

type ProxyStorage struct {
	NoStepSubqueryIntervalFn func(rangeMillis int64) int64
	// contains filtered or unexported fields
}

ProxyStorage implements prometheus' Storage interface

func NewProxyStorage

func NewProxyStorage(NoStepSubqueryIntervalFn func(rangeMillis int64) int64) (*ProxyStorage, error)

NewProxyStorage creates a new ProxyStorage

func (*ProxyStorage) Appender

func (p *ProxyStorage) Appender(context.Context) storage.Appender

Appender returns a new appender against the storage.

func (*ProxyStorage) ApplyConfig

func (p *ProxyStorage) ApplyConfig(c *proxyconfig.Config) error

ApplyConfig updates the current state of this ProxyStorage

func (*ProxyStorage) ChunkQuerier

func (p *ProxyStorage) ChunkQuerier(ctx context.Context, mint, maxt int64) (storage.ChunkQuerier, error)

ChunkQuerier returns a new ChunkQuerier on the storage.

func (*ProxyStorage) CleanTombstones

func (p *ProxyStorage) CleanTombstones() (err error)

Implement web.LocalStorage

func (*ProxyStorage) Close

func (p *ProxyStorage) Close() error

Close releases the resources of the Querier.

func (*ProxyStorage) ConfigHandler

func (p *ProxyStorage) ConfigHandler(w http.ResponseWriter, r *http.Request)

ConfigHandler is an implementation of the config handler within the prometheus API

func (*ProxyStorage) Delete

func (p *ProxyStorage) Delete(mint, maxt int64, ms ...*labels.Matcher) error

func (*ProxyStorage) ExemplarQuerier

func (p *ProxyStorage) ExemplarQuerier(ctx context.Context) (storage.ExemplarQuerier, error)

ExemplarQuerier returns a new ExemplarQuerier on the storage.

func (*ProxyStorage) GetState

func (p *ProxyStorage) GetState() *proxyStorageState

GetState returns the current state of the ProxyStorage

func (*ProxyStorage) MetadataHandler

func (p *ProxyStorage) MetadataHandler(w http.ResponseWriter, r *http.Request)

MetadataHandler is an implementation of the metadata handler within the prometheus API

func (*ProxyStorage) NodeReplacer

func (p *ProxyStorage) NodeReplacer(ctx context.Context, s *parser.EvalStmt, node parser.Node, path []parser.Node) (parser.Node, error)

NodeReplacer replaces promql Nodes with more efficient-to-fetch ones. This works by taking lower-layer chunks of the query, farming them out to prometheus hosts, then stitching the results back together. An example would be a sum, we can sum multiple sums and come up with the same result -- so we do. There are a few ground rules for this:

• Children cannot be AggregateExpr: aggregates have their own combining logic, so its not safe to send a subquery with additional aggregations
• offsets within the subtree must match: if they don't then we'll get mismatched data, so we wait until we are far enough down the tree that they converge
• Don't reduce accuracy/granularity: the intention of this is to get the correct data faster, meaning correctness overrules speed.

func (*ProxyStorage) Querier

func (p *ProxyStorage) Querier(ctx context.Context, mint, maxt int64) (storage.Querier, error)

Querier returns a new Querier on the storage.

func (*ProxyStorage) Snapshot

func (p *ProxyStorage) Snapshot(dir string, withHead bool) error

func (*ProxyStorage) StartTime

func (p *ProxyStorage) StartTime() (int64, error)

StartTime returns the oldest timestamp stored in the storage.

func (*ProxyStorage) Stats

func (p *ProxyStorage) Stats(statsByLabelName string) (*tsdb.Stats, error)

func (*ProxyStorage) WALReplayStatus

func (p *ProxyStorage) WALReplayStatus() (tsdb.WALReplayStatus, error)