store

Documentation

Index

• Variables
• type Entry
• type IndexStore
  • func NewIndexStore() *IndexStore
  • func (m *IndexStore) CreateBuckets(tx *bbolt.Tx) error
  • func (m *IndexStore) DeleteBlockList(tx *bbolt.Tx, p PartitionKey, list *metastorev1.BlockList) error
  • func (m *IndexStore) ListPartitions(tx *bbolt.Tx) ([]*Partition, error)
  • func (m *IndexStore) LoadTenantShard(tx *bbolt.Tx, p PartitionKey, tenant string, shard uint32) (*TenantShard, error)
  • func (m *IndexStore) StoreBlock(tx *bbolt.Tx, shard *TenantShard, md *metastorev1.BlockMeta) error
• type Partition
  • func NewPartition(k PartitionKey) *Partition
  • func (p *Partition) AddTenantShard(tenant string, shard uint32)
  • func (p *Partition) Compare(other *Partition) int
  • func (p *Partition) EndTime() time.Time
  • func (p *Partition) HasTenant(t string) bool
  • func (p *Partition) Overlaps(start, end time.Time) bool
  • func (p *Partition) StartTime() time.Time
• type PartitionKey
  • func NewPartitionKey(timestamp time.Time, duration time.Duration) PartitionKey
  • func (k PartitionKey) Bytes() []byte
  • func (k PartitionKey) Equal(x PartitionKey) bool
  • func (k PartitionKey) MarshalBinary() ([]byte, error)
  • func (k PartitionKey) String() string
  • func (k *PartitionKey) UnmarshalBinary(b []byte) error
• type TenantShard

Variables

var ErrInvalidPartitionKey = errors.New("invalid partition key")

var (
	ErrInvalidStringTable = errors.New("malformed string table")
)

Types

type Entry

type Entry struct {
	Partition   PartitionKey
	Shard       uint32
	Tenant      string
	BlockID     string
	BlockMeta   *metastorev1.BlockMeta
	StringTable *metadata.StringTable
}

type IndexStore

type IndexStore struct{}

func NewIndexStore

func NewIndexStore() *IndexStore

func (*IndexStore) CreateBuckets

func (m *IndexStore) CreateBuckets(tx *bbolt.Tx) error

func (*IndexStore) DeleteBlockList

func (m *IndexStore) DeleteBlockList(tx *bbolt.Tx, p PartitionKey, list *metastorev1.BlockList) error

func (*IndexStore) ListPartitions

func (m *IndexStore) ListPartitions(tx *bbolt.Tx) ([]*Partition, error)

func (*IndexStore) LoadTenantShard

func (m *IndexStore) LoadTenantShard(tx *bbolt.Tx, p PartitionKey, tenant string, shard uint32) (*TenantShard, error)

func (*IndexStore) StoreBlock

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

type Partition

type Partition struct {
	Key          PartitionKey
	TenantShards map[string]map[uint32]struct{}
}

func NewPartition

func NewPartition(k PartitionKey) *Partition

func (*Partition) AddTenantShard

func (p *Partition) AddTenantShard(tenant string, shard uint32)

func (*Partition) Compare

func (p *Partition) Compare(other *Partition) int

func (*Partition) EndTime

func (p *Partition) EndTime() time.Time

func (*Partition) HasTenant

func (p *Partition) HasTenant(t string) bool

func (*Partition) Overlaps

func (p *Partition) Overlaps(start, end time.Time) bool

func (*Partition) StartTime

func (p *Partition) StartTime() time.Time

type PartitionKey

type PartitionKey struct {
	Timestamp time.Time
	Duration  time.Duration
}

func NewPartitionKey

func NewPartitionKey(timestamp time.Time, duration time.Duration) PartitionKey

func (PartitionKey) Bytes

func (k PartitionKey) Bytes() []byte

func (PartitionKey) Equal

func (k PartitionKey) Equal(x PartitionKey) bool

func (PartitionKey) MarshalBinary

func (k PartitionKey) MarshalBinary() ([]byte, error)

func (PartitionKey) String

func (k PartitionKey) String() string

func (*PartitionKey) UnmarshalBinary

func (k *PartitionKey) UnmarshalBinary(b []byte) error

type TenantShard

type TenantShard struct {
	Partition   PartitionKey
	Tenant      string
	Shard       uint32
	Blocks      []*metastorev1.BlockMeta
	StringTable *metadata.StringTable
}