index

package

v2.4.3 Latest Latest Go to latest Published: Feb 9, 2022 License: AGPL-3.0 Imports: 15 Imported by: 0

Details

View Source

const DefaultIndexShards = 32

View Source

var ErrInvalidShardQuery = errors.New("incompatible index shard query")

This section is empty.

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

InvertedIndex implements a in-memory inverted index from label pairs to fingerprints. It is sharded to reduce lock contention on writes.

func NewWithShards(totalShards uint32) *InvertedIndex

func (ii *InvertedIndex) Add(labels []logproto.LabelAdapter, fp model.Fingerprint) labels.Labels

Add a fingerprint under the specified labels. NOTE: memory for `labels` is unsafe; anything retained beyond the life of this function must be copied

func (ii *InvertedIndex) Delete(labels labels.Labels, fp model.Fingerprint)

Delete a fingerprint with the given label pairs.

func (ii *InvertedIndex) LabelNames(shard *astmapper.ShardAnnotation) ([]string, error)

LabelNames returns all label names.

func (ii *InvertedIndex) LabelValues(name string, shard *astmapper.ShardAnnotation) ([]string, error)

LabelValues returns the values for the given label.

func (ii *InvertedIndex) Lookup(matchers []*labels.Matcher, shard *astmapper.ShardAnnotation) ([]model.Fingerprint, error)

Lookup all fingerprints for the provided matchers.