store

package

Go to main page

Versions in this module

v0

v0.26.0

Apr 9, 2022

Changes in this version

+ const CompatibilityTypeLabelName

+ const DefaultPostingOffsetInMemorySampling

+ const EstimatedMaxChunkSize

+ const MaxSamplesPerChunk

+ const PartitionerMaxGapSize

+ const RemoteReadFrameLimit

+ const StoreMatcherKey

+ func NewDefaultChunkBytesPool(maxChunkPoolBytes uint64) (pool.Bytes, error)

+ func NewNoCopyScanner(b []byte, splitFunc bufio.SplitFunc) *noCopyScanner

+ func RegisterStoreServer(storeSrv storepb.StoreServer) func(*grpc.Server)

+ func RegisterWritableStoreServer(storeSrv storepb.WriteableStoreServer) func(*grpc.Server)

+ func ScanGRPCCurlProtoStreamMessages(data []byte, atEOF bool) (advance int, token []byte, err error)

type BucketStore

+ func (s *BucketStore) LabelSet() []labelpb.ZLabelSet

+ type BucketStoreOption func(s *BucketStore)

+ func WithChunkPool(chunkPool pool.Bytes) BucketStoreOption

+ func WithDebugLogging() BucketStoreOption

+ func WithFilterConfig(filter *FilterConfig) BucketStoreOption

+ func WithIndexCache(cache storecache.IndexCache) BucketStoreOption

+ func WithLogger(logger log.Logger) BucketStoreOption

+ func WithQueryGate(queryGate gate.Gate) BucketStoreOption

+ func WithRegistry(reg prometheus.Registerer) BucketStoreOption

+ type BytesCounter struct

+ func NewBytesRead(rc io.ReadCloser) *BytesCounter

+ func (s *BytesCounter) BytesCount() int

+ func (s *BytesCounter) Read(p []byte) (n int, err error)

+ type ChunksLimiter interface

+ Reserve func(num uint64) error

+ type ChunksLimiterFactory func(failedCounter prometheus.Counter) ChunksLimiter

+ func NewChunksLimiterFactory(limit uint64) ChunksLimiterFactory

type Client

+ Addr func() string

+ LabelSets func() []labels.Labels

+ type CloseDelegator interface

+ Delegate func(io.Closer)

+ type FilterConfig struct

+ MaxTime model.TimeOrDurationValue

+ MinTime model.TimeOrDurationValue

+ type InfoStoreServer interface

+ LabelSet func() []labelpb.ZLabelSet

+ TimeRange func() (int64, int64)

+ type Limiter struct

+ func NewLimiter(limit uint64, ctr prometheus.Counter) *Limiter

+ func (l *Limiter) Reserve(num uint64) error

+ type LocalStore struct

+ func NewLocalStoreFromJSONMmappableFile(logger log.Logger, component component.StoreAPI, extLabels labels.Labels, ...) (*LocalStore, error)

+ func (s *LocalStore) Close() (err error)

+ func (s *LocalStore) Info(_ context.Context, _ *storepb.InfoRequest) (*storepb.InfoResponse, error)

+ func (s *LocalStore) LabelNames(_ context.Context, _ *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)

+ func (s *LocalStore) LabelValues(_ context.Context, r *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)

+ func (s *LocalStore) Series(r *storepb.SeriesRequest, srv storepb.Store_SeriesServer) error

+ type MultiTSDBStore struct

+ func NewMultiTSDBStore(logger log.Logger, _ prometheus.Registerer, component component.SourceStoreAPI, ...) *MultiTSDBStore

+ func (s *MultiTSDBStore) Info(ctx context.Context, req *storepb.InfoRequest) (*storepb.InfoResponse, error)

+ func (s *MultiTSDBStore) LabelNames(ctx context.Context, req *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)

+ func (s *MultiTSDBStore) LabelSet() []labelpb.ZLabelSet

+ func (s *MultiTSDBStore) LabelValues(ctx context.Context, req *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)

+ func (s *MultiTSDBStore) Series(r *storepb.SeriesRequest, srv storepb.Store_SeriesServer) error

+ func (s *MultiTSDBStore) TimeRange() (int64, int64)

+ type Part struct

+ ElemRng [2]int

+ End uint64

+ Start uint64

