storage

Oct 15, 2019

Changes in this version

type CompleteTagsResult

+ Metadata block.ResultMetadata

type FetchOptions

+ IncludeResolution bool

type FetchResult

+ Metadata block.ResultMetadata

type SearchResults

+ Metadata block.ResultMetadata

Sep 15, 2019

Changes in this version

+ func IsWarning(store Storage, err error) (bool, error)

+ type ErrorBehavior uint8

+ const BehaviorContainer

+ const BehaviorFail

+ const BehaviorWarn

+ func ParseErrorBehavior(str string) (ErrorBehavior, error)

+ func (t ErrorBehavior) String() string

+ func (v *ErrorBehavior) UnmarshalYAML(unmarshal func(interface{}) error) error

type MockStorage

+ func (m *MockStorage) ErrorBehavior() ErrorBehavior

+ func (m *MockStorage) Name() string

type MockStorageMockRecorder

+ func (mr *MockStorageMockRecorder) ErrorBehavior() *gomock.Call

+ func (mr *MockStorageMockRecorder) Name() *gomock.Call

type Storage

+ ErrorBehavior func() ErrorBehavior

+ Name func() string

Aug 23, 2019

Changes in this version

type FetchOptions

+ LookbackDuration *time.Duration

+ Remote bool

+ RestrictFetchOptions *RestrictFetchOptions

+ Step time.Duration

+ func (o *FetchOptions) LookbackDurationOrDefault(defaultValue time.Duration) time.Duration

+ func (o *FetchOptions) QueryFetchOptions(queryCtx *models.QueryContext, blockType models.FetchedBlockType) (*FetchOptions, error)

type MetricsType

+ const UnknownMetricsType

+ func ParseMetricsType(str string) (MetricsType, error)

+ type RestrictFetchOptions struct

+ MetricsType MetricsType

+ StoragePolicy policy.StoragePolicy

+ func NewRestrictFetchOptionsFromProto(p *rpcpb.RestrictFetchOptions) (RestrictFetchOptions, error)

+ func (o RestrictFetchOptions) Proto() (*rpcpb.RestrictFetchOptions, error)

+ func (o RestrictFetchOptions) Validate() error

Jun 8, 2019

Changes in this version

+ func PromTimestampToTime(timestampMS int64) time.Time

+ func TimeToPromTimestamp(timestamp time.Time) int64

May 18, 2019

Changes in this version

type FetchOptions

+ func (o *FetchOptions) Clone() *FetchOptions

Mar 29, 2019

Changes in this version

+ func FetchOptionsToAggregateOptions(fetchOptions *FetchOptions, tagQuery *CompleteTagsQuery) index.AggregationOptions

type CompleteTagsQuery

+ End time.Time

+ Start time.Time

+ type MockStorage struct

+ func NewMockStorage(ctrl *gomock.Controller) *MockStorage

+ func (m *MockStorage) Close() error

+ func (m *MockStorage) CompleteTags(arg0 context.Context, arg1 *CompleteTagsQuery, arg2 *FetchOptions) (*CompleteTagsResult, error)

+ func (m *MockStorage) EXPECT() *MockStorageMockRecorder

+ func (m *MockStorage) Fetch(arg0 context.Context, arg1 *FetchQuery, arg2 *FetchOptions) (*FetchResult, error)

+ func (m *MockStorage) FetchBlocks(arg0 context.Context, arg1 *FetchQuery, arg2 *FetchOptions) (block.Result, error)

+ func (m *MockStorage) SearchSeries(arg0 context.Context, arg1 *FetchQuery, arg2 *FetchOptions) (*SearchResults, error)

+ func (m *MockStorage) Type() Type

+ func (m *MockStorage) Write(arg0 context.Context, arg1 *WriteQuery) error

+ type MockStorageMockRecorder struct

+ func (mr *MockStorageMockRecorder) Close() *gomock.Call

+ func (mr *MockStorageMockRecorder) CompleteTags(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockStorageMockRecorder) Fetch(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockStorageMockRecorder) FetchBlocks(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockStorageMockRecorder) SearchSeries(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockStorageMockRecorder) Type() *gomock.Call

+ func (mr *MockStorageMockRecorder) Write(arg0, arg1 interface{}) *gomock.Call

type Querier

+ SearchSeries func(ctx context.Context, query *FetchQuery, options *FetchOptions) (*SearchResults, error)

Mar 15, 2019

Changes in this version

type FetchOptions

+ Enforcer cost.ChainedEnforcer

+ Scope tally.Scope

Mar 12, 2019

Changes in this version

+ type QueryConversionCache struct

+ func NewQueryConversionCache(lru *QueryConversionLRU) *QueryConversionCache

+ type QueryConversionLRU struct

+ func NewQueryConversionLRU(size int) (*QueryConversionLRU, error)

+ func (c *QueryConversionLRU) Get(key []byte) (value idx.Query, ok bool)

+ func (c *QueryConversionLRU) Set(key []byte, value idx.Query) (evicted bool)

Feb 3, 2019

Changes in this version

+ func NewUnconsolidatedStep(time time.Time, values []ts.Datapoints) block.UnconsolidatedStep

+ type FanoutOption uint

+ const FanoutDefault

+ const FanoutForceDisable

+ const FanoutForceEnable

+ type FanoutOptions struct

+ FanoutAggregated FanoutOption

