azure

package
v1.109.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 27, 2024 License: Apache-2.0 Imports: 46 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AzureFilePremiumStorageClass     = "premium_smb"
	AzureFileStandardStorageClass    = "standard_smb"
	AzureDiskPremiumSSDStorageClass  = "premium_ssd"
	AzureDiskStandardSSDStorageClass = "standard_ssd"
	AzureDiskStandardStorageClass    = "standard_hdd"

	AzureStorageUpdateType = "AzureStorage"
)
View Source 
const AzureEnterpriseDateLayout = "01/02/2006"
View Source 
const DefaultCredentialAuthorizerType = "AzureDefaultCredential"
View Source 
const SharedKeyAuthorizerType = "AzureAccessKey"

Variables

This section is empty.

Functions

func AzureIsK8s 

func AzureIsK8s(labels map[string]string) bool

Check for the presence of k8s labels

func AzureSetProviderID 

func AzureSetProviderID(abv *BillingRowValues) (providerID string, isVMSSShared bool)

isVMSSShared represents a bool that lets you know while setting providerID we were able to get the actual VMName associated with a VM of a group of VMs in VMSS.

func ConvertAzureStorageConfigToConfig 

func ConvertAzureStorageConfigToConfig(asc AzureStorageConfig) cloud.KeyedConfig

func NewClientCredentialsConfig 

func NewClientCredentialsConfig(clientID string, clientSecret string, tenantID string, env azure.Environment) auth.ClientCredentialsConfig

NewClientCredentialsConfig creates an AuthorizerConfig object configured to obtain an Authorizer through Client Credentials.

func ParseAzureSubscriptionID 

func ParseAzureSubscriptionID(id string) string

func SelectAzureCategory 

func SelectAzureCategory(meterCategory string) string

Types

type Authorizer 

type Authorizer interface {
	cloud.Authorizer
	GetCredential() (azcore.TokenCredential, error)
}

Authorizer configs provide credentials from azidentity to connect to Azure services.

func SelectAuthorizerByType 

func SelectAuthorizerByType(typeStr string) (Authorizer, error)

SelectAuthorizerByType is an implementation of AuthorizerSelectorFn and acts as a register for Authorizer types

type AuthorizerHolder added in v1.108.0 

type AuthorizerHolder struct {
	Authorizer
}

AuthorizerHolder is a StorageAuthorizer implementation that wraps an Authorizer implementation

func (*AuthorizerHolder) Equals added in v1.108.0 

func (ah *AuthorizerHolder) Equals(config cloud.Config) bool

func (*AuthorizerHolder) GetBlobClient added in v1.108.0 

func (ah *AuthorizerHolder) GetBlobClient(serviceURL string) (*azblob.Client, error)

func (*AuthorizerHolder) Sanitize added in v1.108.0 

func (ah *AuthorizerHolder) Sanitize() cloud.Config

type Azure 

type Azure struct {
	Pricing                 map[string]*AzurePricing
	DownloadPricingDataLock sync.RWMutex
	Clientset               clustercache.ClusterCache
	Config                  models.ProviderConfig
	ServiceAccountChecks    *models.ServiceAccountChecks
	ClusterAccountID        string
	ClusterRegion           string
	// contains filtered or unexported fields
}

func (*Azure) AllNodePricing 

func (az *Azure) AllNodePricing() (interface{}, error)

AllNodePricing returns the Azure pricing objects stored

func (*Azure) ApplyReservedInstancePricing 

func (az *Azure) ApplyReservedInstancePricing(nodes map[string]*models.Node)

func (*Azure) ClusterInfo 

func (az *Azure) ClusterInfo() (map[string]string, error)

func (*Azure) ClusterManagementPricing 

func (*Azure) ClusterManagementPricing() (string, float64, error)

func (*Azure) CombinedDiscountForNode 

func (az *Azure) CombinedDiscountForNode(instanceType string, isPreemptible bool, defaultDiscount, negotiatedDiscount float64) float64

func (*Azure) DownloadPricingData 

func (az *Azure) DownloadPricingData() error

DownloadPricingData uses provided azure "best guesses" for pricing

func (*Azure) GetAddresses 

func (*Azure) GetAddresses() ([]byte, error)

func (*Azure) GetAzureStorageConfig 

func (az *Azure) GetAzureStorageConfig(forceReload bool, cp *models.CustomPricing) (*AzureStorageConfig, error)

GetAzureStorageConfig retrieves storage config from secret and sets default values

func (*Azure) GetConfig 

func (az *Azure) GetConfig() (*models.CustomPricing, error)

func (*Azure) GetDisks 

func (az *Azure) GetDisks() ([]byte, error)

func (*Azure) GetKey 

func (az *Azure) GetKey(labels map[string]string, n *v1.Node) models.Key

func (*Azure) GetLocalStorageQuery 

func (az *Azure) GetLocalStorageQuery(window, offset time.Duration, rate bool, used bool) string

func (*Azure) GetManagementPlatform 

func (az *Azure) GetManagementPlatform() (string, error)

func (*Azure) GetOrphanedResources 

func (az *Azure) GetOrphanedResources() ([]models.OrphanedResource, error)

func (*Azure) GetPVKey 

func (az *Azure) GetPVKey(pv *v1.PersistentVolume, parameters map[string]string, defaultRegion string) models.PVKey

func (*Azure) LoadBalancerPricing 

func (azr *Azure) LoadBalancerPricing() (*models.LoadBalancer, error)

LoadBalancerPricing on Azure, LoadBalancer services correspond to public IPs. For now the pricing of LoadBalancer services will be that of a standard static public IP https://azure.microsoft.com/en-us/pricing/details/ip-addresses/. Azure still has load balancers which follow the standard pricing scheme based on rules https://azure.microsoft.com/en-us/pricing/details/load-balancer/, they are created on a per-cluster basis.

func (*Azure) NetworkPricing 

func (az *Azure) NetworkPricing() (*models.Network, error)

Stubbed NetworkPricing for Azure. Pull directly from azure.json for now

func (*Azure) NodePricing 

func (az *Azure) NodePricing(key models.Key) (*models.Node, models.PricingMetadata, error)

NodePricing returns Azure pricing data for a single node

func (*Azure) PVPricing 

func (az *Azure) PVPricing(pvk models.PVKey) (*models.PV, error)

func (*Azure) PricingSourceStatus 

func (az *Azure) PricingSourceStatus() map[string]*models.PricingSource

PricingSourceStatus returns the status of the rate card api

func (*Azure) PricingSourceSummary 

func (az *Azure) PricingSourceSummary() interface{}

PricingSourceSummary returns the pricing source summary for the provider. The summary represents what was _parsed_ from the pricing source, not everything that was _available_ in the pricing source.

func (*Azure) Regions 

func (az *Azure) Regions() []string

func (*Azure) ServiceAccountStatus 

func (az *Azure) ServiceAccountStatus() *models.ServiceAccountStatus

func (*Azure) UpdateConfig 

func (az *Azure) UpdateConfig(r io.Reader, updateType string) (*models.CustomPricing, error)

func (*Azure) UpdateConfigFromConfigMap 

func (az *Azure) UpdateConfigFromConfigMap(a map[string]string) (*models.CustomPricing, error)

type AzureAppKey 

type AzureAppKey struct {
	AppID       string `json:"appId"`
	DisplayName string `json:"displayName"`
	Name        string `json:"name"`
	Password    string `json:"password"`
	Tenant      string `json:"tenant"`
}

Represents an azure app key

type AzureBillingResultFunc 

type AzureBillingResultFunc func(*BillingRowValues) error

type AzurePricing 

type AzurePricing struct {
	Node *models.Node
	PV   *models.PV
}

AzurePricing either contains a Node or PV

type AzureRetailPricing 

type AzureRetailPricing struct {
	BillingCurrency    string                         `json:"BillingCurrency"`
	CustomerEntityId   string                         `json:"CustomerEntityId"`
	CustomerEntityType string                         `json:"CustomerEntityType"`
	Items              []AzureRetailPricingAttributes `json:"Items"`
	NextPageLink       string                         `json:"NextPageLink"`
	Count              int                            `json:"Count"`
}

AzureRetailPricing struct for unmarshalling Azure Retail pricing api JSON response

type AzureRetailPricingAttributes 

type AzureRetailPricingAttributes struct {
	CurrencyCode         string     `json:"currencyCode"`
	TierMinimumUnits     float32    `json:"tierMinimumUnits"`
	RetailPrice          float32    `json:"retailPrice"`
	UnitPrice            float32    `json:"unitPrice"`
	ArmRegionName        string     `json:"armRegionName"`
	Location             string     `json:"location"`
	EffectiveStartDate   *time.Time `json:"effectiveStartDate"`
	EffectiveEndDate     *time.Time `json:"effectiveEndDate"`
	MeterId              string     `json:"meterId"`
	MeterName            string     `json:"meterName"`
	ProductId            string     `json:"productId"`
	SkuId                string     `json:"skuId"`
	ProductName          string     `json:"productName"`
	SkuName              string     `json:"skuName"`
	ServiceName          string     `json:"serviceName"`
	ServiceId            string     `json:"serviceId"`
	ServiceFamily        string     `json:"serviceFamily"`
	UnitOfMeasure        string     `json:"unitOfMeasure"`
	Type                 string     `json:"type"`
	IsPrimaryMeterRegion bool       `json:"isPrimaryMeterRegion"`
	ArmSkuName           string     `json:"armSkuName"`
}

AzureRetailPricingAttributes struct for unmarshalling Azure Retail pricing api JSON response

type AzureServiceKey 

type AzureServiceKey struct {
	SubscriptionID string       `json:"subscriptionId"`
	ServiceKey     *AzureAppKey `json:"serviceKey"`
}

AzureServiceKey service key for a specific subscription Deprecated: v1.104 Use ServiceKey instead

func (*AzureServiceKey) IsValid 

func (ask *AzureServiceKey) IsValid() bool

Validity check on service key

type AzureStorageBillingParser 

type AzureStorageBillingParser struct {
	StorageConnection
}

AzureStorageBillingParser accesses billing data stored in CSV files in Azure Storage

func (*AzureStorageBillingParser) Equals 

func (asbp *AzureStorageBillingParser) Equals(config cloud.Config) bool

func (*AzureStorageBillingParser) ParseBillingData 

func (asbp *AzureStorageBillingParser) ParseBillingData(start, end time.Time, resultFn AzureBillingResultFunc) error

type AzureStorageConfig 

type AzureStorageConfig struct {
	SubscriptionId string `json:"azureSubscriptionID"`
	AccountName    string `json:"azureStorageAccount"`
	AccessKey      string `json:"azureStorageAccessKey"`
	ContainerName  string `json:"azureStorageContainer"`
	ContainerPath  string `json:"azureContainerPath"`
	AzureCloud     string `json:"azureCloud"`
}

AzureStorageConfig Represents an azure storage config Deprecated: v1.104 Use StorageConfiguration instead

func (*AzureStorageConfig) IsEmpty 

func (asc *AzureStorageConfig) IsEmpty() bool

IsEmpty returns true if all fields in config are empty, false if not.

type AzureStorageIntegration 

type AzureStorageIntegration struct {
	AzureStorageBillingParser
}

func (*AzureStorageIntegration) GetCloudCost 

func (asi *AzureStorageIntegration) GetCloudCost(start, end time.Time) (*opencost.CloudCostSetRange, error)

type BillingExportParser 

type BillingExportParser struct {
	Date            int
	MeterCategory   int
	InvoiceEntityID int
	SubscriptionID  int
	InstanceID      int
	Service         int
	Tags            int
	AdditionalInfo  int
	Cost            int
	NetCost         int
	DateFormat      string
}

BillingExportParser holds indexes of relevent fields in Azure Billing CSV in addition to the correct data format

func NewBillingParseSchema 

func NewBillingParseSchema(headers []string) (*BillingExportParser, error)

func (*BillingExportParser) ParseRow 

func (bep *BillingExportParser) ParseRow(start, end time.Time, record []string) *BillingRowValues

type BillingRowValues 

type BillingRowValues struct {
	Date            time.Time
	MeterCategory   string
	SubscriptionID  string
	InvoiceEntityID string
	InstanceID      string
	Service         string
	Tags            map[string]string
	AdditionalInfo  map[string]any
	Cost            float64
	NetCost         float64
}

BillingRowValues holder for Azure Billing Values

func (*BillingRowValues) IsCompute 

func (brv *BillingRowValues) IsCompute(category string) bool

type DefaultAzureCredentialHolder added in v1.108.0 

type DefaultAzureCredentialHolder struct{}

func (*DefaultAzureCredentialHolder) Equals added in v1.108.0 

func (dac *DefaultAzureCredentialHolder) Equals(config cloud.Config) bool

func (*DefaultAzureCredentialHolder) GetCredential added in v1.108.0 

func (dac *DefaultAzureCredentialHolder) GetCredential() (azcore.TokenCredential, error)

func (*DefaultAzureCredentialHolder) MarshalJSON added in v1.108.0 

func (dac *DefaultAzureCredentialHolder) MarshalJSON() ([]byte, error)

func (*DefaultAzureCredentialHolder) Sanitize added in v1.108.0 

func (dac *DefaultAzureCredentialHolder) Sanitize() cloud.Config

func (*DefaultAzureCredentialHolder) Validate added in v1.108.0 

func (dac *DefaultAzureCredentialHolder) Validate() error

type PriceSheetClient 

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

PriceSheetClient contains the methods for the PriceSheet group. Don't use this type directly, use NewPriceSheetClient() instead.

func NewPriceSheetClient 

func NewPriceSheetClient(billingAccountID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*PriceSheetClient, error)

NewPriceSheetClient creates a new instance of PriceSheetClient with the specified values. billingAccountId - Azure Billing Account ID. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*PriceSheetClient) BeginDownloadByBillingPeriod 

func (client *PriceSheetClient) BeginDownloadByBillingPeriod(ctx context.Context, billingPeriodName string) (*runtime.Poller[PriceSheetClientDownloadResponse], error)