+ type Partitioner interface

+ Partition func(length int, rng func(int) (uint64, uint64)) []Part

+ func NewGapBasedPartitioner(maxGapSize uint64) Partitioner

type PrometheusStore

+ func (p *PrometheusStore) LabelSet() []labelpb.ZLabelSet

+ func (p *PrometheusStore) Timestamps() (mint int64, maxt int64)

type ProxyStore

+ func (s *ProxyStore) LabelSet() []labelpb.ZLabelSet

+ func (s *ProxyStore) TimeRange() (int64, int64)

+ type ReadWriteTSDBStore struct

+ type SeriesLimiter interface

+ Reserve func(num uint64) error

+ type SeriesLimiterFactory func(failedCounter prometheus.Counter) SeriesLimiter

+ func NewSeriesLimiterFactory(limit uint64) SeriesLimiterFactory

+ type TSDBReader interface

+ StartTime func() (int64, error)

type TSDBStore

+ func (s *TSDBStore) LabelSet() []labelpb.ZLabelSet

+ func (s *TSDBStore) TimeRange() (int64, int64)

v0.3.2

Mar 4, 2019

v0.3.1

Feb 18, 2019

v0.3.0

Feb 8, 2019

v0.2.1

Dec 27, 2018

v0.2.0

Dec 10, 2018

Changes in this version

type Client

+ String func() string

v0.1.0

Sep 18, 2018

Changes in this version

+ type BucketStore struct

+ func NewBucketStore(logger log.Logger, reg prometheus.Registerer, bucket objstore.BucketReader, ...) (*BucketStore, error)

+ func (s *BucketStore) Close() (err error)

+ func (s *BucketStore) Info(context.Context, *storepb.InfoRequest) (*storepb.InfoResponse, error)

+ func (s *BucketStore) InitialSync(ctx context.Context) error

+ func (s *BucketStore) LabelNames(context.Context, *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)

+ func (s *BucketStore) LabelValues(ctx context.Context, req *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)

+ func (s *BucketStore) Series(req *storepb.SeriesRequest, srv storepb.Store_SeriesServer) error

+ func (s *BucketStore) SyncBlocks(ctx context.Context) error

+ func (s *BucketStore) TimeRange() (mint, maxt int64)

+ type Client interface

+ Labels func() []storepb.Label

+ TimeRange func() (mint int64, maxt int64)

+ type PrometheusStore struct

+ func NewPrometheusStore(logger log.Logger, client *http.Client, baseURL *url.URL, ...) (*PrometheusStore, error)

+ func (p *PrometheusStore) Info(ctx context.Context, r *storepb.InfoRequest) (*storepb.InfoResponse, error)

+ func (p *PrometheusStore) LabelNames(ctx context.Context, r *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)

+ func (p *PrometheusStore) LabelValues(ctx context.Context, r *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)

+ func (p *PrometheusStore) Series(r *storepb.SeriesRequest, s storepb.Store_SeriesServer) error

+ type ProxyStore struct

+ func NewProxyStore(logger log.Logger, stores func(context.Context) ([]Client, error), ...) *ProxyStore

+ func (s *ProxyStore) Info(ctx context.Context, r *storepb.InfoRequest) (*storepb.InfoResponse, error)

+ func (s *ProxyStore) LabelNames(ctx context.Context, r *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)

+ func (s *ProxyStore) LabelValues(ctx context.Context, r *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)

+ func (s *ProxyStore) Series(r *storepb.SeriesRequest, srv storepb.Store_SeriesServer) error

+ type TSDBStore struct

+ func NewTSDBStore(logger log.Logger, reg prometheus.Registerer, db *tsdb.DB, ...) *TSDBStore

+ func (s *TSDBStore) Info(ctx context.Context, r *storepb.InfoRequest) (*storepb.InfoResponse, error)

+ func (s *TSDBStore) LabelNames(ctx context.Context, r *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)

+ func (s *TSDBStore) LabelValues(ctx context.Context, r *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)

+ func (s *TSDBStore) Series(r *storepb.SeriesRequest, srv storepb.Store_SeriesServer) error

v0.1.0-rc.2

Jul 5, 2018

v0.1.0-rc.1

May 30, 2018

v0.1.0-rc.0

May 18, 2018

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL