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."`
	DataDir          string             `yaml:"data_dir"`
	MinReadyDuration time.Duration      `yaml:"min_ready_duration" category:"advanced"`
	Raft             raft.Config        `yaml:"raft"`
	Index            index.Config       `yaml:",inline" category:"advanced"`
	DLQRecovery      dlq.RecoveryConfig `yaml:",inline" category:"advanced"`
	Compactor        compactor.Config   `yaml:",inline" category:"advanced"`
	Scheduler        scheduler.Config   `yaml:",inline" category:"advanced"`
}

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

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

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

type IndexQuerier interface {
	QueryMetadata(*bbolt.Tx, index.MetadataQuery) iter.Iterator[*metastorev1.BlockMeta]
}

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

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

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

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

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

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(tenant string) *metastorev1.TenantStats
}

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

type TombstoneDeleter interface {
	DeleteTombstones(*bbolt.Tx, *raft.Log, ...*metastorev1.Tombstones) error
	AddTombstones(*bbolt.Tx, *raft.Log, *metastorev1.Tombstones) error
}

type Tombstones interface {
	Exists(tenant string, shard uint32, block string) bool
}