aws

Jan 5, 2026

Changes in this version

+ const FargatePricingSource

type AWS

+ FargatePricing *FargatePricing

+ FargatePricingError error

+ type FargatePricing struct

+ func NewFargatePricing() *FargatePricing

+ func (f *FargatePricing) GetHourlyPricing(region string, os, arch string) (cpu, memory float64, err error)

+ func (f *FargatePricing) Initialize(nodeList []*clustercache.Node) error

+ type FargateRegionPricing map[string]float64

+ func (f FargateRegionPricing) Validate() error

Dec 18, 2025

Changes in this version

+ var ErrNoAthenaBucket = errors.New("No Athena Bucket configured")

type AthenaIntegration

+ func (ai *AthenaIntegration) RefreshStatus() cloud.ConnectionStatus

type S3SelectIntegration

+ func (s3si *S3SelectIntegration) RefreshStatus() cloud.ConnectionStatus

Oct 22, 2025

Changes in this version

+ type FailingMockAthenaQuerier struct

+ func (fmaq *FailingMockAthenaQuerier) GetAthenaClient() (*athena.Client, error)

+ type FailingQueryAthenaQuerier struct

+ func (fqaq *FailingQueryAthenaQuerier) GetAthenaClient() (*athena.Client, error)

+ type MockAthenaClient struct

+ GetQueryExecutionFunc func(ctx context.Context, params *athena.GetQueryExecutionInput, ...) (*athena.GetQueryExecutionOutput, error)

+ GetQueryResultsFunc func(ctx context.Context, params *athena.GetQueryResultsInput, ...) (*athena.GetQueryResultsOutput, error)

+ StartQueryExecutionFunc func(ctx context.Context, params *athena.StartQueryExecutionInput, ...) (*athena.StartQueryExecutionOutput, error)

+ func (m *MockAthenaClient) GetQueryExecution(ctx context.Context, params *athena.GetQueryExecutionInput, ...) (*athena.GetQueryExecutionOutput, error)

+ func (m *MockAthenaClient) GetQueryResults(ctx context.Context, params *athena.GetQueryResultsInput, ...) (*athena.GetQueryResultsOutput, error)

+ func (m *MockAthenaClient) StartQueryExecution(ctx context.Context, params *athena.StartQueryExecutionInput, ...) (*athena.StartQueryExecutionOutput, error)

+ type MockAthenaQuerier struct

+ func (maq *MockAthenaQuerier) GetAthenaClient() (*athena.Client, error)

+ func (maq *MockAthenaQuerier) GetColumns() (map[string]bool, error)

+ func (maq *MockAthenaQuerier) Query(ctx context.Context, query string, fn func(*athena.GetQueryResultsOutput) bool) error

Aug 29, 2025

Changes in this version

type AthenaConfiguration

+ CURVersion string

type AthenaQuerier

+ func (aq *AthenaQuerier) HasBillingPeriodPartitions() (bool, error)

type AwsAthenaInfo

+ CURVersion string

Jan 17, 2025

Changes in this version

+ const TypeDiscountedUsage

+ const TypeEDPDiscount

+ const TypePrivateRateDiscount

+ const TypeSavingsPlanCoveredUsage

type AWS

+ func (awsProvider *AWS) GpuPricing(nodeLabels map[string]string) (string, error)

Nov 8, 2024

Changes in this version

type AWSProductAttributes

+ Operation string

type AWSProductTerms

+ LoadBalancer *models.LoadBalancer

Sep 26, 2024

Changes in this version

+ const AWSLabelColumnPrefix

+ const AthenaResourceTagPrefix

+ const S3SelectAWSLabelPrefix

+ const S3SelectAvailabilityZone

+ const S3SelectBillPayerAccountID

+ const S3SelectNetRICost

+ const S3SelectNetSPCost

+ const S3SelectRegionCode

+ const S3SelectResourceTagsPrefix

+ const S3SelectUserLabelPrefix

+ const TagAWSEKSClusterName

+ const TagEKSClusterName

+ const TagEKSCtlClusterName

+ const TagKubernetesPVCName

+ const TagKubernetesPVName

+ const TagKubernetesServiceName

type AthenaQueryIndexes

+ AWSTagColumns []string

type S3SelectQuerier

+ func (s3sq *S3SelectQuerier) GetHeaders(queryKey string, cli *s3.Client) ([]string, error)

Jun 25, 2024

Changes in this version

+ const WebIdentityAuthorizerType

type AWSProductAttributes

+ MarketOption string

+ RegionCode string

+ type GoogleIDTokenRetriever struct

