Documentation ¶
Overview ¶
Package storage is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetQueryTerminatorTagName ¶
GetQueryTerminatorTagName will return the name for the terminator matcher in the given pattern. This is useful for filtering out any additional results.
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 }
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 ¶ added in v0.15.16
type M3WrappedStorageOptions struct {
AggregateNamespacesAllData bool
}
M3WrappedStorageOptions is the graphite storage options.
type MockStorage ¶ added in v0.15.12
type MockStorage struct {
// contains filtered or unexported fields
}
MockStorage is a mock of Storage interface
func NewMockStorage ¶ added in v0.15.12
func NewMockStorage(ctrl *gomock.Controller) *MockStorage
NewMockStorage creates a new mock instance
func (*MockStorage) EXPECT ¶ added in v0.15.12
func (m *MockStorage) EXPECT() *MockStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockStorage) FetchByQuery ¶ added in v0.15.12
func (m *MockStorage) FetchByQuery(arg0 context.Context, arg1 string, arg2 FetchOptions) (*FetchResult, error)
FetchByQuery mocks base method
type MockStorageMockRecorder ¶ added in v0.15.12
type MockStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockStorageMockRecorder is the mock recorder for MockStorage
func (*MockStorageMockRecorder) FetchByQuery ¶ added in v0.15.12
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, enforcer cost.ChainedEnforcer, instrumentOpts instrument.Options, opts M3WrappedStorageOptions, ) Storage
NewM3WrappedStorage creates a graphite storage wrapper around an m3query storage instance.