Versions in this module Expand all Collapse all v0 v0.1.23 Mar 25, 2026 v0.1.22 Mar 25, 2026 v0.1.21 Mar 9, 2026 v0.1.20 Oct 6, 2025 v0.1.19 Aug 25, 2025 v0.1.18 Aug 25, 2025 v0.1.17 Aug 23, 2025 v0.1.16 Aug 22, 2025 Changes in this version + const GB + const LargeSizeLimit + const MB + const MediumSizeLimit + const MinDatarangesForSmallAggregation + const SmallDatapointLimit + const SmallSizeLimit + type Datarange struct + DatapointCount int64 + ID int64 + MaxDatapointKey int64 + MinDatapointKey int64 + SizeBytes int64 + type Operation struct + DatarangeIDs []int64 + FirstDatapoint uint64 + LastDatapoint uint64 + Reason string + TotalSize int64 + Type OptimizationType + type OptimizationType string + const OptimizationLargeToVeryLarge + const OptimizationMediumToLarge + const OptimizationSmallDatapoints + const OptimizationSmallToMedium + type Optimizer struct + func NewOptimizer(dataranges []client.DatarangeInfo) *Optimizer + func (o *Optimizer) FindBestOptimization() *Operation v0.1.15 Jul 14, 2025 v0.1.14 Jul 13, 2025 v0.1.13 Jul 13, 2025 v0.1.12 Jul 13, 2025 Changes in this version + const MaxAggregateSize + const MinThreshold + const OperationCostBase + const TargetSize + func Command() *cli.Command + type AggregationOperation struct + Files []TarFile + FirstDatapoint uint64 + LastDatapoint uint64 + Score float64 + type AggregationOptimizer struct + func NewAggregationOptimizer(files []TarFile) *AggregationOptimizer + func (ao *AggregationOptimizer) FindAllBeneficialAggregations() []*AggregationOperation + func (ao *AggregationOptimizer) FindBestAggregation() *AggregationOperation + func (ao *AggregationOptimizer) SetBalanceParameters(minFilesForSmall int, maxSizeRatio int, allowMixedSizes bool) + func (ao *AggregationOptimizer) SetThresholds(minScore float64, targetSize int64, maxAggregateSize int64) + type TarFile struct + Created time.Time + ID string + MaxID uint64 + MinID uint64 + S3Key string + Size int64 + func ConvertFromDatarangeInfo(dataranges []client.DatarangeInfo) []TarFile
Go to main page