+ FanoutAggregatedOptimized FanoutOption

+ FanoutUnaggregated FanoutOption

type FetchOptions

+ BlockType models.FetchedBlockType

+ FanoutOptions *FanoutOptions

type Querier

+ CompleteTags func(ctx context.Context, query *CompleteTagsQuery, options *FetchOptions) (*CompleteTagsResult, error)

+ type SeriesMatchQuery struct

+ End time.Time

+ Start time.Time

+ TagMatchers []models.Matchers

type Type

+ const TypeDebug

Nov 19, 2018

Changes in this version

+ type CompleteTagsQuery struct

+ CompleteNameOnly bool

+ FilterNameTags [][]byte

+ TagMatchers models.Matchers

+ func (q *CompleteTagsQuery) String() string

+ type CompleteTagsResult struct

+ CompleteNameOnly bool

+ CompletedTags []CompletedTag

+ type CompleteTagsResultBuilder interface

+ Add func(*CompleteTagsResult) error

+ Build func() CompleteTagsResult

+ func NewCompleteTagsResultBuilder(nameOnly bool) CompleteTagsResultBuilder

+ type CompletedTag struct

+ Name []byte

+ Values [][]byte

type FetchOptions

+ func NewFetchOptions() *FetchOptions

Oct 5, 2018

Changes in this version

+ func NewMultiBlockWrapper(unconsolidatedBlock block.UnconsolidatedBlock) block.Block

+ func NewMultiSeriesBlock(seriesList ts.SeriesList, query *FetchQuery) (block.UnconsolidatedBlock, error)

Sep 21, 2018

Changes in this version

type MetricsType

+ const DefaultMetricsType

Aug 10, 2018

Changes in this version

+ func FetchOptionsToM3Options(fetchOptions *FetchOptions, fetchQuery *FetchQuery) index.QueryOptions

+ func FetchQueryToM3Query(fetchQuery *FetchQuery) (index.Query, error)

+ func FetchResultToBlockResult(result *FetchResult, query *FetchQuery) (block.Result, error)

+ func FetchResultToPromResult(result *FetchResult) *prompb.QueryResult

+ func FromIdentTagIteratorToTags(identTags ident.TagIterator) (models.Tags, error)

+ func FromM3IdentToMetric(identNamespace, identID ident.ID, iterTags ident.TagIterator) (*models.Metric, error)

+ func PromLabelsToM3Tags(labels []*prompb.Label) models.Tags

+ func PromMatcherToM3(matcher *prompb.LabelMatcher) (*models.Matcher, error)

+ func PromMatchersToM3(matchers []*prompb.LabelMatcher) (models.Matchers, error)

+ func PromSamplesToM3Datapoints(samples []*prompb.Sample) ts.Datapoints

+ func PromTypeToM3(labelType prompb.LabelMatcher_Type) (models.MatchType, error)

+ func SeriesToPromSamples(series *ts.Series) []*prompb.Sample

+ func SeriesToPromTS(series *ts.Series) *prompb.TimeSeries

+ func TagsToIdentTagIterator(tags models.Tags) ident.TagIterator

+ func TagsToPromLabels(tags models.Tags) []*prompb.Label

+ func TimeToTimestamp(timestamp time.Time) int64

+ func TimestampToTime(timestampMS int64) time.Time

+ func ValidateMetricsType(v MetricsType) error

+ type Appender interface

+ Write func(ctx context.Context, query *WriteQuery) error

+ type Attributes struct

+ MetricsType MetricsType

+ Resolution time.Duration

+ Retention time.Duration

+ type FetchOptions struct

+ KillChan chan struct{}

+ Limit int

+ type FetchQuery struct

+ End time.Time

+ Interval time.Duration

+ Raw string

+ Start time.Time

+ TagMatchers models.Matchers

+ func PromReadQueryToM3(query *prompb.Query) (*FetchQuery, error)

+ func (q *FetchQuery) String() string

+ type FetchResult struct

+ HasNext bool

+ LocalOnly bool

+ SeriesList ts.SeriesList

+ func SeriesIteratorsToFetchResult(seriesIterators encoding.SeriesIterators, namespace ident.ID, ...) (*FetchResult, error)

+ type MetricsType uint

+ const AggregatedMetricsType

+ const UnaggregatedMetricsType

+ func (t MetricsType) String() string

+ func (v *MetricsType) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type Querier interface

+ Fetch func(ctx context.Context, query *FetchQuery, options *FetchOptions) (*FetchResult, error)

+ FetchBlocks func(ctx context.Context, query *FetchQuery, options *FetchOptions) (block.Result, error)

+ FetchTags func(ctx context.Context, query *FetchQuery, options *FetchOptions) (*SearchResults, error)

+ type Query interface

+ type QueryResult struct

+ Err error

+ FetchResult *FetchResult

+ type SearchResults struct

+ Metrics models.Metrics

+ type Storage interface

+ Close func() error

+ Type func() Type

+ type Type int

+ const TypeLocalDC

+ const TypeMultiDC

+ const TypeRemoteDC

+ type WriteQuery struct

+ Annotation []byte

+ Attributes Attributes

+ Datapoints ts.Datapoints

+ Raw string

+ Tags models.Tags

+ Unit xtime.Unit

+ func PromWriteTSToM3(timeseries *prompb.TimeSeries) *WriteQuery

+ func (q *WriteQuery) String() string