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(ctx context.Context, pricing pricingiface.PricingAPI, ec2Api ec2iface.EC2API, ...) *Provider
  • func (p *Provider) InstanceTypes() []string
  • func (p *Provider) LivenessProbe(req *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(ctx 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(req *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