metastore

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

type CompactionService struct {
	metastorev1.CompactionServiceServer
	// contains filtered or unexported fields
}

type Config struct {
	Address          string            `yaml:"address"`
	GRPCClientConfig grpcclient.Config `yaml:"grpc_client_config" doc:"description=Configures the gRPC client used to communicate with the metastore."`
	MinReadyDuration time.Duration     `yaml:"min_ready_duration" category:"advanced"`
	Raft             raftnode.Config   `yaml:"raft"`
	FSM              fsm.Config        `yaml:",inline" category:"advanced"`
	Index            index.Config      `yaml:"index" category:"advanced"`
	Compactor        compactor.Config  `yaml:",inline" category:"advanced"`
	Scheduler        scheduler.Config  `yaml:",inline" category:"advanced"`
}

type IndexBlockFinder interface {
	GetBlocks(*bbolt.Tx, *metastorev1.BlockList) ([]*metastorev1.BlockMeta, error)
}

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

type IndexDeleter interface {
	DeleteShard(tx *bbolt.Tx, partition indexstore.Partition, tenant string, shard uint32) error
}

type IndexInserter interface {
	InsertBlock(*bbolt.Tx, *metastorev1.BlockMeta) error
}

type IndexPartitionLister interface {
	// Partitions provide access to all partitions in the index.
	// They are iterated in the order of their creation and are
	// guaranteed to be thread-safe for reads.
	Partitions(*bbolt.Tx) goiter.Seq[indexstore.Partition]
}

type IndexQuerier interface {
	QueryMetadata(*bbolt.Tx, context.Context, index.MetadataQuery) ([]*metastorev1.BlockMeta, error)
	QueryMetadataLabels(*bbolt.Tx, context.Context, index.MetadataQuery) ([]*typesv1.Labels, error)
}

type IndexReader interface {
	IndexBlockFinder
	IndexPartitionLister
}

type IndexReplacer interface {
	ReplaceBlocks(*bbolt.Tx, *metastorev1.CompactedBlocks) error
}

type IndexService struct {
	metastorev1.IndexServiceServer
	// contains filtered or unexported fields
}

type IndexWriter interface {
	IndexInserter
	IndexDeleter
}

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

type Overrides interface {
	retention.Overrides
}

type PlacementStats interface {
	RecordStats(iter.Iterator[placement.Sample])
}

type QueryService struct {
	metastorev1.MetadataQueryServiceServer
	// contains filtered or unexported fields
}

type Raft interface {
	Propose(fsm.RaftLogEntryType, proto.Message) (proto.Message, error)
}

type State interface {
	ConsistentRead(context.Context, func(*bbolt.Tx, raftnode.ReadIndex)) error
}

type TenantIndex interface {
	GetTenantStats(tx *bbolt.Tx, tenant string) *metastorev1.TenantStats
}

type TenantService struct {
	metastorev1.TenantServiceServer
	// contains filtered or unexported fields
}

type Tombstones interface {
	AddTombstones(*bbolt.Tx, *raft.Log, *metastorev1.Tombstones) error
	DeleteTombstones(*bbolt.Tx, *raft.Log, ...*metastorev1.Tombstones) error
	Exists(tenant string, shard uint32, block string) bool
}