pricing

Documentation

Index

• Constants
• func NewBidRetrieverServiceClient(config schedulerconfig.PricingApiConfig) (bidstore.BidRetrieverServiceClient, error)
• type Bid
• type BidPriceCache
  • func NewBidPriceCache(client bidstore.BidRetrieverServiceClient, ...) *BidPriceCache
  • func (p *BidPriceCache) GetBidPrices(ctx *armadacontext.Context) (BidPriceSnapshot, error)
  • func (p *BidPriceCache) Initialise(ctx *armadacontext.Context) error
  • func (p *BidPriceCache) Run(ctx *armadacontext.Context) error
• type BidPriceProvider
• type BidPriceSnapshot
  • func (s *BidPriceSnapshot) GetPrice(queue string, band bidstore.PriceBand) (map[string]Bid, bool)
• type ExternalBidPriceService
  • func NewExternalBidPriceService(client bidstore.BidRetrieverServiceClient, ...) *ExternalBidPriceService
  • func (b *ExternalBidPriceService) GetBidPrices(ctx *armadacontext.Context) (BidPriceSnapshot, error)
• type LocalBidPriceService
  • func NewLocalBidPriceService(pools []string, queueCache queue.QueueCache) *LocalBidPriceService
  • func (b *LocalBidPriceService) GetBidPrices(ctx *armadacontext.Context) (BidPriceSnapshot, error)
• type NoopBidPriceProvider
  • func (n NoopBidPriceProvider) GetBidPrices(ctx *armadacontext.Context) (BidPriceSnapshot, error)
• type PriceKey

Constants

const NonPreemptibleRunningPrice = 1_000_000

Functions

func NewBidRetrieverServiceClient

func NewBidRetrieverServiceClient(config schedulerconfig.PricingApiConfig) (bidstore.BidRetrieverServiceClient, error)

Types

type Bid

type Bid struct {
	RunningBid float64
	QueuedBid  float64
}

type BidPriceCache

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

func NewBidPriceCache

func NewBidPriceCache(client bidstore.BidRetrieverServiceClient, rlf *internaltypes.ResourceListFactory, updateFrequency time.Duration) *BidPriceCache

func (*BidPriceCache) GetBidPrices

func (p *BidPriceCache) GetBidPrices(ctx *armadacontext.Context) (BidPriceSnapshot, error)

func (*BidPriceCache) Initialise

func (p *BidPriceCache) Initialise(ctx *armadacontext.Context) error

func (*BidPriceCache) Run

func (p *BidPriceCache) Run(ctx *armadacontext.Context) error

type BidPriceProvider

type BidPriceProvider interface {
	GetBidPrices(ctx *armadacontext.Context) (BidPriceSnapshot, error)
}

type BidPriceSnapshot

type BidPriceSnapshot struct {
	Timestamp     time.Time
	Bids          map[PriceKey]map[string]Bid
	ResourceUnits map[string]internaltypes.ResourceList
}

func (*BidPriceSnapshot) GetPrice

func (s *BidPriceSnapshot) GetPrice(queue string, band bidstore.PriceBand) (map[string]Bid, bool)

type ExternalBidPriceService

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

func NewExternalBidPriceService

func NewExternalBidPriceService(client bidstore.BidRetrieverServiceClient, rlf *internaltypes.ResourceListFactory) *ExternalBidPriceService

func (*ExternalBidPriceService) GetBidPrices

func (b *ExternalBidPriceService) GetBidPrices(ctx *armadacontext.Context) (BidPriceSnapshot, error)

type LocalBidPriceService

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

func NewLocalBidPriceService

func NewLocalBidPriceService(pools []string, queueCache queue.QueueCache) *LocalBidPriceService

func (*LocalBidPriceService) GetBidPrices

func (b *LocalBidPriceService) GetBidPrices(ctx *armadacontext.Context) (BidPriceSnapshot, error)

type NoopBidPriceProvider

type NoopBidPriceProvider struct{}

func (NoopBidPriceProvider) GetBidPrices

func (n NoopBidPriceProvider) GetBidPrices(ctx *armadacontext.Context) (BidPriceSnapshot, error)

type PriceKey

type PriceKey struct {
	Queue string
	Band  bidstore.PriceBand
}