+ Aud string

+ func (gitr GoogleIDTokenRetriever) Equals(other IDTokenRetriever) bool

+ func (gitr GoogleIDTokenRetriever) GetIdentityToken() ([]byte, error)

+ func (gitr GoogleIDTokenRetriever) Sanitize() IDTokenRetriever

+ func (gitr GoogleIDTokenRetriever) Validate() error

+ type IDTokenRetriever interface

+ Equals func(IDTokenRetriever) bool

+ GetIdentityToken func() ([]byte, error)

+ Sanitize func() IDTokenRetriever

+ Validate func() error

+ type WebIdentity struct

+ IdentityProvider string

+ RoleARN string

+ TokenRetriever IDTokenRetriever

+ func (wea *WebIdentity) CreateAWSConfig(region string) (aws.Config, error)

+ func (wea *WebIdentity) Equals(config cloud.Config) bool

+ func (wea *WebIdentity) MarshalJSON() ([]byte, error)

+ func (wea *WebIdentity) Sanitize() cloud.Config

+ func (wea *WebIdentity) UnmarshalJSON(b []byte) error

+ func (wea *WebIdentity) Validate() error

Oct 31, 2023

Changes in this version

+ var StorageClassProvisionerDefaults = map[string]string

type AthenaConfiguration

+ Catalog string

+ func (ac *AthenaConfiguration) Provider() string

type AthenaQuerier

+ func (aq *AthenaQuerier) GetStatus() cloud.ConnectionStatus

type AwsAthenaInfo

+ AthenaCatalog string

type S3Configuration

+ func (s3c *S3Configuration) Provider() string

type S3Connection

+ ConnectionStatus cloud.ConnectionStatus

+ func (s3c *S3Connection) GetStatus() cloud.ConnectionStatus

Oct 9, 2023

Changes in this version

+ const S3SelectAccountID

+ const S3SelectDateLayout

+ const S3SelectItemType

+ const S3SelectListCost

+ const S3SelectNetCost

+ const S3SelectProductCode

+ const S3SelectRICost

+ const S3SelectResourceID

+ const S3SelectSPCost

+ const S3SelectStartDate

+ const S3SelectUsageType

+ var AthenaNetPricingCoalesce = fmt.Sprintf("COALESCE(%s, %s, 0)", AthenaNetPricingColumn, AthenaPricingColumn)

+ var AthenaNetRIPricingCoalesce = fmt.Sprintf("COALESCE(%s, %s, 0)", AthenaNetRIPricingColumn, AthenaRIPricingColumn)

+ var AthenaNetSPPricingCoalesce = fmt.Sprintf("COALESCE(%s, %s, 0)", AthenaNetSPPricingColumn, AthenaSPPricingColumn)

type AthenaIntegration

+ func (ai *AthenaIntegration) GetAmortizedCostColumn(allColumns map[string]bool) string

+ func (ai *AthenaIntegration) GetPartitionWhere(start, end time.Time) string

type AthenaQueryIndexes

+ IsK8sColumn string

Jul 11, 2023

Changes in this version

+ type S3SelectIntegration struct

+ func (s3si *S3SelectIntegration) GetCloudCost(start, end time.Time) (*kubecost.CloudCostSetRange, error)

+ func (s3si *S3SelectIntegration) GetHeaders(queryKeys []string, client *s3.Client) ([]string, error)

Jun 8, 2023

Changes in this version

+ const APIPricingSource

+ const AWSHourlyPublicIPCost

+ const AccessKeyAuthorizerType

+ const AssumeRoleAuthorizerType

+ const AthenaDateColumn

+ const AthenaDateLayout

+ const AthenaDateTruncColumn

+ const AthenaInfoUpdateType

+ const AthenaIsNetwork

+ const AthenaIsNode

+ const AthenaIsVol

+ const AthenaNetPricingColumn

+ const AthenaNetRIPricingColumn

+ const AthenaNetSPPricingColumn

+ const AthenaPricingColumn

+ const AthenaRIPricingColumn

+ const AthenaSPPricingColumn

+ const AthenaWhereDateFmt

+ const AthenaWhereUsage

+ const AttachedState

+ const ClusterIdEnvVar

+ const EKSCapacitySpotTypeValue

+ const EKSCapacityTypeLabel

+ const HourlyRateCode

+ const HourlyRateCodeCn

+ const InUseState

+ const LabelColumnPrefix

+ const PreemptibleType

+ const ReservedInstancePricingSource

+ const ServiceAccountAuthorizerType

+ const SpotInfoUpdateType

+ const SpotPricingSource

