metastore

package

Go to main page

Versions in this module

v1

v1.12.0

Jan 15, 2025

Changes in this version

type IndexQuerier

+ QueryMetadataLabels func(*bbolt.Tx, index.MetadataLabelQuery) ([]*typesv1.Labels, error)

type MetadataQueryService

+ func (svc *MetadataQueryService) QueryMetadataLabels(ctx context.Context, req *metastorev1.QueryMetadataLabelsRequest) (resp *metastorev1.QueryMetadataLabelsResponse, err error)

v1.11.1

Jan 9, 2025

v1.11.0

Dec 19, 2024

Changes in this version

+ type CompactionCommandHandler struct

+ func NewCompactionCommandHandler(logger log.Logger, index IndexReplacer, compactor compaction.Compactor, ...) *CompactionCommandHandler

+ func (h *CompactionCommandHandler) GetCompactionPlanUpdate(tx *bbolt.Tx, cmd *raft.Log, req *raft_log.GetCompactionPlanUpdateRequest) (*raft_log.GetCompactionPlanUpdateResponse, error)

+ func (h *CompactionCommandHandler) UpdateCompactionPlan(tx *bbolt.Tx, cmd *raft.Log, req *raft_log.UpdateCompactionPlanRequest) (*raft_log.UpdateCompactionPlanResponse, error)

+ type CompactionService struct

+ func NewCompactionService(logger log.Logger, raft Raft) *CompactionService

+ func (svc *CompactionService) PollCompactionJobs(_ context.Context, req *metastorev1.PollCompactionJobsRequest) (*metastorev1.PollCompactionJobsResponse, error)

type Config

+ Compactor compactor.Config

+ DLQRecovery dlq.RecoveryConfig

+ Scheduler scheduler.Config

+ type Index interface

+ InsertBlock func(*bbolt.Tx, *metastorev1.BlockMeta) error

+ type IndexBlockFinder interface

+ FindBlocks func(*bbolt.Tx, *metastorev1.BlockList) ([]*metastorev1.BlockMeta, error)

+ type IndexCommandHandler struct

+ func NewIndexCommandHandler(logger log.Logger, index Index, tombstones Tombstones, ...) *IndexCommandHandler

+ func (m *IndexCommandHandler) AddBlock(tx *bbolt.Tx, cmd *raft.Log, req *metastorev1.AddBlockRequest) (*metastorev1.AddBlockResponse, error)

+ type IndexQuerier interface

+ QueryMetadata func(*bbolt.Tx, index.MetadataQuery) iter.Iterator[*metastorev1.BlockMeta]

+ type IndexReplacer interface

+ ReplaceBlocks func(*bbolt.Tx, *metastorev1.CompactedBlocks) error

+ type IndexService struct

+ func NewIndexService(logger log.Logger, raft Raft, state State, index IndexBlockFinder, ...) *IndexService

+ func (svc *IndexService) AddBlock(ctx context.Context, req *metastorev1.AddBlockRequest) (resp *metastorev1.AddBlockResponse, err error)

+ func (svc *IndexService) AddRecoveredBlock(ctx context.Context, req *metastorev1.AddBlockRequest) (*metastorev1.AddBlockResponse, error)

+ func (svc *IndexService) GetBlockMetadata(ctx context.Context, req *metastorev1.GetBlockMetadataRequest) (resp *metastorev1.GetBlockMetadataResponse, err error)

+ type MetadataQueryService struct

+ func NewMetadataQueryService(logger log.Logger, state State, index IndexQuerier) *MetadataQueryService

+ func (svc *MetadataQueryService) QueryMetadata(ctx context.Context, req *metastorev1.QueryMetadataRequest) (resp *metastorev1.QueryMetadataResponse, err error)

type Metastore

+ func (m *Metastore) Register(server *grpc.Server)

+ type PlacementStats interface

+ RecordStats func(iter.Iterator[placement.Sample])

+ type Raft interface

+ Propose func(fsm.RaftLogEntryType, proto.Message) (proto.Message, error)

+ type State interface

+ ConsistentRead func(context.Context, func(*bbolt.Tx, raftnode.ReadIndex)) error