BeginDownloadByBillingPeriod - requests a pricesheet for a specific billing period `yyyymm`. Returns a Poller that will provide the download URL when the pricesheet is ready. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2022-06-01 billingPeriodName - Billing Period Name `yyyymm`.

type PriceSheetClientDownloadProperties 

type PriceSheetClientDownloadProperties struct {
	DownloadURL string `json:"downloadUrl"`
	ValidTill   string `json:"validTill"`
}

type PriceSheetClientDownloadResponse 

type PriceSheetClientDownloadResponse struct {
	ID         string                             `json:"id"`
	Name       string                             `json:"name"`
	StartTime  time.Time                          `json:"startTime"`
	EndTime    time.Time                          `json:"endTime"`
	Status     string                             `json:"status"`
	Properties PriceSheetClientDownloadProperties `json:"properties"`
}

type PriceSheetDownloader 

type PriceSheetDownloader struct {
	TenantID         string
	ClientID         string
	ClientSecret     string
	BillingAccount   string
	OfferID          string
	ConvertMeterInfo func(info commerce.MeterInfo) (map[string]*AzurePricing, error)
}

func (*PriceSheetDownloader) GetPricing 

func (d *PriceSheetDownloader) GetPricing(ctx context.Context) (map[string]*AzurePricing, error)

type SharedKeyCredential added in v1.108.0 

type SharedKeyCredential struct {
	AccessKey string `json:"accessKey"`
	Account   string `json:"account"`
}

SharedKeyCredential is a StorageAuthorizer with credentials which cannot be used to authorize other services. This is a legacy auth method which is not included in azidentity

func (*SharedKeyCredential) Equals added in v1.108.0 

func (skc *SharedKeyCredential) Equals(config cloud.Config) bool

func (*SharedKeyCredential) GetBlobClient added in v1.108.0 

func (skc *SharedKeyCredential) GetBlobClient(serviceURL string) (*azblob.Client, error)

func (*SharedKeyCredential) MarshalJSON added in v1.108.0 

func (skc *SharedKeyCredential) MarshalJSON() ([]byte, error)

func (*SharedKeyCredential) Sanitize added in v1.108.0 

func (skc *SharedKeyCredential) Sanitize() cloud.Config

func (*SharedKeyCredential) Validate added in v1.108.0 

func (skc *SharedKeyCredential) Validate() error

type StorageAuthorizer added in v1.108.0 

type StorageAuthorizer interface {
	cloud.Authorizer
	GetBlobClient(serviceURL string) (*azblob.Client, error)
}

StorageAuthorizer is a service specific Authorizer for Azure Storage, it exists so that we can support existing Shared Key configurations while allowing the Authorizer to have a service agnostic api

func SelectStorageAuthorizerByType added in v1.108.0 

func SelectStorageAuthorizerByType(typeStr string) (StorageAuthorizer, error)

SelectStorageAuthorizerByType is an implementation of AuthorizerSelectorFn and acts as a register for Authorizer types

type StorageConfiguration 

type StorageConfiguration struct {
	SubscriptionID string            `json:"subscriptionID"`
	Account        string            `json:"account"`
	Container      string            `json:"container"`
	Path           string            `json:"path"`
	Cloud          string            `json:"cloud"`
	Authorizer     StorageAuthorizer `json:"authorizer"`
}

func (*StorageConfiguration) Equals 

func (sc *StorageConfiguration) Equals(config cloud.Config) bool

func (*StorageConfiguration) Key 

func (sc *StorageConfiguration) Key() string

func (*StorageConfiguration) Provider added in v1.107.0 

func (sc *StorageConfiguration) Provider() string

func (*StorageConfiguration) Sanitize 

func (sc *StorageConfiguration) Sanitize() cloud.Config

func (*StorageConfiguration) UnmarshalJSON 

func (sc *StorageConfiguration) UnmarshalJSON(b []byte) error

func (*StorageConfiguration) Validate 

func (sc *StorageConfiguration) Validate() error

Check ensures that all required fields are set, and throws an error if they are not

type StorageConnection 

type StorageConnection struct {
	StorageConfiguration
	ConnectionStatus cloud.ConnectionStatus
}

StorageConnection provides access to Azure Storage

func (*StorageConnection) DownloadBlobToFile added in v1.109.0 

func (sc *StorageConnection) DownloadBlobToFile(localFilePath string, blobName string, client *azblob.Client, ctx context.Context) error

DownloadBlobToFile downloads the Azure Billing CSV to a local file

func (*StorageConnection) Equals 

func (sc *StorageConnection) Equals(config cloud.Config) bool

func (*StorageConnection) GetStatus added in v1.107.0 

func (sc *StorageConnection) GetStatus() cloud.ConnectionStatus

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.