+ const SpotRefreshDuration

+ var OnDemandRateCodes = map[string]struct

+ var OnDemandRateCodesCn = map[string]struct

+ func ConvertAwsAthenaInfoToConfig(aai AwsAthenaInfo) config.KeyedConfig

+ func GetAthenaQueryFunc(fn func(types.Row)) func(*athena.GetQueryResultsOutput) bool

+ func GetAthenaRowValue(row types.Row, queryColumnIndexes map[string]int, columnName string) string

+ func GetAthenaRowValueFloat(row types.Row, queryColumnIndexes map[string]int, columnName string) (float64, error)

+ func GetCSVRowValue(row []string, queryColumnIndexes map[string]int, columnName string) string

+ func GetCSVRowValueFloat(row []string, queryColumnIndexes map[string]int, columnName string) (float64, error)

+ func ParseARN(id string) string

+ func SelectAWSCategory(isNode, isVol, isNetwork bool, providerID, service string) string

+ type AWS struct

+ BaseCPUPrice string

+ BaseGPUPrice string

+ BaseRAMPrice string

+ BaseSpotCPUPrice string

+ BaseSpotGPUPrice string

+ BaseSpotRAMPrice string

+ Clientset clustercache.ClusterCache

+ ClusterAccountID string

+ ClusterRegion string

+ Config models.ProviderConfig

+ DownloadPricingDataLock sync.RWMutex

+ Pricing map[string]*AWSProductTerms

+ ProjectID string

+ RIDataLock sync.RWMutex

+ RIDataRunning bool

+ RIPricingByInstanceID map[string]*RIData

+ RIPricingError error

+ SavingsPlanDataByInstanceID map[string]*SavingsPlanData

+ SavingsPlanDataLock sync.RWMutex

+ SavingsPlanDataRunning bool

+ ServiceAccountChecks *models.ServiceAccountChecks

+ SpotDataBucket string

+ SpotDataPrefix string

+ SpotDataRegion string

+ SpotLabelName string

+ SpotLabelValue string

+ SpotPricingByInstanceID map[string]*spotInfo

+ SpotPricingError error

+ SpotPricingLock sync.RWMutex

+ SpotPricingUpdatedAt *time.Time

+ SpotRefreshRunning bool

+ ValidPricingKeys map[string]bool

+ func (aws *AWS) AllNodePricing() (interface{}, error)

+ func (aws *AWS) ApplyReservedInstancePricing(nodes map[string]*models.Node)

+ func (aws *AWS) ClusterManagementPricing() (string, float64, error)

+ func (aws *AWS) CombinedDiscountForNode(instanceType string, isPreemptible bool, ...) float64

+ func (aws *AWS) ConfigureAuth() error

+ func (aws *AWS) ConfigureAuthWith(config *models.CustomPricing) error

+ func (aws *AWS) DownloadPricingData() error

+ func (aws *AWS) GetAWSAccessKey() (*AWSAccessKey, error)

+ func (aws *AWS) GetAWSAthenaInfo() (*AwsAthenaInfo, error)

+ func (aws *AWS) GetAddresses() ([]byte, error)

+ func (aws *AWS) GetConfig() (*models.CustomPricing, error)

+ func (aws *AWS) GetDisks() ([]byte, error)

+ func (aws *AWS) GetKey(labels map[string]string, n *v1.Node) models.Key

+ func (aws *AWS) GetLocalStorageQuery(window, offset time.Duration, rate bool, used bool) string

+ func (aws *AWS) GetManagementPlatform() (string, error)

+ func (aws *AWS) GetOrphanedResources() ([]models.OrphanedResource, error)

+ func (aws *AWS) GetPVKey(pv *v1.PersistentVolume, parameters map[string]string, defaultRegion string) models.PVKey

+ func (aws *AWS) GetReservationDataFromAthena() error

+ func (aws *AWS) GetSavingsPlanDataFromAthena() error

+ func (aws *AWS) KubeAttrConversion(location, instanceType, operatingSystem string) string

+ func (aws *AWS) LoadBalancerPricing() (*models.LoadBalancer, error)

+ func (aws *AWS) NetworkPricing() (*models.Network, error)

+ func (aws *AWS) NodePricing(k models.Key) (*models.Node, error)

+ func (aws *AWS) PVPricing(pvk models.PVKey) (*models.PV, error)

+ func (aws *AWS) PricingSourceStatus() map[string]*models.PricingSource

+ func (aws *AWS) PricingSourceSummary() interface{}

+ func (aws *AWS) QueryAthenaPaginated(ctx context.Context, query string, fn func(*athena.GetQueryResultsOutput) bool) error

