Versions in this module Expand all Collapse all v1 v1.2.0 Jan 25, 2026 Changes in this version + func PriorityIntToLevel(priority int32) string + func PriorityLevelToRange(level string) (int32, int32) + type PriorityWeightCalculator struct + AgeFetcher func(ctx context.Context, queueName string, level string, nowMs int64) (int64, bool, error) + func NewPriorityWeightCalculator(base *repositorysql.BaseSQL) *PriorityWeightCalculator + func (p *PriorityWeightCalculator) CalculateWeights(ctx context.Context, queueName string, queueMeta *queuepb.QueueMetadata) (map[string]int32, error) + func (p *PriorityWeightCalculator) SelectPriorityLevel(weights map[string]int32) string
Go to main page