Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

index

package

Go to main page

Versions in this module

v1

v1.12.0

Jan 15, 2025

Changes in this version

type Index

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

+ type MetadataLabelQuery struct

+ Labels []string

v1.11.1

Jan 9, 2025

v1.11.0

Dec 19, 2024

Changes in this version

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

+ func NewStore() *store.IndexStore

type Index

+ func (i *Index) FindBlocks(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) QueryMetadata(tx *bbolt.Tx, query MetadataQuery) iter.Iterator[*metastorev1.BlockMeta]

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

+ type InvalidQueryError struct

+ Err error

+ Query MetadataQuery

+ func (e *InvalidQueryError) Error() string

+ type MetadataQuery struct

+ EndTime time.Time

+ Expr string

+ StartTime time.Time

+ Tenant []string

+ func (q *MetadataQuery) String() string

type Store

+ CreateBuckets func(*bbolt.Tx) error

+ DeleteBlockList func(*bbolt.Tx, store.PartitionKey, *metastorev1.BlockList) error

+ LoadTenantShard func(*bbolt.Tx, store.PartitionKey, string, uint32) (*store.TenantShard, error)

+ StoreBlock func(tx *bbolt.Tx, shard *store.TenantShard, md *metastorev1.BlockMeta) error

v1.10.1

Jan 14, 2025

v1.10.0

Nov 9, 2024

Changes in this version

+ var DefaultConfig = Config

+ type Config struct

+ PartitionCacheSize int

+ PartitionDuration time.Duration

+ QueryLookaroundPeriod time.Duration

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

+ type Index struct

+ Config *Config

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

+ func (i *Index) CreatePartitionKey(blockId string) PartitionKey

+ func (i *Index) FindBlock(shardNum uint32, tenant string, blockId string) *metastorev1.BlockMeta

+ func (i *Index) FindBlocksInRange(start, end int64, tenants map[string]struct{}) ([]*metastorev1.BlockMeta, error)

+ func (i *Index) FindPartitionMetas(blockId string) []*PartitionMeta

+ func (i *Index) ForEachPartition(ctx context.Context, fn func(meta *PartitionMeta) error) error

+ func (i *Index) InsertBlock(b *metastorev1.BlockMeta)

+ func (i *Index) LoadPartitions()

+ func (i *Index) ReplaceBlocks(sources []string, sourceShard uint32, sourceTenant string, ...)

+ type PartitionKey string

+ func (k PartitionKey) Parse() (t time.Time, d time.Duration, err error)

+ type PartitionMeta struct

+ Duration time.Duration

+ Key PartitionKey

+ Tenants []string

+ Ts time.Time

+ func (m *PartitionMeta) AddTenant(tenant string)

+ func (m *PartitionMeta) EndTime() time.Time

+ func (m *PartitionMeta) HasTenant(tenant string) bool

+ func (m *PartitionMeta) StartTime() time.Time

+ type Store interface

+ ListBlocks func(p PartitionKey, shard uint32, tenant string) []*metastorev1.BlockMeta

+ ListPartitions func() []PartitionKey

+ ListShards func(p PartitionKey) []uint32

+ ListTenants func(p PartitionKey, shard uint32) []string