node

func CopyImmutableBlobsBounded ¶ added in v0.60.1

func CopyImmutableBlobsBounded(
	ctx context.Context,
	logger *slog.Logger,
	imm *immutable.ImmutableDb,
	c *chain.Chain,
	maxSlot uint64,
	onProgress func(LoadBlobsProgress),
) (int, uint64, error)

CopyImmutableBlobsBounded copies immutable blocks into the blob store from the current chain tip up to and including maxSlot, storing produced-UTxO offsets per block. maxSlot of 0 copies to the immutable tip. It reuses a caller-opened ImmutableDb and Chain so it can be invoked repeatedly during a download to overlap the copy with fetching (parallel fetch, sequenced processing). Returns the number of blocks copied and the highest slot copied.

Safe against chunks that arrive out of order: bounding by maxSlot (the last slot of a known-contiguous chunk prefix) stops the copy before it can reach a higher out-of-order chunk past a gap. Blocks above maxSlot are left for a later call with a higher bound.

func ImmutableUtxoOffsetsTipSlot ¶ added in v0.47.0

func ImmutableUtxoOffsetsTipSlot(
	db *database.Database,
) (uint64, bool, error)

ImmutableUtxoOffsetsTipSlot reports the latest slot for which the Mithril immutable-copy phase persisted produced-UTxO offset references. The second return value is false when no immutable copy has run (the sync-state key is unset); callers must treat that as "no skip threshold" and write offsets normally.

func Load ¶ added in v0.5.0

func Load(ctx context.Context, cfg *config.Config, logger *slog.Logger, immutableDir string) error

func LoadWithDB ¶ added in v0.22.0

func LoadWithDB(
	ctx context.Context,
	cfg *config.Config,
	logger *slog.Logger,
	immutableDir string,
	db *database.Database,
) error

LoadWithDB loads immutable DB blocks into the chain. If db is nil, a new database connection is opened (and closed on return).

func MarkImmutableUtxoOffsetsComplete ¶ added in v0.60.1

func MarkImmutableUtxoOffsetsComplete(
	db *database.Database,
	immutableTipSlot uint64,
) error

MarkImmutableUtxoOffsetsComplete records that produced-UTxO offset references are stored for every immutable block up to immutableTipSlot, so a later API backfill can skip re-writing them. It is idempotent. Callers that split the immutable copy (for example the pipelined download/copy) must call this after the copy completes, because the per-block copy stores the offsets but does not advance this marker on its own.

func RepairCriticalDeferredIndexes ¶ added in v0.51.0

func RepairCriticalDeferredIndexes(
	db *database.Database,
	logger *slog.Logger,
) error

RepairCriticalDeferredIndexes rebuilds the API/rollback-critical subset if a prior run left deferred indexes pending. It leaves the pending marker in place so RepairDeferredIndexes can finish the lazy remainder later.

func RepairDeferredIndexes ¶ added in v0.50.0

func RepairDeferredIndexes(
	db *database.Database,
	logger *slog.Logger,
) error

RepairDeferredIndexes rebuilds any deferred indexes that were recorded as pending by a prior interrupted run. It is safe to call when no rebuild is outstanding: BuildDeferredIndexes is itself idempotent and clears the marker.

func Run ¶

func Run(cfg *config.Config, logger *slog.Logger) error

func RunPlannerStats ¶ added in v0.47.0

func RunPlannerStats(db *database.Database, logger *slog.Logger) error

RunPlannerStats collects query-planner statistics on the metadata store if it implements PlannerStatsUpdater. No-op for non-SQLite stores.

func WithBulkLoadPragmas ¶ added in v0.22.0

func WithBulkLoadPragmas(
	db *database.Database,
	logger *slog.Logger,
) func()

WithBulkLoadPragmas enables bulk-load optimizations on the metadata store if it implements BulkLoadOptimizer. The returned cleanup function restores normal pragmas and must be deferred by the caller.