query

Documentation

Index

• Constants
• func NewInProcessClient(t testing.TB, name string, client storepb.StoreClient, extLset labels.Labels) store.Client
• func ParseEval(lines []string, i int) (int, *evalCmd, error)
• func ParseLoad(lines []string, i int) (int, *loadCmd, error)
• func ParseStore(lines []string, i int) (int, *storeCmd, error)
• type Config
  • func BuildQueryConfig(queryAddrs []string) ([]Config, error)
  • func DefaultConfig() Config
  • func LoadConfigs(confYAML []byte) ([]Config, error)
  • func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error
• type EndpointSet
  • func NewEndpointSet(logger log.Logger, reg *prometheus.Registry, ...) *EndpointSet
  • func (e *EndpointSet) Close()
  • func (e *EndpointSet) GetEndpointStatus() []EndpointStatus
  • func (e *EndpointSet) GetExemplarsStores() []*exemplarspb.ExemplarStore
  • func (e *EndpointSet) GetMetricMetadataClients() []metadatapb.MetadataClient
  • func (e *EndpointSet) GetRulesClients() []rulespb.RulesClient
  • func (e *EndpointSet) GetStoreClients() []store.Client
  • func (e *EndpointSet) GetTargetsClients() []targetspb.TargetsClient
  • func (e *EndpointSet) Update(ctx context.Context)
• type EndpointSpec
  • func NewGRPCEndpointSpec(addr string, isStrictStatic bool) EndpointSpec
• type EndpointStatus
• type QueryableCreator
  • func NewQueryableCreator(logger log.Logger, reg prometheus.Registerer, proxy storepb.StoreServer, ...) QueryableCreator

Constants

const (

	// Default minimum and maximum time values used by Prometheus when they are not passed as query parameter.
	MinTime = -9223309901257974
	MaxTime = 9223309901257974
)

Functions

func NewInProcessClient

func NewInProcessClient(t testing.TB, name string, client storepb.StoreClient, extLset labels.Labels) store.Client

func ParseEval

func ParseEval(lines []string, i int) (int, *evalCmd, error)

ParseEval parses eval statements.

func ParseLoad

func ParseLoad(lines []string, i int) (int, *loadCmd, error)

ParseLoad parses load statements.

func ParseStore

func ParseStore(lines []string, i int) (int, *storeCmd, error)

ParseStore parses store statements.

Types

type Config

type Config struct {
	HTTPClientConfig http_util.ClientConfig    `yaml:"http_config"`
	EndpointsConfig  http_util.EndpointsConfig `yaml:",inline"`
}

func BuildQueryConfig

func BuildQueryConfig(queryAddrs []string) ([]Config, error)

BuildQueryConfig returns a query client configuration from a static address.

func DefaultConfig

func DefaultConfig() Config

func LoadConfigs

func LoadConfigs(confYAML []byte) ([]Config, error)

LoadConfigs loads a list of Config from YAML data.

func (*Config) UnmarshalYAML

func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements the yaml.Unmarshaler interface.

type EndpointSet

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

EndpointSet maintains a set of active Thanos endpoints. It is backed up by Endpoint Specifications that are dynamically fetched on every Update() call.

func NewEndpointSet

func NewEndpointSet(
	logger log.Logger,
	reg *prometheus.Registry,
	endpointSpecs func() []EndpointSpec,
	dialOpts []grpc.DialOption,
	unhealthyEndpointTimeout time.Duration,
) *EndpointSet

NewEndpointSet returns a new set of Thanos APIs.

func (*EndpointSet) Close

func (e *EndpointSet) Close()

func (*EndpointSet) GetEndpointStatus

func (e *EndpointSet) GetEndpointStatus() []EndpointStatus

func (*EndpointSet) GetExemplarsStores

func (e *EndpointSet) GetExemplarsStores() []*exemplarspb.ExemplarStore

GetExemplarsStores returns a list of all active exemplars stores.

func (*EndpointSet) GetMetricMetadataClients

func (e *EndpointSet) GetMetricMetadataClients() []metadatapb.MetadataClient

GetMetricMetadataClients returns a list of all active metadata clients.

func (*EndpointSet) GetRulesClients

func (e *EndpointSet) GetRulesClients() []rulespb.RulesClient

GetRulesClients returns a list of all active rules clients.

func (*EndpointSet) GetStoreClients

func (e *EndpointSet) GetStoreClients() []store.Client

GetStoreClients returns a list of all active stores.

func (*EndpointSet) GetTargetsClients

func (e *EndpointSet) GetTargetsClients() []targetspb.TargetsClient

GetTargetsClients returns a list of all active targets clients.

func (*EndpointSet) Update

func (e *EndpointSet) Update(ctx context.Context)

Update updates the endpoint set. It fetches current list of endpoint specs from function and updates the fresh metadata from all endpoints. Keeps around statically defined nodes that were defined with the strict mode.

type EndpointSpec

type EndpointSpec interface {
	// Addr returns Thanos API Address for the endpoint spec. It is used as ID for endpoint.
	Addr() string
	// Metadata returns current labels, component type and min, max ranges for store.
	// It can change for every call for this method.
	// If metadata call fails we assume that store is no longer accessible and we should not use it.
	// NOTE: It is implementation responsibility to retry until context timeout, but a caller responsibility to manage
	// given store connection.
	Metadata(ctx context.Context, client *endpointClients) (*endpointMetadata, error)

	// IsStrictStatic returns true if the endpoint has been statically defined and it is under a strict mode.
	IsStrictStatic() bool
}

func NewGRPCEndpointSpec

func NewGRPCEndpointSpec(addr string, isStrictStatic bool) EndpointSpec

NewGRPCEndpointSpec creates gRPC endpoint spec. It uses InfoAPI to get Metadata.

type EndpointStatus

type EndpointStatus struct {
	Name          string              `json:"name"`
	LastCheck     time.Time           `json:"lastCheck"`
	LastError     *stringError        `json:"lastError"`
	LabelSets     []labels.Labels     `json:"labelSets"`
	ComponentType component.Component `json:"-"`
	MinTime       int64               `json:"minTime"`
	MaxTime       int64               `json:"maxTime"`
}

type QueryableCreator

type QueryableCreator func(deduplicate bool, replicaLabels []string, storeDebugMatchers [][]*labels.Matcher, maxResolutionMillis int64, partialResponse, skipChunks bool) storage.Queryable

QueryableCreator returns implementation of promql.Queryable that fetches data from the proxy store API endpoints. If deduplication is enabled, all data retrieved from it will be deduplicated along all replicaLabels by default. When the replicaLabels argument is not empty it overwrites the global replicaLabels flag. This allows specifying replicaLabels at query time. maxResolutionMillis controls downsampling resolution that is allowed (specified in milliseconds). partialResponse controls `partialResponseDisabled` option of StoreAPI and partial response behavior of proxy.

func NewQueryableCreator

func NewQueryableCreator(logger log.Logger, reg prometheus.Registerer, proxy storepb.StoreServer, maxConcurrentSelects int, selectTimeout time.Duration) QueryableCreator

NewQueryableCreator creates QueryableCreator.