series

Documentation

Index

• func FindSetMatches(pattern string) []string
• type GatewayClient
• type IndexGatewayClientStore
  • func NewIndexGatewayClientStore(client GatewayClient, logger log.Logger) *IndexGatewayClientStore
  • func (c *IndexGatewayClientStore) GetChunkRefs(ctx context.Context, _ string, from, through model.Time, ...) ([]logproto.ChunkRef, error)
  • func (c *IndexGatewayClientStore) GetSeries(ctx context.Context, _ string, from, through model.Time, ...) ([]labels.Labels, error)
  • func (c *IndexGatewayClientStore) GetShards(ctx context.Context, _ string, from, through model.Time, ...) (*logproto.ShardsResponse, error)
  • func (c *IndexGatewayClientStore) HasForSeries(_, _ model.Time) (sharding.ForSeries, bool)
  • func (c *IndexGatewayClientStore) IndexChunk(_ context.Context, _, _ model.Time, _ chunk.Chunk) error
  • func (c *IndexGatewayClientStore) LabelNamesForMetricName(ctx context.Context, _ string, from, through model.Time, metricName string, ...) ([]string, error)
  • func (c *IndexGatewayClientStore) LabelValuesForMetricName(ctx context.Context, _ string, from, through model.Time, metricName string, ...) ([]string, error)
  • func (c *IndexGatewayClientStore) SetChunkFilterer(_ chunk.RequestChunkFilterer)
  • func (c *IndexGatewayClientStore) Stats(ctx context.Context, _ string, from, through model.Time, ...) (*stats.Stats, error)
  • func (c *IndexGatewayClientStore) Volume(ctx context.Context, _ string, from, through model.Time, limit int32, ...) (*logproto.VolumeResponse, error)
• type IndexReaderWriter
  • func NewIndexReaderWriter(schemaCfg config.SchemaConfig, schema series_index.SeriesStoreSchema, ...) *IndexReaderWriter
  • func (c *IndexReaderWriter) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, ...) ([]logproto.ChunkRef, error)
  • func (c *IndexReaderWriter) GetSeries(ctx context.Context, userID string, from, through model.Time, ...) ([]labels.Labels, error)
  • func (c *IndexReaderWriter) GetShards(_ context.Context, _ string, _, _ model.Time, _ uint64, _ chunk.Predicate) (*logproto.ShardsResponse, error)
  • func (c *IndexReaderWriter) HasForSeries(_, _ model.Time) (sharding.ForSeries, bool)
  • func (c *IndexReaderWriter) IndexChunk(ctx context.Context, from, through model.Time, chk chunk.Chunk) error
  • func (c *IndexReaderWriter) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error)
  • func (c *IndexReaderWriter) LabelValuesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error)
  • func (c *IndexReaderWriter) SetChunkFilterer(f chunk.RequestChunkFilterer)
  • func (c *IndexReaderWriter) Stats(_ context.Context, _ string, _, _ model.Time, _ ...*labels.Matcher) (*stats.Stats, error)
  • func (c *IndexReaderWriter) Volume(_ context.Context, _ string, _, _ model.Time, _ int32, _ []string, _ string, ...) (*logproto.VolumeResponse, error)

Functions

func FindSetMatches

func FindSetMatches(pattern string) []string

FindSetMatches returns list of values that can be equality matched on. copied from Prometheus querier.go, removed check for Prometheus wrapper.

Types

type GatewayClient

type GatewayClient interface {
	GetChunkRef(ctx context.Context, in *logproto.GetChunkRefRequest) (*logproto.GetChunkRefResponse, error)
	GetSeries(ctx context.Context, in *logproto.GetSeriesRequest) (*logproto.GetSeriesResponse, error)
	LabelNamesForMetricName(ctx context.Context, in *logproto.LabelNamesForMetricNameRequest) (*logproto.LabelResponse, error)
	LabelValuesForMetricName(ctx context.Context, in *logproto.LabelValuesForMetricNameRequest) (*logproto.LabelResponse, error)
	GetStats(ctx context.Context, in *logproto.IndexStatsRequest) (*logproto.IndexStatsResponse, error)
	GetVolume(ctx context.Context, in *logproto.VolumeRequest) (*logproto.VolumeResponse, error)

	GetShards(ctx context.Context, in *logproto.ShardsRequest) (*logproto.ShardsResponse, error)
}

NB(owen-d): mostly modeled off of the proto-generated `logproto.IndexGatewayClient`, but decoupled from explicit GRPC dependencies to work well with streaming grpc methods

type IndexGatewayClientStore

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

IndexGatewayClientStore implements pkg/storage/stores/index.ReaderWriter

func NewIndexGatewayClientStore

func NewIndexGatewayClientStore(client GatewayClient, logger log.Logger) *IndexGatewayClientStore

func (*IndexGatewayClientStore) GetChunkRefs

