series

package

v3.0.0 Latest Latest Go to latest Published: Apr 8, 2024 License: AGPL-3.0 Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/grafana/loki

Links

Open Source Insights

Documentation ¶

Index ¶

func FindSetMatches(pattern string) []string
type GatewayClient
type IndexGatewayClientStore
- func NewIndexGatewayClientStore(client GatewayClient, logger log.Logger) *IndexGatewayClientStore
type IndexReaderWriter
- func NewIndexReaderWriter(schemaCfg config.SchemaConfig, schema series_index.SeriesStoreSchema, ...) *IndexReaderWriter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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) ([]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) ([]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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
index

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL