planner

type Config struct {
	PlanningInterval time.Duration   `yaml:"planning_interval"`
	MinTableOffset   int             `yaml:"min_table_offset"`
	MaxTableOffset   int             `yaml:"max_table_offset"`
	RetentionConfig  RetentionConfig `yaml:"retention"`
	Queue            queue.Config    `yaml:"queue"`
}

type Limits interface {
	RetentionLimits
	strategies.Limits
	BloomCreationEnabled(tenantID string) bool
	BloomBuildMaxBuilders(tenantID string) int
	BuilderResponseTimeout(tenantID string) time.Duration
	BloomTaskMaxRetries(tenantID string) int
}

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

type Planner struct {
	services.Service
	// contains filtered or unexported fields
}

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

type QueueTask struct {
	*protos.ProtoTask
	*TaskMeta
}

type RetentionConfig struct {
	Enabled         bool `yaml:"enabled"`
	MaxLookbackDays int  `yaml:"max_lookback_days" doc:"hidden"`
}

type RetentionLimits interface {
	RetentionPeriod(userID string) time.Duration
	StreamRetention(userID string) []validation.StreamRetention
	AllByUserID() map[string]*validation.Limits
	DefaultLimits() *validation.Limits
}

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

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