storage

Documentation

Overview

Package storage is a generated GoMock package.

Index

• func GetQueryTerminatorTagName(query string) []byte
• func TranslateQueryToMatchersWithTerminator(query string) (models.Matchers, error)
• type DataOptions
• type FetchOptions
• type FetchResult
  • func NewFetchResult(ctx context.Context, seriesList []*ts.Series, resultMeta block.ResultMetadata) *FetchResult
  • func (fr *FetchResult) Close() error
  • func (fr *FetchResult) Reset()
• type M3WrappedStorageOptions
• type MockStorage
  • func NewMockStorage(ctrl *gomock.Controller) *MockStorage
  • func (m *MockStorage) EXPECT() *MockStorageMockRecorder
  • func (m *MockStorage) FetchByQuery(arg0 context.Context, arg1 string, arg2 FetchOptions) (*FetchResult, error)
• type MockStorageMockRecorder
  • func (mr *MockStorageMockRecorder) FetchByQuery(arg0, arg1, arg2 interface{}) *gomock.Call
• type Storage
  • func NewM3WrappedStorage(m3storage storage.Storage, m3dbOpts m3db.Options, ...) Storage

Functions

func GetQueryTerminatorTagName

func GetQueryTerminatorTagName(query string) []byte

GetQueryTerminatorTagName will return the name for the terminator matcher in the given pattern. This is useful for filtering out any additional results.

func TranslateQueryToMatchersWithTerminator

func TranslateQueryToMatchersWithTerminator(
	query string,
) (models.Matchers, error)

TranslateQueryToMatchersWithTerminator converts a graphite query to tag matcher pairs, and adds a terminator matcher to the end.

Types

type DataOptions

type DataOptions struct {
	// Timeout determines a custom timeout for the context. If set to 0, uses
	// the default timeout.
	Timeout time.Duration
	// Limit is the limit for number of datapoints to retrieve.
	Limit int
}

DataOptions provide data context.

type FetchOptions

type FetchOptions struct {
	// StartTime is the start time for the fetch.
	StartTime time.Time
	// EndTime is the end time for the fetch.
	EndTime time.Time
	// DataOptions are the options for the fetch.
	DataOptions
	// Source is the query source.
	Source []byte
}

FetchOptions provides context to a fetch expression.

type FetchResult

type FetchResult struct {
	// SeriesList is the aggregated list of results across all underlying storage
	// calls.
	SeriesList []*ts.Series
	// Metadata contains any additional metadata indicating information about
	// series execution.
	Metadata block.ResultMetadata
}

FetchResult provides a fetch result and meta information.

func NewFetchResult

func NewFetchResult(
	ctx context.Context,
	seriesList []*ts.Series,
	resultMeta block.ResultMetadata,
) *FetchResult

NewFetchResult is a convenience method for creating a FetchResult.

func (*FetchResult) Close

func (fr *FetchResult) Close() error

Close will return the fetch result to the pool.

func (*FetchResult) Reset

func (fr *FetchResult) Reset()

Reset will wipe out existing fetch result data.

type M3WrappedStorageOptions

type M3WrappedStorageOptions struct {
	AggregateNamespacesAllData                 bool
	ShiftTimeStart                             time.Duration
	ShiftTimeEnd                               time.Duration
	ShiftStepsStart                            int
	ShiftStepsEnd                              int
	ShiftStepsStartWhenAtResolutionBoundary    *int
	ShiftStepsEndWhenAtResolutionBoundary      *int
	ShiftStepsStartWhenEndAtResolutionBoundary *int
	ShiftStepsEndWhenStartAtResolutionBoundary *int
	RenderPartialStart                         bool
	RenderPartialEnd                           bool
	RenderSeriesAllNaNs                        bool
	CompileEscapeAllNotOnlyQuotes              bool
}

M3WrappedStorageOptions is the graphite storage options.

type MockStorage

type MockStorage struct {
	// contains filtered or unexported fields
}

MockStorage is a mock of Storage interface

func NewMockStorage

func NewMockStorage(ctrl *gomock.Controller) *MockStorage

NewMockStorage creates a new mock instance

func (*MockStorage) EXPECT

func (m *MockStorage) EXPECT() *MockStorageMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockStorage) FetchByQuery

func (m *MockStorage) FetchByQuery(arg0 context.Context, arg1 string, arg2 FetchOptions) (*FetchResult, error)

FetchByQuery mocks base method

type MockStorageMockRecorder

type MockStorageMockRecorder struct {
	// contains filtered or unexported fields
}

MockStorageMockRecorder is the mock recorder for MockStorage

func (*MockStorageMockRecorder) FetchByQuery

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

FetchByQuery indicates an expected call of FetchByQuery

type Storage

type Storage interface {
	// FetchByQuery fetches timeseries data based on a query.
	FetchByQuery(
		ctx context.Context, query string, opts FetchOptions,
	) (*FetchResult, error)
}

Storage provides an interface for retrieving timeseries values or names based upon a query or path.

func NewM3WrappedStorage

func NewM3WrappedStorage(
	m3storage storage.Storage,
	m3dbOpts m3db.Options,
	instrumentOpts instrument.Options,
	opts M3WrappedStorageOptions,
) Storage

NewM3WrappedStorage creates a graphite storage wrapper around an m3query storage instance.