query

Documentation

Index

• 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 EndpointSet
  • func NewEndpointSet(now nowFunc, 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) GetQueryAPIClients() []querypb.QueryClient
  • 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 EndpointStatus
• type GRPCEndpointSpec
  • func NewGRPCEndpointSpec(addr string, isStrictStatic bool) *GRPCEndpointSpec
  • func (es *GRPCEndpointSpec) Addr() string
  • func (es *GRPCEndpointSpec) IsStrictStatic() bool
• type QueryableCreator
  • func NewQueryableCreator(logger log.Logger, reg prometheus.Registerer, proxy storepb.StoreServer, ...) QueryableCreator

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 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(
	now nowFunc,
	logger log.Logger,
	reg *prometheus.Registry,
	endpointSpecs func() []*GRPCEndpointSpec,
	dialOpts []grpc.DialOption,
	unhealthyEndpointTimeout time.Duration,
	endpointInfoTimeout 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) GetQueryAPIClients

func (e *EndpointSet) GetQueryAPIClients() []querypb.QueryClient

GetQueryAPIClients returns a list of all active query API 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 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 GRPCEndpointSpec

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

func NewGRPCEndpointSpec

func NewGRPCEndpointSpec(addr string, isStrictStatic bool) *GRPCEndpointSpec

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

func (*GRPCEndpointSpec) Addr

func (es *GRPCEndpointSpec) Addr() string

func (*GRPCEndpointSpec) IsStrictStatic

func (es *GRPCEndpointSpec) IsStrictStatic() bool

IsStrictStatic returns true if the endpoint has been statically defined and it is under a strict mode.

type QueryableCreator

type QueryableCreator func(deduplicate bool, replicaLabels []string, storeDebugMatchers [][]*labels.Matcher, maxResolutionMillis int64, partialResponse, enableQueryPushdown, skipChunks bool, shardInfo *storepb.ShardInfo) 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.