Versions in this module Expand all Collapse all v0 v0.1.0 Aug 26, 2026 Changes in this version + const DefaultConcurrency + func GuardNotCatalog(ks *keyspace.RelationalKeyspace, t Target) error + func LatestVersions(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) (map[string]int, error) + func NextTemplateVersion(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) (int, error) + func PendingIndexes(ctx context.Context, db *recordlayer.FDBDatabase, ...) ([]*recordlayer.Index, error) + func PinnedMetadata(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) (*recordlayer.RecordMetaData, error) + func SaveTemplate(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) error + type BuildOptions struct + IndexNames []string + Limit int + Logger *slog.Logger + MaxRetries int + RecordsPerSecond int + TimeLimit time.Duration + type CatalogTargetError struct + DatabaseID string + Reason string + SchemaName string + func (e *CatalogTargetError) Error() string + type Event struct + Err error + FromVersion int + Indexes []string + Outcome Outcome + Records int64 + Target Target + ToVersion int + Types int + type Options struct + Concurrency int + Progress func(Event) + type Outcome string + const OutcomeBuilt + const OutcomeCollected + const OutcomeFailed + const OutcomeMigrated + const OutcomeNoWork + const OutcomeRefused + const OutcomeSkipped + type Result struct + Built int + Collected int + Failed int + Failures []*TargetError + Migrated int + NoWork int + Refused int + Skipped int + Total int + func BuildAll(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) (Result, error) + func BuildIndexes(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) (Result, error) + func CollectAllStatistics(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) (Result, error) + func CollectStatistics(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) (Result, error) + func Migrate(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) (Result, error) + func MigrateTemplate(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) (Result, error) + func MigrateToLatest(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) (Result, error) + type StatisticsOptions struct + Collect recordlayer.CollectOptions + type Target struct + DatabaseID string + SchemaName string + TemplateName string + TemplateVersion int + func FilterByTemplate(targets []Target, templateName string) []Target + func ListTargets(ctx context.Context, db *recordlayer.FDBDatabase, cat api.StoreCatalog, ...) ([]Target, error) + func (t Target) String() string + type TargetError struct + Err error + Target Target + func (e *TargetError) Error() string + func (e *TargetError) Unwrap() error
Go to main page