pricing

Documentation

Index

• Variables
• func NewAPI(sess *session.Session, region string) pricingiface.PricingAPI
• type Controller
  • func NewController(pricingProvider *Provider) *Controller
  • func (c *Controller) Builder(_ context.Context, m manager.Manager) corecontroller.Builder
  • func (c *Controller) Name() string
  • func (c *Controller) Reconcile(ctx context.Context, _ reconcile.Request) (reconcile.Result, error)
• type Err
• type Provider
  • func NewProvider(_ context.Context, pricing pricingiface.PricingAPI, ec2Api ec2iface.EC2API, ...) *Provider
  • func (p *Provider) InstanceTypes() []string
  • func (p *Provider) LivenessProbe(_ *http.Request) error
  • func (p *Provider) OnDemandLastUpdated() time.Time
  • func (p *Provider) OnDemandPrice(instanceType string) (float64, bool)
  • func (p *Provider) Reset()
  • func (p *Provider) SpotLastUpdated() time.Time
  • func (p *Provider) SpotPrice(instanceType string, zone string) (float64, bool)
  • func (p *Provider) UpdateOnDemandPricing(ctx context.Context) error
  • func (p *Provider) UpdateSpotPricing(ctx context.Context) error

Variables

var (
	InstanceTypeLabel     = "instance_type"
	CapacityTypeLabel     = "capacity_type"
	RegionLabel           = "region"
	TopologyLabel         = "zone"
	InstancePriceEstimate = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Namespace: metrics.Namespace,
			Subsystem: cloudProviderSubsystem,
			Name:      "instance_type_price_estimate",
			Help:      "Estimated hourly price used when making informed decisions on node cost calculation. This is updated once on startup and then every 12 hours.",
		},
		[]string{
			InstanceTypeLabel,
			CapacityTypeLabel,
			RegionLabel,
			TopologyLabel,
		})
)

Functions

func NewAPI

func NewAPI(sess *session.Session, region string) pricingiface.PricingAPI

NewPricingAPI returns a pricing API configured based on a particular region

Types

type Controller

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

func NewController

func NewController(pricingProvider *Provider) *Controller

func (*Controller) Builder

func (c *Controller) Builder(_ context.Context, m manager.Manager) corecontroller.Builder

func (*Controller) Name

func (c *Controller) Name() string

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, _ reconcile.Request) (reconcile.Result, error)

type Err

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

type Provider

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

Provider provides actual pricing data to the AWS cloud provider to allow it to make more informed decisions regarding which instances to launch. This is initialized at startup with a periodically updated static price list to support running in locations where pricing data is unavailable. In those cases the static pricing data provides a relative ordering that is still more accurate than our previous pricing model. In the event that a pricing update fails, the previous pricing information is retained and used which may be the static initial pricing data if pricing updates never succeed.

func NewProvider

func NewProvider(_ context.Context, pricing pricingiface.PricingAPI, ec2Api ec2iface.EC2API, region string) *Provider

func (*Provider) InstanceTypes

func (p *Provider) InstanceTypes() []string

InstanceTypes returns the list of all instance types for which either a spot or on-demand price is known.

func (*Provider) LivenessProbe

func (p *Provider) LivenessProbe(_ *http.Request) error

func (*Provider) OnDemandLastUpdated

func (p *Provider) OnDemandLastUpdated() time.Time

OnDemandLastUpdated returns the time that the on-demand pricing was last updated

func (*Provider) OnDemandPrice

func (p *Provider) OnDemandPrice(instanceType string) (float64, bool)

OnDemandPrice returns the last known on-demand price for a given instance type, returning an error if there is no known on-demand pricing for the instance type.

func (*Provider) Reset

func (p *Provider) Reset()

func (*Provider) SpotLastUpdated

func (p *Provider) SpotLastUpdated() time.Time

SpotLastUpdated returns the time that the spot pricing was last updated

func (*Provider) SpotPrice

func (p *Provider) SpotPrice(instanceType string, zone string) (float64, bool)

SpotPrice returns the last known spot price for a given instance type and zone, returning an error if there is no known spot pricing for that instance type or zone

func (*Provider) UpdateOnDemandPricing

func (p *Provider) UpdateOnDemandPricing(ctx context.Context) error

func (*Provider) UpdateSpotPricing

func (p *Provider) UpdateSpotPricing(ctx context.Context) error

nolint: gocyclo