prices

Documentation

Index

• Variables
• func GetPrices(r *schema.Resource, q QueryRunner) error
• func GetPricesConcurrent(resources []*schema.Resource, q QueryRunner) error
• func PopulatePrices(cfg *config.Config, project *schema.Project) error
• type GraphQLQuery
• type GraphQLQueryRunner
  • func NewGraphQLQueryRunner(endpoint string, apiKey string) *GraphQLQueryRunner
  • func (q *GraphQLQueryRunner) RunQueries(r *schema.Resource) ([]QueryResult, error)
• type PricingAPIError
  • func (e *PricingAPIError) Error() string
• type QueryResult
• type QueryRunner

Variables

var ErrInvalidAPIKey = errors.New("Invalid API key")

Functions

func GetPrices

func GetPrices(r *schema.Resource, q QueryRunner) error

func GetPricesConcurrent

func GetPricesConcurrent(resources []*schema.Resource, q QueryRunner) error

GetPricesConcurrent gets the prices of all resources concurrently. Concurrency level is calculated using the following formula: max(min(4, numCPU * 4), 16)

func PopulatePrices

func PopulatePrices(cfg *config.Config, project *schema.Project) error

Types

type GraphQLQuery

type GraphQLQuery struct {
	Query     string                 `json:"query"`
	Variables map[string]interface{} `json:"variables"`
}

type GraphQLQueryRunner

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

func NewGraphQLQueryRunner

func NewGraphQLQueryRunner(endpoint string, apiKey string) *GraphQLQueryRunner

func (*GraphQLQueryRunner) RunQueries

func (q *GraphQLQueryRunner) RunQueries(r *schema.Resource) ([]QueryResult, error)

type PricingAPIError

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

func (*PricingAPIError) Error

func (e *PricingAPIError) Error() string

type QueryResult

type QueryResult struct {
	Result gjson.Result
	// contains filtered or unexported fields
}

type QueryRunner

type QueryRunner interface {
	RunQueries(resource *schema.Resource) ([]QueryResult, error)
}