index

Documentation

Index

• Variables
• func NewStore() *store.IndexStore
• type Config
  • func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
• type Index
  • func NewIndex(logger log.Logger, s Store, cfg Config) *Index
  • func (i *Index) GetBlocks(tx *bbolt.Tx, list *metastorev1.BlockList) ([]*metastorev1.BlockMeta, error)
  • func (i *Index) GetTenantStats(tenant string) *metastorev1.TenantStats
  • func (i *Index) Init(tx *bbolt.Tx) error
  • func (i *Index) InsertBlock(tx *bbolt.Tx, b *metastorev1.BlockMeta) error
  • func (i *Index) QueryMetadata(tx *bbolt.Tx, query MetadataQuery) ([]*metastorev1.BlockMeta, error)
  • func (i *Index) QueryMetadataLabels(tx *bbolt.Tx, query MetadataQuery) ([]*typesv1.Labels, error)
  • func (i *Index) ReplaceBlocks(tx *bbolt.Tx, compacted *metastorev1.CompactedBlocks) error
  • func (i *Index) Restore(tx *bbolt.Tx) error
• type InvalidQueryError
  • func (e *InvalidQueryError) Error() string
• type MetadataQuery
  • func (q *MetadataQuery) String() string
• type Store

Variables

var DefaultConfig = Config{
	ShardCacheSize:      2000,
	BlockReadCacheSize:  100000,
	BlockWriteCacheSize: 10000,
	// contains filtered or unexported fields
}

var ErrBlockExists = fmt.Errorf("block already exists")

Functions

func NewStore

func NewStore() *store.IndexStore

Types

type Config

type Config struct {
	ShardCacheSize      int `yaml:"shard_cache_size"`
	BlockWriteCacheSize int `yaml:"block_write_cache_size"`
	BlockReadCacheSize  int `yaml:"block_read_cache_size"`
	// contains filtered or unexported fields
}

func (*Config) RegisterFlagsWithPrefix

func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

type Index

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

func NewIndex

func NewIndex(logger log.Logger, s Store, cfg Config) *Index

func (*Index) GetBlocks

func (i *Index) GetBlocks(tx *bbolt.Tx, list *metastorev1.BlockList) ([]*metastorev1.BlockMeta, error)

func (*Index) GetTenantStats

func (i *Index) GetTenantStats(tenant string) *metastorev1.TenantStats

func (*Index) Init

func (i *Index) Init(tx *bbolt.Tx) error

func (*Index) InsertBlock

func (i *Index) InsertBlock(tx *bbolt.Tx, b *metastorev1.BlockMeta) error

func (*Index) QueryMetadata

func (i *Index) QueryMetadata(tx *bbolt.Tx, query MetadataQuery) ([]*metastorev1.BlockMeta, error)

func (*Index) QueryMetadataLabels

func (i *Index) QueryMetadataLabels(tx *bbolt.Tx, query MetadataQuery) ([]*typesv1.Labels, error)

func (*Index) ReplaceBlocks

func (i *Index) ReplaceBlocks(tx *bbolt.Tx, compacted *metastorev1.CompactedBlocks) error

func (*Index) Restore

func (i *Index) Restore(tx *bbolt.Tx) error

type InvalidQueryError

type InvalidQueryError struct {
	Query MetadataQuery
	Err   error
}

func (*InvalidQueryError) Error

func (e *InvalidQueryError) Error() string

type MetadataQuery

type MetadataQuery struct {
	Expr      string
	StartTime time.Time
	EndTime   time.Time
	Tenant    []string
	Labels    []string
}

func (*MetadataQuery) String

func (q *MetadataQuery) String() string

type Store

type Store interface {
	CreateBuckets(*bbolt.Tx) error
	ListPartitions(*bbolt.Tx) ([]*store.Partition, error)
	LoadShard(*bbolt.Tx, store.PartitionKey, string, uint32) (*store.Shard, error)
}