The highest tagged major version is v3.

series

package

v1.6.2-0...-94e0029 Latest Latest Go to latest Published: May 2, 2024 License: AGPL-3.0 Imports: 31 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

Documentation ¶

Index ¶

func FindSetMatches(pattern string) []string
func NewIndexGatewayClientStore(client logproto.IndexGatewayClient, logger log.Logger) index.ReaderWriter
func NewIndexReaderWriter(schemaCfg config.SchemaConfig, schema series_index.SeriesStoreSchema, ...) index.ReaderWriter
type IndexGatewayClientStore

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.

func NewIndexGatewayClientStore ¶

func NewIndexGatewayClientStore(client logproto.IndexGatewayClient, logger log.Logger) 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
}

IndexGatewayClientStore implements pkg/storage/stores/index.ReaderWriter

func (*IndexGatewayClientStore) GetChunkRefs ¶

func (c *IndexGatewayClientStore) GetChunkRefs(ctx context.Context, _ string, from, through model.Time, allMatchers ...*labels.Matcher) ([]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) 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)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
index

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