storage

package
v0.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 20, 2019 License: Apache-2.0 Imports: 10 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 TranslateQueryToMatchers

func TranslateQueryToMatchers(query string) models.Matchers

TranslateQueryToMatchers converts a graphite query to tag matcher pairs.

Types

type DataOptions

type DataOptions struct {
	Timeout time.Duration // Whether to use a custom timeout, zero if no or positive if yes
}

DataOptions provide data context

type FetchOptions

type FetchOptions struct {
	StartTime time.Time // The start time for the fetch
	EndTime   time.Time // The end time for the fetch
	DataOptions
}

FetchOptions provide context to a fetch

type FetchResult

type FetchResult struct {
	SeriesList []*ts.Series // The aggregated list of results across all underlying storage calls
}

FetchResult provides a fetch result and meta information

func NewFetchResult

func NewFetchResult(ctx context.Context, seriesList []*ts.Series) *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 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) Storage

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

Jump to

Keyboard shortcuts

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