planner

type BinPackResult[G Sizer] struct {
	Groups []G
	Size   int64
}

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

type CompactionPlan struct {
	// OutputObjects contains the planned output objects (one per bin).
	OutputObjects []*compactionpb.SingleTenantObjectSource
	// TotalUncompressedSize is the total uncompressed size across all output objects (for reporting).
	TotalUncompressedSize int64
	// LeftoverBeforeStreams contains streams with data before the compaction window.
	LeftoverBeforeStreams []*LeftoverStreamGroup
	// LeftoverAfterStreams contains streams with data after the compaction window.
	LeftoverAfterStreams []*LeftoverStreamGroup
}

type IndexInfo struct {
	Path   string
	Tenant string
}

type IndexStreamReader interface {
	ReadStreams(ctx context.Context, indexPath, tenant string, windowStart, windowEnd time.Time) (*IndexStreamResult, error)
}

type IndexStreamResult struct {
	Streams               []StreamInfo
	LeftoverBeforeStreams []LeftoverStreamInfo
	LeftoverAfterStreams  []LeftoverStreamInfo
}

type LeftoverPlan struct {
	// BeforeWindow contains planned output objects for data BEFORE the compaction window.
	BeforeWindow []*compactionpb.MultiTenantObjectSource
	// BeforeWindowSize is the total uncompressed size of BeforeWindow (for reporting).
	BeforeWindowSize int64
	// AfterWindow contains planned output objects for data AFTER the compaction window.
	AfterWindow []*compactionpb.MultiTenantObjectSource
	// AfterWindowSize is the total uncompressed size of AfterWindow (for reporting).
	AfterWindowSize int64
}

type LeftoverStreamGroup struct {
	Streams               []*compactionpb.TenantStream
	TotalUncompressedSize int64
}

type LeftoverStreamInfo struct {
	compactionpb.TenantStream
	LabelsHash       uint64
	UncompressedSize int64
}

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

type Sizer interface {
	GetSize() int64
}

type StreamCollectionResult struct {
	// StreamGroups contains streams grouped by labels hash.
	StreamGroups []*StreamGroup
	// TotalUncompressedSize is the sum of uncompressed sizes across all stream groups.
	TotalUncompressedSize int64
	// LeftoverBeforeStreams contains streams with data before the compaction window.
	LeftoverBeforeStreams []*LeftoverStreamGroup
	// LeftoverAfterStreams contains streams with data after the compaction window.
	LeftoverAfterStreams []*LeftoverStreamGroup
}

type StreamGroup struct {
	// Streams contains all the stream entries for this stream (from different indexes).
	Streams []*compactionpb.Stream
	// TotalUncompressedSize is the sum of uncompressed sizes across all streams.
	TotalUncompressedSize int64
}

type StreamInfo struct {
	compactionpb.Stream
	// LabelsHash is the stable hash of the stream labels.
	LabelsHash uint64
	// UncompressedSize is the total uncompressed size of this stream.
	UncompressedSize int64
}