querier

Documentation

Index

• Variables
• type Config
  • func (in *Config) DeepCopy() *Config
  • func (in *Config) DeepCopyInto(out *Config)
  • func (*Config) Descriptor() ([]byte, []int)
  • func (in *Config) FlagSet(prefix ...string) *pflag.FlagSet
  • func (x *Config) GetBatchIterators() bool
  • func (x *Config) GetDefaultEvaluationInterval() *durationpb.Duration
  • func (x *Config) GetIngesterMetadataStreaming() bool
  • func (x *Config) GetIngesterStreaming() bool
  • func (x *Config) GetIterators() bool
  • func (x *Config) GetLookbackDelta() *durationpb.Duration
  • func (x *Config) GetMaxConcurrent() int32
  • func (x *Config) GetMaxQueryIntoFuture() *durationpb.Duration
  • func (x *Config) GetMaxSamples() int32
  • func (x *Config) GetPerStepStatsEnabled() bool
  • func (x *Config) GetQueryIngestersWithin() *durationpb.Duration
  • func (x *Config) GetQueryStoreAfter() *durationpb.Duration
  • func (x *Config) GetQueryStoreForLabelsEnabled() bool
  • func (x *Config) GetShuffleShardingIngestersLookbackPeriod() *durationpb.Duration
  • func (x *Config) GetThanosEngine() bool
  • func (x *Config) GetTimeout() *durationpb.Duration
  • func (*Config) ProtoMessage()
  • func (x *Config) ProtoReflect() protoreflect.Message
  • func (x *Config) Reset()
  • func (x *Config) String() string

Variables

var File_github_com_rancher_opni_internal_cortex_config_querier_querier_proto protoreflect.FileDescriptor

Types

type Config

type Config struct {

	// The maximum number of concurrent queries.
	MaxConcurrent *int32 `protobuf:"varint,1,opt,name=max_concurrent,json=maxConcurrent,proto3,oneof" json:"max_concurrent,omitempty"`
	// The timeout for a query.
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Use iterators to execute query, as opposed to fully materialising the series in memory.
	Iterators *bool `protobuf:"varint,3,opt,name=iterators,proto3,oneof" json:"iterators,omitempty"`
	// Use batch iterators to execute query, as opposed to fully materialising the series in memory.  Takes precedent over the -querier.iterators flag.
	BatchIterators *bool `protobuf:"varint,4,opt,name=batch_iterators,json=batchIterators,proto3,oneof" json:"batch_iterators,omitempty"`
	// Use streaming RPCs to query ingester.
	IngesterStreaming *bool `protobuf:"varint,5,opt,name=ingester_streaming,json=ingesterStreaming,proto3,oneof" json:"ingester_streaming,omitempty"`
	// Use streaming RPCs for metadata APIs from ingester.
	IngesterMetadataStreaming *bool `` /* 145-byte string literal not displayed */
	// Maximum number of samples a single query can load into memory.
	MaxSamples *int32 `protobuf:"varint,7,opt,name=max_samples,json=maxSamples,proto3,oneof" json:"max_samples,omitempty"`
	// Maximum lookback beyond which queries are not sent to ingester. 0 means all queries are sent to ingester.
	QueryIngestersWithin *durationpb.Duration `protobuf:"bytes,8,opt,name=query_ingesters_within,json=queryIngestersWithin,proto3" json:"query_ingesters_within,omitempty"`
	// Deprecated (Querying long-term store for labels will be always enabled in the future.): Query long-term store for series, label values and label names APIs.
	QueryStoreForLabelsEnabled *bool `` /* 152-byte string literal not displayed */
	// Enable returning samples stats per steps in query response.
	PerStepStatsEnabled *bool `` /* 130-byte string literal not displayed */
	// The time after which a metric should be queried from storage and not just ingesters. 0 means all queries are sent to store. When running the blocks storage, if this option is enabled, the time range of the query sent to the store will be manipulated to ensure the query end is not more recent than 'now - query-store-after'.
	QueryStoreAfter *durationpb.Duration `protobuf:"bytes,11,opt,name=query_store_after,json=queryStoreAfter,proto3" json:"query_store_after,omitempty"`
	// Maximum duration into the future you can query. 0 to disable.
	MaxQueryIntoFuture *durationpb.Duration `protobuf:"bytes,12,opt,name=max_query_into_future,json=maxQueryIntoFuture,proto3" json:"max_query_into_future,omitempty"`
	// The default evaluation interval or step size for subqueries.
	DefaultEvaluationInterval *durationpb.Duration `` /* 139-byte string literal not displayed */
	// Time since the last sample after which a time series is considered stale and ignored by expression evaluations.
	LookbackDelta *durationpb.Duration `protobuf:"bytes,14,opt,name=lookback_delta,json=lookbackDelta,proto3" json:"lookback_delta,omitempty"`
	// When distributor's sharding strategy is shuffle-sharding and this setting is > 0, queriers fetch in-memory series from the minimum set of required ingesters, selecting only ingesters which may have received series since 'now - lookback period'. The lookback period should be greater or equal than the configured 'query store after' and 'query ingesters within'. If this setting is 0, queriers always query all ingesters (ingesters shuffle sharding on read path is disabled).
	ShuffleShardingIngestersLookbackPeriod *durationpb.Duration `` /* 182-byte string literal not displayed */
	// Experimental. Use Thanos promql engine https://github.com/thanos-io/promql-engine rather than the Prometheus promql engine.
	ThanosEngine *bool `protobuf:"varint,16,opt,name=thanos_engine,json=thanosEngine,proto3,oneof" json:"thanos_engine,omitempty"`
	// contains filtered or unexported fields
}