+ func (aws *AWS) Regions() []string

+ func (aws *AWS) ServiceAccountStatus() *models.ServiceAccountStatus

+ func (aws *AWS) SpotRefreshEnabled() bool

+ func (aws *AWS) UpdateConfig(r io.Reader, updateType string) (*models.CustomPricing, error)

+ func (aws *AWS) UpdateConfigFromConfigMap(cm map[string]string) (*models.CustomPricing, error)

+ func (awsProvider *AWS) ClusterInfo() (map[string]string, error)

+ type AWSAccessKey struct

+ AccessKeyID string

+ SecretAccessKey string

+ func (accessKey AWSAccessKey) CreateConfig(region string) (awsSDK.Config, error)

+ func (accessKey AWSAccessKey) Retrieve(ctx context.Context) (awsSDK.Credentials, error)

+ type AWSCurrencyCode struct

+ CNY string

+ USD string

+ type AWSOfferTerm struct

+ OfferTermCode string

+ PriceDimensions map[string]*AWSRateCode

+ Sku string

+ func (ot *AWSOfferTerm) String() string

+ type AWSPricing struct

+ Products map[string]*AWSProduct

+ Terms AWSPricingTerms

+ type AWSPricingTerms struct

+ OnDemand map[string]map[string]*AWSOfferTerm

+ Reserved map[string]map[string]*AWSOfferTerm

+ type AWSProduct struct

+ Attributes AWSProductAttributes

+ Sku string

+ type AWSProductAttributes struct

+ CapacityStatus string

+ GPU string

+ InstanceFamily string

+ InstanceType string

+ Location string

+ Memory string

+ OperatingSystem string

+ PreInstalledSw string

+ Storage string

+ UsageType string

+ VCpu string

+ type AWSProductTerms struct

+ GPU string

+ Memory string

+ OnDemand *AWSOfferTerm

+ PV *models.PV

+ Reserved *AWSOfferTerm

+ Sku string

+ Storage string

+ VCpu string

+ type AWSRateCode struct

+ PricePerUnit AWSCurrencyCode

+ Unit string

+ func (rc *AWSRateCode) String() string

+ type AccessKey struct

+ ID string

+ Secret string

+ func (ak *AccessKey) CreateAWSConfig(region string) (cfg aws.Config, err error)

+ func (ak *AccessKey) Equals(config config.Config) bool

+ func (ak *AccessKey) MarshalJSON() ([]byte, error)

+ func (ak *AccessKey) Retrieve(ctx context.Context) (aws.Credentials, error)

+ func (ak *AccessKey) Sanitize() config.Config

+ func (ak *AccessKey) Validate() error

+ type AssumeRole struct

+ Authorizer Authorizer

+ RoleARN string

+ func (ara *AssumeRole) CreateAWSConfig(region string) (aws.Config, error)

+ func (ara *AssumeRole) Equals(config config.Config) bool

+ func (ara *AssumeRole) MarshalJSON() ([]byte, error)

+ func (ara *AssumeRole) Sanitize() config.Config

+ func (ara *AssumeRole) UnmarshalJSON(b []byte) error

+ func (ara *AssumeRole) Validate() error

+ type AthenaConfiguration struct

+ Account string

+ Authorizer Authorizer

+ Bucket string

+ Database string

+ Region string

+ Table string

+ Workgroup string

+ func (ac *AthenaConfiguration) Equals(config config.Config) bool

+ func (ac *AthenaConfiguration) Key() string

+ func (ac *AthenaConfiguration) Sanitize() config.Config

+ func (ac *AthenaConfiguration) UnmarshalJSON(b []byte) error

+ func (ac *AthenaConfiguration) Validate() error

+ type AthenaIntegration struct

+ func (ai *AthenaIntegration) CalculateK8sPercent(cost, k8sCost float64) float64

+ func (ai *AthenaIntegration) ConvertLabelToAWSTag(label string) string

+ func (ai *AthenaIntegration) GetAmortizedCostCase(allColumns map[string]bool) string

+ func (ai *AthenaIntegration) GetAmortizedNetCostCase(allColumns map[string]bool) string

+ func (ai *AthenaIntegration) GetAmortizedNetCostColumn(allColumns map[string]bool) string

+ func (ai *AthenaIntegration) GetCloudCost(start, end time.Time) (*kubecost.CloudCostSetRange, error)

+ func (ai *AthenaIntegration) GetConnectionStatus() string

+ func (ai *AthenaIntegration) GetConnectionStatusFromResult(result cloud.EmptyChecker, currentStatus cloud.ConnectionStatus) cloud.ConnectionStatus