func (c *IndexGatewayClientStore) GetChunkRefs(ctx context.Context, _ string, from, through model.Time, predicate chunk.Predicate) ([]logproto.ChunkRef, error)

func (*IndexGatewayClientStore) GetSeries

func (c *IndexGatewayClientStore) GetSeries(ctx context.Context, _ string, from, through model.Time, matchers ...*labels.Matcher) ([]labels.Labels, error)

func (*IndexGatewayClientStore) GetShards

func (c *IndexGatewayClientStore) GetShards(
	ctx context.Context,
	_ string,
	from, through model.Time,
	targetBytesPerShard uint64,
	predicate chunk.Predicate,
) (*logproto.ShardsResponse, error)

func (*IndexGatewayClientStore) HasForSeries

func (c *IndexGatewayClientStore) HasForSeries(_, _ model.Time) (sharding.ForSeries, bool)

IndexGatewayClientStore does not implement tsdb.ForSeries; that is implemented by the index-gws themselves and will be called during the `GetShards() invocation`

func (*IndexGatewayClientStore) IndexChunk

func (c *IndexGatewayClientStore) IndexChunk(_ context.Context, _, _ model.Time, _ chunk.Chunk) error

func (*IndexGatewayClientStore) LabelNamesForMetricName

func (c *IndexGatewayClientStore) LabelNamesForMetricName(ctx context.Context, _ string, from, through model.Time, metricName string, matchers ...*labels.Matcher) ([]string, error)

LabelNamesForMetricName retrieves all label names for a metric name.

func (*IndexGatewayClientStore) LabelValuesForMetricName

func (c *IndexGatewayClientStore) LabelValuesForMetricName(ctx context.Context, _ string, from, through model.Time, metricName string, labelName string, matchers ...*labels.Matcher) ([]string, error)

func (*IndexGatewayClientStore) SetChunkFilterer

func (c *IndexGatewayClientStore) SetChunkFilterer(_ chunk.RequestChunkFilterer)

func (*IndexGatewayClientStore) Stats

func (c *IndexGatewayClientStore) Stats(ctx context.Context, _ string, from, through model.Time, matchers ...*labels.Matcher) (*stats.Stats, error)

func (*IndexGatewayClientStore) Volume

func (c *IndexGatewayClientStore) Volume(ctx context.Context, _ string, from, through model.Time, limit int32, targetLabels []string, aggregateBy string, matchers ...*labels.Matcher) (*logproto.VolumeResponse, error)

type IndexReaderWriter

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

IndexReaderWriter implements pkg/storage/stores/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) *IndexReaderWriter

func (*IndexReaderWriter) GetChunkRefs

func (c *IndexReaderWriter) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, predicate chunk.Predicate) ([]logproto.ChunkRef, error)

func (*IndexReaderWriter) GetSeries

func (c *IndexReaderWriter) GetSeries(ctx context.Context, userID string, from, through model.Time, matchers ...*labels.Matcher) ([]labels.Labels, error)

func (*IndexReaderWriter) GetShards

func (c *IndexReaderWriter) GetShards(
	_ context.Context,
	_ string,
	_, _ model.Time,
	_ uint64,
	_ chunk.Predicate,
) (*logproto.ShardsResponse, error)

old index stores do not implement dynamic sharidng -- skip

func (*IndexReaderWriter) HasForSeries

func (c *IndexReaderWriter) HasForSeries(_, _ model.Time) (sharding.ForSeries, bool)

old index stores do not implement tsdb.ForSeries -- skip

func (*IndexReaderWriter) IndexChunk

func (c *IndexReaderWriter) IndexChunk(ctx context.Context, from, through model.Time, chk chunk.Chunk) error

func (*IndexReaderWriter) LabelNamesForMetricName

func (c *IndexReaderWriter) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, metricName string, matchers ...*labels.Matcher) ([]string, error)

LabelNamesForMetricName retrieves all label names for a metric name.

func (*IndexReaderWriter) LabelValuesForMetricName

func (c *IndexReaderWriter) LabelValuesForMetricName(ctx context.Context, userID string, from, through model.Time, metricName string, labelName string, matchers ...*labels.Matcher) ([]string, error)

func (*IndexReaderWriter) SetChunkFilterer

func (c *IndexReaderWriter) SetChunkFilterer(f chunk.RequestChunkFilterer)

func (*IndexReaderWriter) Stats

func (c *IndexReaderWriter) Stats(_ context.Context, _ string, _, _ model.Time, _ ...*labels.Matcher) (*stats.Stats, error)

old index stores do not implement stats -- skip

func (*IndexReaderWriter) Volume

func (c *IndexReaderWriter) Volume(_ context.Context, _ string, _, _ model.Time, _ int32, _ []string, _ string, _ ...*labels.Matcher) (*logproto.VolumeResponse, error)

old index stores do not implement label volume -- skip