func (*Config) DeepCopy

func (in *Config) DeepCopy() *Config

func (*Config) DeepCopyInto

func (in *Config) DeepCopyInto(out *Config)

func (*Config) Descriptor

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) FlagSet

func (in *Config) FlagSet(prefix ...string) *pflag.FlagSet

func (*Config) GetBatchIterators

func (x *Config) GetBatchIterators() bool

func (*Config) GetDefaultEvaluationInterval

func (x *Config) GetDefaultEvaluationInterval() *durationpb.Duration

func (*Config) GetIngesterMetadataStreaming

func (x *Config) GetIngesterMetadataStreaming() bool

func (*Config) GetIngesterStreaming

func (x *Config) GetIngesterStreaming() bool

func (*Config) GetIterators

func (x *Config) GetIterators() bool

func (*Config) GetLookbackDelta

func (x *Config) GetLookbackDelta() *durationpb.Duration

func (*Config) GetMaxConcurrent

func (x *Config) GetMaxConcurrent() int32

func (*Config) GetMaxQueryIntoFuture

func (x *Config) GetMaxQueryIntoFuture() *durationpb.Duration

func (*Config) GetMaxSamples

func (x *Config) GetMaxSamples() int32

func (*Config) GetPerStepStatsEnabled

func (x *Config) GetPerStepStatsEnabled() bool

func (*Config) GetQueryIngestersWithin

func (x *Config) GetQueryIngestersWithin() *durationpb.Duration

func (*Config) GetQueryStoreAfter

func (x *Config) GetQueryStoreAfter() *durationpb.Duration

func (*Config) GetQueryStoreForLabelsEnabled

func (x *Config) GetQueryStoreForLabelsEnabled() bool

func (*Config) GetShuffleShardingIngestersLookbackPeriod

func (x *Config) GetShuffleShardingIngestersLookbackPeriod() *durationpb.Duration

func (*Config) GetThanosEngine

func (x *Config) GetThanosEngine() bool

func (*Config) GetTimeout

func (x *Config) GetTimeout() *durationpb.Duration

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset

func (x *Config) Reset()

func (*Config) String

func (x *Config) String() string