Documentation
¶
Index ¶
- func FindSetMatches(pattern string) []string
- type IndexGatewayClient
- 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) 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)
- type IndexStore
- func (c *IndexStore) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, ...) ([]logproto.ChunkRef, error)
- func (c *IndexStore) GetSeries(ctx context.Context, userID string, from, through model.Time, ...) ([]labels.Labels, error)
- func (c *IndexStore) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error)
- func (c *IndexStore) LabelValuesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error)
- func (c *IndexStore) SetChunkFilterer(f chunk.RequestChunkFilterer)
- type IndexWriter
- type SchemaWrites
- type Writer
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.
Types ¶
type IndexGatewayClient ¶
type IndexGatewayClient interface {
GetChunkRef(ctx context.Context, in *indexgatewaypb.GetChunkRefRequest, opts ...grpc.CallOption) (*indexgatewaypb.GetChunkRefResponse, error)
LabelNamesForMetricName(ctx context.Context, in *indexgatewaypb.LabelNamesForMetricNameRequest, opts ...grpc.CallOption) (*indexgatewaypb.LabelResponse, error)
LabelValuesForMetricName(ctx context.Context, in *indexgatewaypb.LabelValuesForMetricNameRequest, opts ...grpc.CallOption) (*indexgatewaypb.LabelResponse, error)
}
type IndexGatewayClientStore ¶
type IndexGatewayClientStore struct {
*IndexStore
// contains filtered or unexported fields
}
func NewIndexGatewayClientStore ¶
func NewIndexGatewayClientStore(client IndexGatewayClient, index *IndexStore) *IndexGatewayClientStore
func (*IndexGatewayClientStore) GetChunkRefs ¶
type IndexStore ¶
type IndexStore struct {
// contains filtered or unexported fields
}
func NewIndexStore ¶
func NewIndexStore(schemaCfg config.SchemaConfig, schema index.SeriesStoreSchema, index index.Client, fetcher chunkFetcher, chunkBatchSize int) *IndexStore
func (*IndexStore) GetChunkRefs ¶
func (*IndexStore) LabelNamesForMetricName ¶
func (c *IndexStore) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, metricName string) ([]string, error)
LabelNamesForMetricName retrieves all label names for a metric name.
func (*IndexStore) LabelValuesForMetricName ¶
func (*IndexStore) SetChunkFilterer ¶
func (c *IndexStore) SetChunkFilterer(f chunk.RequestChunkFilterer)
type IndexWriter ¶
type IndexWriter interface {
NewWriteBatch() index.WriteBatch
BatchWrite(context.Context, index.WriteBatch) error
}
type SchemaWrites ¶
type SchemaWrites interface {
GetChunkWriteEntries(from, through model.Time, userID string, metricName string, labels labels.Labels, chunkID string) ([]index.Entry, error)
GetCacheKeysAndLabelWriteEntries(from, through model.Time, userID string, metricName string, labels labels.Labels, chunkID string) ([]string, [][]index.Entry, error)
}
type Writer ¶
type Writer struct {
DisableIndexDeduplication bool
// contains filtered or unexported fields
}
func NewWriter ¶
func NewWriter(fetcher *fetcher.Fetcher, schemaCfg config.SchemaConfig, indexWriter IndexWriter, schema SchemaWrites, writeDedupeCache cache.Cache, disableIndexDeduplication bool) *Writer
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.