Documentation
¶
Index ¶
- type Config
- type Store
- func (s *Store) GetShards(_ context.Context, _ string, _ model.Time, _ model.Time, _ uint64, ...) (*logproto.ShardsResponse, error)
- func (s *Store) LabelNamesForMetricName(ctx context.Context, _ string, from, through model.Time, _ string, ...) ([]string, error)
- func (s *Store) LabelValuesForMetricName(ctx context.Context, _ string, from, through model.Time, _ string, ...) ([]string, error)
- func (s *Store) SelectLogs(ctx context.Context, req logql.SelectLogParams) (iter.EntryIterator, error)
- func (s *Store) SelectSamples(ctx context.Context, req logql.SelectSampleParams) (iter.SampleIterator, error)
- func (s *Store) SelectSeries(ctx context.Context, req logql.SelectLogParams) ([]logproto.SeriesIdentifier, error)
- func (s *Store) Stats(_ context.Context, _ string, _ model.Time, _ model.Time, _ ...*labels.Matcher) (*stats.Stats, error)
- func (s *Store) String() string
- func (s *Store) Volume(_ context.Context, _ string, _ model.Time, _ model.Time, _ int32, _ []string, ...) (*logproto.VolumeResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Enabled bool `yaml:"enabled" doc:"description=Enable the dataobj querier."`
From storageconfig.DayTime `` /* 158-byte string literal not displayed */
ShardFactor int `yaml:"shard_factor" doc:"description=The number of shards to use for the dataobj querier."`
}
func (*Config) PeriodConfig ¶
func (c *Config) PeriodConfig() config.PeriodConfig
func (*Config) RegisterFlags ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store implements querier.Store for querying data objects.
func (*Store) GetShards ¶
func (s *Store) GetShards(_ context.Context, _ string, _ model.Time, _ model.Time, _ uint64, _ chunk.Predicate) (*logproto.ShardsResponse, error)
GetShards implements querier.Store
func (*Store) LabelNamesForMetricName ¶
func (s *Store) LabelNamesForMetricName(ctx context.Context, _ string, from, through model.Time, _ string, matchers ...*labels.Matcher) ([]string, error)
LabelNamesForMetricName implements querier.Store
func (*Store) LabelValuesForMetricName ¶
func (s *Store) LabelValuesForMetricName(ctx context.Context, _ string, from, through model.Time, _ string, labelName string, matchers ...*labels.Matcher) ([]string, error)
LabelValuesForMetricName implements querier.Store
func (*Store) SelectLogs ¶
func (s *Store) SelectLogs(ctx context.Context, req logql.SelectLogParams) (iter.EntryIterator, error)
SelectLogs implements querier.Store
func (*Store) SelectSamples ¶
func (s *Store) SelectSamples(ctx context.Context, req logql.SelectSampleParams) (iter.SampleIterator, error)
SelectSamples implements querier.Store
func (*Store) SelectSeries ¶
func (s *Store) SelectSeries(ctx context.Context, req logql.SelectLogParams) ([]logproto.SeriesIdentifier, error)
SelectSeries implements querier.Store
Source Files
Click to show internal directories.
Click to hide internal directories.