Versions in this module Expand all Collapse all v2 v2.6.2 Aug 12, 2022 Changes in this version + const DefaultIndexShards + var ErrInvalidShardQuery = errors.New("incompatible index shard query") + func ValidateBitPrefixShardFactor(factor uint32) error + type BitPrefixInvertedIndex struct + func NewBitPrefixWithShards(totalShards uint32) (*BitPrefixInvertedIndex, error) + func (ii *BitPrefixInvertedIndex) Add(labels []logproto.LabelAdapter, fp model.Fingerprint) labels.Labels + func (ii *BitPrefixInvertedIndex) Delete(labels labels.Labels, fp model.Fingerprint) + func (ii *BitPrefixInvertedIndex) LabelNames(shard *astmapper.ShardAnnotation) ([]string, error) + func (ii *BitPrefixInvertedIndex) LabelValues(name string, shard *astmapper.ShardAnnotation) ([]string, error) + func (ii *BitPrefixInvertedIndex) Lookup(matchers []*labels.Matcher, shard *astmapper.ShardAnnotation) ([]model.Fingerprint, error) + type Interface interface + Add func(labels []logproto.LabelAdapter, fp model.Fingerprint) labels.Labels + Delete func(labels labels.Labels, fp model.Fingerprint) + LabelNames func(shard *astmapper.ShardAnnotation) ([]string, error) + LabelValues func(name string, shard *astmapper.ShardAnnotation) ([]string, error) + Lookup func(matchers []*labels.Matcher, shard *astmapper.ShardAnnotation) ([]model.Fingerprint, error) + type InvertedIndex struct + func NewWithShards(totalShards uint32) *InvertedIndex + func (ii *InvertedIndex) Add(labels []logproto.LabelAdapter, fp model.Fingerprint) labels.Labels + func (ii *InvertedIndex) Delete(labels labels.Labels, fp model.Fingerprint) + func (ii *InvertedIndex) LabelNames(shard *astmapper.ShardAnnotation) ([]string, error) + func (ii *InvertedIndex) LabelValues(name string, shard *astmapper.ShardAnnotation) ([]string, error) + func (ii *InvertedIndex) Lookup(matchers []*labels.Matcher, shard *astmapper.ShardAnnotation) ([]model.Fingerprint, error) + type Multi struct + func NewMultiInvertedIndex(periods []config.PeriodConfig, indexShards uint32) (*Multi, error) + func (m *Multi) Add(labels []logproto.LabelAdapter, fp model.Fingerprint) (result labels.Labels) + func (m *Multi) Delete(labels labels.Labels, fp model.Fingerprint) + func (m *Multi) LabelNames(t time.Time, shard *astmapper.ShardAnnotation) ([]string, error) + func (m *Multi) LabelValues(t time.Time, name string, shard *astmapper.ShardAnnotation) ([]string, error) + func (m *Multi) Lookup(t time.Time, matchers []*labels.Matcher, shard *astmapper.ShardAnnotation) ([]model.Fingerprint, error)
Go to main page