prioritymultiplier

Jan 29, 2025

Changes in this version

+ func NewServiceClient(config schedulerconfig.PriorityMultiplierConfig) (priorityoverride.PriorityMultiplierServiceClient, error)

+ type Provider interface

+ Multiplier func(pool, queue string) (float64, error)

+ Ready func() bool

+ func NewNoOpProvider() Provider

+ func NewStaticProvider(multipliers map[multiplierKey]float64) Provider

+ type ServiceProvider struct

+ func NewServiceProvider(apiClient priorityoverride.PriorityMultiplierServiceClient, ...) *ServiceProvider

+ func (p *ServiceProvider) Multiplier(pool, queue string) (float64, error)

+ func (p *ServiceProvider) Ready() bool

+ func (p *ServiceProvider) Run(ctx *armadacontext.Context) error

+ type StaticProvider struct

+ func (s *StaticProvider) Multiplier(pool, queue string) (float64, error)

+ func (s *StaticProvider) Ready() bool