Documentation
¶
Index ¶
- func FindSetMatches(pattern string) []string
- func NewIndexGatewayClientStore(client logproto.IndexGatewayClient, fallbackStore index.Reader) index.ReaderWriter
- func NewIndexReaderWriter(schemaCfg config.SchemaConfig, schema series_index.SeriesStoreSchema, ...) index.ReaderWriter
- type IndexGatewayClientStore
- func (c *IndexGatewayClientStore) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, ...) ([]logproto.ChunkRef, error)
- func (c *IndexGatewayClientStore) GetSeries(ctx context.Context, userID string, from, through model.Time, ...) ([]labels.Labels, error)
- func (c *IndexGatewayClientStore) IndexChunk(_ context.Context, _, _ model.Time, _ chunk.Chunk) error
- func (c *IndexGatewayClientStore) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error)
- func (c *IndexGatewayClientStore) LabelValuesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error)
- func (c *IndexGatewayClientStore) LabelVolume(ctx context.Context, userID string, from, through model.Time, limit int32, ...) (*logproto.LabelVolumeResponse, error)
- func (c *IndexGatewayClientStore) SetChunkFilterer(chunkFilter chunk.RequestChunkFilterer)
- func (c *IndexGatewayClientStore) Stats(ctx context.Context, userID string, from, through model.Time, ...) (*stats.Stats, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FindSetMatches ¶
FindSetMatches returns list of values that can be equality matched on. copied from Prometheus querier.go, removed check for Prometheus wrapper.
func NewIndexGatewayClientStore ¶
func NewIndexGatewayClientStore(client logproto.IndexGatewayClient, fallbackStore index.Reader) index.ReaderWriter
func NewIndexReaderWriter ¶
func NewIndexReaderWriter(schemaCfg config.SchemaConfig, schema series_index.SeriesStoreSchema, index series_index.Client, fetcher *fetcher.Fetcher, chunkBatchSize int, writeDedupeCache cache.Cache) index.ReaderWriter
Types ¶
type IndexGatewayClientStore ¶
type IndexGatewayClientStore struct {
// contains filtered or unexported fields
}
func (*IndexGatewayClientStore) GetChunkRefs ¶
func (*IndexGatewayClientStore) IndexChunk ¶
func (*IndexGatewayClientStore) LabelNamesForMetricName ¶
func (c *IndexGatewayClientStore) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, metricName string) ([]string, error)
LabelNamesForMetricName retrieves all label names for a metric name.
func (*IndexGatewayClientStore) LabelValuesForMetricName ¶
func (*IndexGatewayClientStore) LabelVolume ¶
func (*IndexGatewayClientStore) SetChunkFilterer ¶
func (c *IndexGatewayClientStore) SetChunkFilterer(chunkFilter chunk.RequestChunkFilterer)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.