+ func (ai *AthenaIntegration) GetIsKubernetesCase(allColumns map[string]bool) string

+ func (ai *AthenaIntegration) GetIsKubernetesColumn(allColumns map[string]bool) string

+ func (ai *AthenaIntegration) GetKubernetesCostColumn(allColumns map[string]bool, pricingCase string) string

+ func (ai *AthenaIntegration) GetListCostColumn() string

+ func (ai *AthenaIntegration) GetNetCostColumn(allColumns map[string]bool) string

+ func (ai *AthenaIntegration) RemoveColumnAliases(columns []string)

+ func (ai *AthenaIntegration) RowToCloudCost(row types.Row, aqi AthenaQueryIndexes, ccsr *kubecost.CloudCostSetRange) error

+ type AthenaQuerier struct

+ ConnectionStatus cloud.ConnectionStatus

+ func (aq *AthenaQuerier) Equals(config cloudconfig.Config) bool

+ func (aq *AthenaQuerier) GetAthenaClient() (*athena.Client, error)

+ func (aq *AthenaQuerier) GetColumns() (map[string]bool, error)

+ func (aq *AthenaQuerier) Query(ctx context.Context, query string, fn func(*athena.GetQueryResultsOutput) bool) error

+ type AthenaQueryIndexes struct

+ AmortizedCostColumn string

+ AmortizedK8sCostColumn string

+ AmortizedNetCostColumn string

+ AmortizedNetK8sCostColumn string

+ ColumnIndexes map[string]int

+ InvoicedCostColumn string

+ InvoicedK8sCostColumn string

+ ListCostColumn string

+ ListK8sCostColumn string

+ NetCostColumn string

+ NetK8sCostColumn string

+ Query string

+ TagColumns []string

+ type Authorizer interface

+ CreateAWSConfig func(string) (aws.Config, error)

+ func SelectAuthorizerByType(typeStr string) (Authorizer, error)

+ type AwsAthenaInfo struct

+ AccountID string

+ AthenaBucketName string

+ AthenaDatabase string

+ AthenaRegion string

+ AthenaTable string

+ AthenaWorkgroup string

+ MasterPayerARN string

+ ServiceKeyName string

+ ServiceKeySecret string

+ func (aai *AwsAthenaInfo) CreateConfig() (awsSDK.Config, error)

+ func (aai *AwsAthenaInfo) IsEmpty() bool

+ type AwsSpotFeedInfo struct

+ AccountID string

+ BucketName string

+ Prefix string

+ Region string

+ ServiceKeyName string

+ ServiceKeySecret string

+ SpotLabel string

+ SpotLabelValue string

+ type RIData struct

+ EffectiveCost float64

+ MostRecentDate string

+ ReservationARN string

+ ResourceID string

+ type S3Configuration struct

+ Account string

+ Authorizer Authorizer

+ Bucket string

+ Region string

+ func (s3c *S3Configuration) CreateAWSConfig() (aws.Config, error)

+ func (s3c *S3Configuration) Equals(config config.Config) bool

+ func (s3c *S3Configuration) Key() string

+ func (s3c *S3Configuration) Sanitize() config.Config

+ func (s3c *S3Configuration) UnmarshalJSON(b []byte) error

+ func (s3c *S3Configuration) Validate() error

+ type S3Connection struct

+ func (s3c *S3Connection) Equals(config config.Config) bool

+ func (s3c *S3Connection) GetS3Client() (*s3.Client, error)

+ func (s3c *S3Connection) ListObjects(cli *s3.Client) (*s3.ListObjectsOutput, error)

+ type S3SelectQuerier struct

+ func (s3sq *S3SelectQuerier) Equals(config config.Config) bool

+ func (s3sq *S3SelectQuerier) GetQueryKeys(start, end time.Time, client *s3.Client) ([]string, error)

+ func (s3sq *S3SelectQuerier) Query(query string, queryKeys []string, cli *s3.Client, fn func(*csv.Reader) error) error

+ type SavingsPlanData struct

+ EffectiveCost float64

+ MostRecentDate string

+ ResourceID string

+ SavingsPlanARN string

+ type ServiceAccount struct

+ func (sa *ServiceAccount) CreateAWSConfig(region string) (aws.Config, error)

+ func (sa *ServiceAccount) Equals(config config.Config) bool

+ func (sa *ServiceAccount) MarshalJSON() ([]byte, error)

+ func (sa *ServiceAccount) Sanitize() config.Config

+ func (sa *ServiceAccount) Validate() error