+ type TenantIndex interface

+ GetTenantStats func(tenant string) *metastorev1.TenantStats

+ type TenantService struct

+ func NewTenantService(logger log.Logger, state State, index TenantIndex) *TenantService

+ func (svc *TenantService) DeleteTenant(context.Context, *metastorev1.DeleteTenantRequest) (*metastorev1.DeleteTenantResponse, error)

+ func (svc *TenantService) GetTenant(ctx context.Context, req *metastorev1.GetTenantRequest) (resp *metastorev1.GetTenantResponse, err error)

+ type TombstoneDeleter interface

+ AddTombstones func(*bbolt.Tx, *raft.Log, *metastorev1.Tombstones) error

+ DeleteTombstones func(*bbolt.Tx, *raft.Log, ...*metastorev1.Tombstones) error

+ type Tombstones interface

+ Exists func(tenant string, shard uint32, block string) bool

v1.10.1

Jan 14, 2025

v1.10.0

Nov 9, 2024

Changes in this version

type Config

+ BlockCleaner blockcleaner.Config

+ Index index.Config

type Metastore

+ func (m *Metastore) TransferLeadership() (err error)

v1.9.2

Jan 14, 2025

v1.9.1

Oct 17, 2024

v1.9.0

Oct 3, 2024

Changes in this version

type Config

+ DLQRecoveryPeriod time.Duration

+ MinReadyDuration time.Duration

type Metastore

+ func (m *Metastore) AddRecoveredBlock(_ context.Context, req *metastorev1.AddBlockRequest) (*metastorev1.AddBlockResponse, error)

v1.8.0

Sep 12, 2024

Changes in this version

+ type CompactionConfig struct

+ JobLeaseDuration time.Duration

+ JobMaxFailures int

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

+ type Config struct

+ Address string

+ Compaction CompactionConfig

+ DataDir string

+ GRPCClientConfig grpcclient.Config

+ Raft RaftConfig

+ func (cfg *Config) RegisterFlags(f *flag.FlagSet)

+ func (cfg *Config) Validate() error

+ type FSM struct

+ func (fsm *FSM) Apply(l *raft.Log) interface{}

+ func (fsm *FSM) Restore(snapshot io.ReadCloser) error

+ func (fsm *FSM) Snapshot() (raft.FSMSnapshot, error)

+ type Limits interface

+ type Metastore struct

+ func New(config Config, limits Limits, logger log.Logger, reg prometheus.Registerer, ...) (*Metastore, error)

+ func (m *Metastore) AddBlock(_ context.Context, req *metastorev1.AddBlockRequest) (*metastorev1.AddBlockResponse, error)

+ func (m *Metastore) CheckReady(ctx context.Context) (err error)

+ func (m *Metastore) GetCompactionJobs(_ context.Context, req *compactorv1.GetCompactionRequest) (*compactorv1.GetCompactionResponse, error)

+ func (m *Metastore) GetProfileStats(ctx context.Context, r *metastorev1.GetProfileStatsRequest) (*typesv1.GetProfileStatsResponse, error)

+ func (m *Metastore) Info(_ context.Context, _ *connect.Request[metastorev1.InfoRequest]) (*connect.Response[metastorev1.InfoResponse], error)

+ func (m *Metastore) PollCompactionJobs(_ context.Context, req *compactorv1.PollCompactionJobsRequest) (*compactorv1.PollCompactionJobsResponse, error)

+ func (m *Metastore) QueryMetadata(ctx context.Context, request *metastorev1.QueryMetadataRequest) (*metastorev1.QueryMetadataResponse, error)

+ func (m *Metastore) ReadIndex(ctx context.Context, req *metastorev1.ReadIndexRequest) (*metastorev1.ReadIndexResponse, error)

+ func (m *Metastore) Service() services.Service

+ func (m *Metastore) Shutdown() error

+ type RaftConfig struct

+ AdvertiseAddress string

+ ApplyTimeout time.Duration

+ BindAddress string

+ BootstrapExpectPeers int

+ BootstrapPeers []string

+ Dir string

+ ServerID string

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

+ func (cfg *RaftConfig) Validate() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL