planner

Nov 19, 2024

Changes in this version

type Config

+ Queue queue.Config

+ type TaskMeta struct

Sep 18, 2024

Changes in this version

type Config

+ RetentionConfig RetentionConfig

+ type RetentionConfig struct

+ Enabled bool

+ MaxLookbackDays int

+ func (cfg *RetentionConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

+ func (cfg *RetentionConfig) Validate() error

+ type RetentionLimits interface

+ AllByUserID func() map[string]*validation.Limits

+ DefaultLimits func() *validation.Limits

+ RetentionPeriod func(userID string) time.Duration

+ StreamRetention func(userID string) []validation.StreamRetention

+ type RetentionManager struct

+ func NewRetentionManager(cfg RetentionConfig, limits RetentionLimits, bloomStore bloomshipper.StoreBase, ...) *RetentionManager

+ func (r *RetentionManager) Apply(ctx context.Context) error

Jul 2, 2024

Changes in this version

+ func FindGapsInFingerprintBounds(ownershipRange v1.FingerprintBounds, metas []v1.FingerprintBounds) (gaps []v1.FingerprintBounds, err error)

+ func NewQueueMetrics(r prometheus.Registerer) *queue.Metrics

+ func SplitFingerprintKeyspaceByFactor(factor int) []v1.FingerprintBounds

+ type Config struct

+ MaxQueuedTasksPerTenant int

+ MaxTableOffset int

+ MinTableOffset int

+ PlanningInterval time.Duration

+ func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

+ func (cfg *Config) Validate() error

+ type Limits interface

+ BloomBuildMaxBuilders func(tenantID string) int

+ BloomCreationEnabled func(tenantID string) bool

+ BloomSplitSeriesKeyspaceBy func(tenantID string) int

+ BloomTaskMaxRetries func(tenantID string) int

+ BuilderResponseTimeout func(tenantID string) time.Duration

+ type Metrics struct

+ func NewMetrics(r prometheus.Registerer, getConnectedBuilders func() float64) *Metrics

+ type Planner struct

+ func New(cfg Config, limits Limits, schemaCfg config.SchemaConfig, ...) (*Planner, error)

+ func (p *Planner) BuilderLoop(builder protos.PlannerForBuilder_BuilderLoopServer) error

+ func (p *Planner) NotifyBuilderShutdown(_ context.Context, req *protos.NotifyBuilderShutdownRequest) (*protos.NotifyBuilderShutdownResponse, error)

+ type QueueLimits struct

+ func NewQueueLimits(limits Limits) *QueueLimits

+ func (c *QueueLimits) MaxConsumers(tenantID string, allConsumers int) int

+ type QueueTask struct

+ func NewQueueTask(ctx context.Context, queueTime time.Time, task *protos.Task, ...) *QueueTask