local

Apr 14, 2017

retracted

Changes in this version

type MemorySeriesStorageOptions

+ HeadChunkTimeout time.Duration

+ TargetHeapSize uint64

Nov 1, 2016

retracted

Changes in this version

type MemorySeriesStorage

+ func (s *MemorySeriesStorage) Querier() (Querier, error)

+ type NoopQuerier struct

+ func (s *NoopQuerier) Close() error

+ func (s *NoopQuerier) LabelValuesForLabelName(ctx context.Context, labelName model.LabelName) (model.LabelValues, error)

+ func (s *NoopQuerier) LastSampleForLabelMatchers(ctx context.Context, cutoff model.Time, matcherSets ...metric.LabelMatchers) (model.Vector, error)

+ func (s *NoopQuerier) MetricsForLabelMatchers(ctx context.Context, from, through model.Time, ...) ([]metric.Metric, error)

+ func (s *NoopQuerier) QueryInstant(ctx context.Context, ts model.Time, stalenessDelta time.Duration, ...) ([]SeriesIterator, error)

+ func (s *NoopQuerier) QueryRange(ctx context.Context, from, through model.Time, ...) ([]SeriesIterator, error)

type NoopStorage

+ func (s *NoopStorage) Querier() (Querier, error)

type Querier

+ Close func() error

type Storage

+ Querier func() (Querier, error)

Oct 7, 2016

retracted

Changes in this version

+ type NoopStorage struct

+ func (s *NoopStorage) Append(sample *model.Sample) error

+ func (s *NoopStorage) DropMetricsForLabelMatchers(ctx context.Context, matchers ...*metric.LabelMatcher) (int, error)

+ func (s *NoopStorage) LabelValuesForLabelName(ctx context.Context, labelName model.LabelName) (model.LabelValues, error)

+ func (s *NoopStorage) LastSampleForLabelMatchers(ctx context.Context, cutoff model.Time, matcherSets ...metric.LabelMatchers) (model.Vector, error)

+ func (s *NoopStorage) MetricsForLabelMatchers(ctx context.Context, from, through model.Time, ...) ([]metric.Metric, error)

+ func (s *NoopStorage) NeedsThrottling() bool

+ func (s *NoopStorage) QueryInstant(ctx context.Context, ts model.Time, stalenessDelta time.Duration, ...) ([]SeriesIterator, error)

+ func (s *NoopStorage) QueryRange(ctx context.Context, from, through model.Time, ...) ([]SeriesIterator, error)

+ func (s *NoopStorage) Start() (err error)

+ func (s *NoopStorage) Stop() error

+ func (s *NoopStorage) WaitForIndexing()

Sep 3, 2016

retracted

Changes in this version

type MemorySeriesStorage

+ func (s *MemorySeriesStorage) DropMetricsForLabelMatchers(matchers ...*metric.LabelMatcher) (int, error)

+ func (s *MemorySeriesStorage) LastSampleForLabelMatchers(cutoff model.Time, matcherSets ...metric.LabelMatchers) (model.Vector, error)

+ func (s *MemorySeriesStorage) QueryInstant(ts model.Time, stalenessDelta time.Duration, matchers ...*metric.LabelMatcher) ([]SeriesIterator, error)

+ func (s *MemorySeriesStorage) QueryRange(from, through model.Time, matchers ...*metric.LabelMatcher) ([]SeriesIterator, error)

type Querier

+ LastSampleForLabelMatchers func(cutoff model.Time, matcherSets ...metric.LabelMatchers) (model.Vector, error)

+ QueryInstant func(ts model.Time, stalenessDelta time.Duration, matchers ...*metric.LabelMatcher) ([]SeriesIterator, error)

+ QueryRange func(from, through model.Time, matchers ...*metric.LabelMatcher) ([]SeriesIterator, error)

type SeriesIterator

+ Close func()

+ Metric func() metric.Metric

type Storage

+ DropMetricsForLabelMatchers func(...*metric.LabelMatcher) (int, error)

Jul 18, 2016

retracted

Changes in this version

+ const Version

+ var DefaultChunkEncoding = doubleDelta

+ var ErrDuplicateSampleForTimestamp = fmt.Errorf("sample with repeated timestamp but different value")

+ var ErrOutOfOrderSample = fmt.Errorf("sample timestamp out of order")

+ var ZeroSample = model.Sample

+ var ZeroSamplePair = model.SamplePair

+ func DumpHeads(filename string, out io.Writer) error

+ type MemorySeriesStorage struct

+ func NewMemorySeriesStorage(o *MemorySeriesStorageOptions) *MemorySeriesStorage

+ func NewTestStorage(t testutil.T, encoding chunkEncoding) (*MemorySeriesStorage, testutil.Closer)

+ func (s *MemorySeriesStorage) Append(sample *model.Sample) error

+ func (s *MemorySeriesStorage) Collect(ch chan<- prometheus.Metric)

+ func (s *MemorySeriesStorage) Describe(ch chan<- *prometheus.Desc)

+ func (s *MemorySeriesStorage) DropMetricsForFingerprints(fps ...model.Fingerprint)

+ func (s *MemorySeriesStorage) LabelValuesForLabelName(labelName model.LabelName) model.LabelValues

+ func (s *MemorySeriesStorage) LastSampleForFingerprint(fp model.Fingerprint) model.Sample

+ func (s *MemorySeriesStorage) MetricsForLabelMatchers(from, through model.Time, matchers ...*metric.LabelMatcher) map[model.Fingerprint]metric.Metric

+ func (s *MemorySeriesStorage) NeedsThrottling() bool

+ func (s *MemorySeriesStorage) NewPreloader() Preloader

+ func (s *MemorySeriesStorage) Start() (err error)

+ func (s *MemorySeriesStorage) Stop() error

+ func (s *MemorySeriesStorage) WaitForIndexing()

+ type MemorySeriesStorageOptions struct

+ CheckpointDirtySeriesLimit int

+ CheckpointInterval time.Duration

+ Dirty bool

+ MaxChunksToPersist int

+ MemoryChunks int

+ MinShrinkRatio float64

+ NumMutexes int

+ PedanticChecks bool

+ PersistenceRetentionPeriod time.Duration

+ PersistenceStoragePath string

+ SyncStrategy SyncStrategy

+ type Preloader interface

+ Close func()

+ PreloadInstant func(fp model.Fingerprint, timestamp model.Time, stalenessDelta time.Duration) SeriesIterator

+ PreloadRange func(fp model.Fingerprint, from, through model.Time) SeriesIterator

+ type Querier interface

+ LabelValuesForLabelName func(model.LabelName) model.LabelValues

+ LastSampleForFingerprint func(model.Fingerprint) model.Sample

+ MetricsForLabelMatchers func(from, through model.Time, matchers ...*metric.LabelMatcher) map[model.Fingerprint]metric.Metric

+ NewPreloader func() Preloader

+ type SeriesIterator interface

+ RangeValues func(metric.Interval) []model.SamplePair

+ ValueAtOrBeforeTime func(model.Time) model.SamplePair

+ type Storage interface

+ DropMetricsForFingerprints func(...model.Fingerprint)

+ Start func() error

+ Stop func() error

+ WaitForIndexing func()

+ type SyncStrategy int

+ const Adaptive

+ const Always

+ const Never

+ func (ss *SyncStrategy) Set(s string) error

+ func (ss SyncStrategy) String() string