costmodelenv.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610
  1. package env
  2. import (
  3. "fmt"
  4. "regexp"
  5. "strconv"
  6. "time"
  7. "github.com/opencost/opencost/pkg/log"
  8. "github.com/opencost/opencost/pkg/util/timeutil"
  9. )
  10. const (
  11. AWSAccessKeyIDEnvVar = "AWS_ACCESS_KEY_ID"
  12. AWSAccessKeySecretEnvVar = "AWS_SECRET_ACCESS_KEY"
  13. AWSClusterIDEnvVar = "AWS_CLUSTER_ID"
  14. AWSPricingURL = "AWS_PRICING_URL"
  15. AlibabaAccessKeyIDEnvVar = "ALIBABA_ACCESS_KEY_ID"
  16. AlibabaAccessKeySecretEnvVar = "ALIBABA_SECRET_ACCESS_KEY"
  17. AzureOfferIDEnvVar = "AZURE_OFFER_ID"
  18. AzureBillingAccountEnvVar = "AZURE_BILLING_ACCOUNT"
  19. KubecostNamespaceEnvVar = "KUBECOST_NAMESPACE"
  20. PodNameEnvVar = "POD_NAME"
  21. ClusterIDEnvVar = "CLUSTER_ID"
  22. ClusterProfileEnvVar = "CLUSTER_PROFILE"
  23. PrometheusServerEndpointEnvVar = "PROMETHEUS_SERVER_ENDPOINT"
  24. MaxQueryConcurrencyEnvVar = "MAX_QUERY_CONCURRENCY"
  25. QueryLoggingFileEnvVar = "QUERY_LOGGING_FILE"
  26. RemoteEnabledEnvVar = "REMOTE_WRITE_ENABLED"
  27. RemotePWEnvVar = "REMOTE_WRITE_PASSWORD"
  28. SQLAddressEnvVar = "SQL_ADDRESS"
  29. UseCSVProviderEnvVar = "USE_CSV_PROVIDER"
  30. CSVRegionEnvVar = "CSV_REGION"
  31. CSVEndpointEnvVar = "CSV_ENDPOINT"
  32. CSVPathEnvVar = "CSV_PATH"
  33. ConfigPathEnvVar = "CONFIG_PATH"
  34. CloudProviderAPIKeyEnvVar = "CLOUD_PROVIDER_API_KEY"
  35. DisableAggregateCostModelCache = "DISABLE_AGGREGATE_COST_MODEL_CACHE"
  36. EmitPodAnnotationsMetricEnvVar = "EMIT_POD_ANNOTATIONS_METRIC"
  37. EmitNamespaceAnnotationsMetricEnvVar = "EMIT_NAMESPACE_ANNOTATIONS_METRIC"
  38. EmitKsmV1MetricsEnvVar = "EMIT_KSM_V1_METRICS"
  39. EmitKsmV1MetricsOnly = "EMIT_KSM_V1_METRICS_ONLY"
  40. ThanosEnabledEnvVar = "THANOS_ENABLED"
  41. ThanosQueryUrlEnvVar = "THANOS_QUERY_URL"
  42. ThanosOffsetEnvVar = "THANOS_QUERY_OFFSET"
  43. ThanosMaxSourceResEnvVar = "THANOS_MAX_SOURCE_RESOLUTION"
  44. LogCollectionEnabledEnvVar = "LOG_COLLECTION_ENABLED"
  45. ProductAnalyticsEnabledEnvVar = "PRODUCT_ANALYTICS_ENABLED"
  46. ErrorReportingEnabledEnvVar = "ERROR_REPORTING_ENABLED"
  47. ValuesReportingEnabledEnvVar = "VALUES_REPORTING_ENABLED"
  48. DBBasicAuthUsername = "DB_BASIC_AUTH_USERNAME"
  49. DBBasicAuthPassword = "DB_BASIC_AUTH_PW"
  50. DBBearerToken = "DB_BEARER_TOKEN"
  51. MultiClusterBasicAuthUsername = "MC_BASIC_AUTH_USERNAME"
  52. MultiClusterBasicAuthPassword = "MC_BASIC_AUTH_PW"
  53. MultiClusterBearerToken = "MC_BEARER_TOKEN"
  54. InsecureSkipVerify = "INSECURE_SKIP_VERIFY"
  55. KubeConfigPathEnvVar = "KUBECONFIG_PATH"
  56. UTCOffsetEnvVar = "UTC_OFFSET"
  57. CurrentClusterIdFilterEnabledVar = "CURRENT_CLUSTER_ID_FILTER_ENABLED"
  58. CacheWarmingEnabledEnvVar = "CACHE_WARMING_ENABLED"
  59. ETLEnabledEnvVar = "ETL_ENABLED"
  60. ETLMaxPrometheusQueryDurationMinutes = "ETL_MAX_PROMETHEUS_QUERY_DURATION_MINUTES"
  61. ETLResolutionSeconds = "ETL_RESOLUTION_SECONDS"
  62. LegacyExternalAPIDisabledVar = "LEGACY_EXTERNAL_API_DISABLED"
  63. PromClusterIDLabelEnvVar = "PROM_CLUSTER_ID_LABEL"
  64. PricingConfigmapName = "PRICING_CONFIGMAP_NAME"
  65. MetricsConfigmapName = "METRICS_CONFIGMAP_NAME"
  66. KubecostJobNameEnvVar = "KUBECOST_JOB_NAME"
  67. KubecostConfigBucketEnvVar = "KUBECOST_CONFIG_BUCKET"
  68. ClusterInfoFileEnabledEnvVar = "CLUSTER_INFO_FILE_ENABLED"
  69. ClusterCacheFileEnabledEnvVar = "CLUSTER_CACHE_FILE_ENABLED"
  70. PrometheusQueryOffsetEnvVar = "PROMETHEUS_QUERY_OFFSET"
  71. PrometheusRetryOnRateLimitResponseEnvVar = "PROMETHEUS_RETRY_ON_RATE_LIMIT"
  72. PrometheusRetryOnRateLimitMaxRetriesEnvVar = "PROMETHEUS_RETRY_ON_RATE_LIMIT_MAX_RETRIES"
  73. PrometheusRetryOnRateLimitDefaultWaitEnvVar = "PROMETHEUS_RETRY_ON_RATE_LIMIT_DEFAULT_WAIT"
  74. PrometheusHeaderXScopeOrgIdEnvVar = "PROMETHEUS_HEADER_X_SCOPE_ORGID"
  75. IngestPodUIDEnvVar = "INGEST_POD_UID"
  76. ETLReadOnlyMode = "ETL_READ_ONLY"
  77. AllocationNodeLabelsEnabled = "ALLOCATION_NODE_LABELS_ENABLED"
  78. AllocationNodeLabelsIncludeList = "ALLOCATION_NODE_LABELS_INCLUDE_LIST"
  79. regionOverrideList = "REGION_OVERRIDE_LIST"
  80. ExportCSVFile = "EXPORT_CSV_FILE"
  81. ExportCSVLabelsList = "EXPORT_CSV_LABELS_LIST"
  82. ExportCSVLabelsAll = "EXPORT_CSV_LABELS_ALL"
  83. ExportCSVMaxDays = "EXPORT_CSV_MAX_DAYS"
  84. )
  85. const DefaultConfigMountPath = "/var/configs"
  86. var offsetRegex = regexp.MustCompile(`^(\+|-)(\d\d):(\d\d)$`)
  87. func IsETLReadOnlyMode() bool {
  88. return GetBool(ETLReadOnlyMode, false)
  89. }
  90. func GetExportCSVFile() string {
  91. return Get(ExportCSVFile, "")
  92. }
  93. func GetExportCSVLabelsAll() bool {
  94. return GetBool(ExportCSVLabelsAll, false)
  95. }
  96. func GetExportCSVLabelsList() []string {
  97. return GetList(ExportCSVLabelsList, ",")
  98. }
  99. func GetExportCSVMaxDays() int {
  100. return GetInt(ExportCSVMaxDays, 90)
  101. }
  102. // GetKubecostConfigBucket returns a file location for a mounted bucket configuration which is used to store
  103. // a subset of kubecost configurations that require sharing via remote storage.
  104. func GetKubecostConfigBucket() string {
  105. return Get(KubecostConfigBucketEnvVar, "")
  106. }
  107. // IsClusterInfoFileEnabled returns true if the cluster info is read from a file or pulled from the local
  108. // cloud provider and kubernetes.
  109. func IsClusterInfoFileEnabled() bool {
  110. return GetBool(ClusterInfoFileEnabledEnvVar, false)
  111. }
  112. // IsClusterCacheFileEnabled returns true if the kubernetes cluster data is read from a file or pulled from the local
  113. // kubernetes API.
  114. func IsClusterCacheFileEnabled() bool {
  115. return GetBool(ClusterCacheFileEnabledEnvVar, false)
  116. }
  117. // IsPrometheusRetryOnRateLimitResponse will attempt to retry if a 429 response is received OR a 400 with a body containing
  118. // ThrottleException (common in AWS services like AMP)
  119. func IsPrometheusRetryOnRateLimitResponse() bool {
  120. return GetBool(PrometheusRetryOnRateLimitResponseEnvVar, true)
  121. }
  122. // GetPrometheusRetryOnRateLimitMaxRetries returns the maximum number of retries that should be attempted prior to failing.
  123. // Only used if IsPrometheusRetryOnRateLimitResponse() is true.
  124. func GetPrometheusRetryOnRateLimitMaxRetries() int {
  125. return GetInt(PrometheusRetryOnRateLimitMaxRetriesEnvVar, 5)
  126. }
  127. // GetPrometheusRetryOnRateLimitDefaultWait returns the default wait time for a retriable rate limit response without a
  128. // Retry-After header.
  129. func GetPrometheusRetryOnRateLimitDefaultWait() time.Duration {
  130. return GetDuration(PrometheusRetryOnRateLimitDefaultWaitEnvVar, 100*time.Millisecond)
  131. }
  132. // GetPrometheusHeaderXScopeOrgId returns the default value for X-Scope-OrgID header used for requests in Mimir/Cortex-Tenant API.
  133. // To use Mimir(or Cortex-Tenant) instead of Prometheus add variable from cluster settings:
  134. // "PROMETHEUS_HEADER_X_SCOPE_ORGID": "my-cluster-name"
  135. // Then set Prometheus URL to prometheus API endpoint:
  136. // "PROMETHEUS_SERVER_ENDPOINT": "http://mimir-url/prometheus/"
  137. func GetPrometheusHeaderXScopeOrgId() string {
  138. return Get(PrometheusHeaderXScopeOrgIdEnvVar, "")
  139. }
  140. // GetPrometheusQueryOffset returns the time.Duration to offset all prometheus queries by. NOTE: This env var is applied
  141. // to all non-range queries made via our query context. This should only be applied when there is a significant delay in
  142. // data arriving in the target prom db. For example, if supplying a thanos or cortex querier for the prometheus server, using
  143. // a 3h offset will ensure that current time = current time - 3h.
  144. //
  145. // This offset is NOT the same as the GetThanosOffset() option, as that is only applied to queries made specifically targeting
  146. // thanos. This offset is applied globally.
  147. func GetPrometheusQueryOffset() time.Duration {
  148. offset := Get(PrometheusQueryOffsetEnvVar, "")
  149. if offset == "" {
  150. return 0
  151. }
  152. dur, err := timeutil.ParseDuration(offset)
  153. if err != nil {
  154. return 0
  155. }
  156. return dur
  157. }
  158. func GetPricingConfigmapName() string {
  159. return Get(PricingConfigmapName, "pricing-configs")
  160. }
  161. func GetMetricsConfigmapName() string {
  162. return Get(MetricsConfigmapName, "metrics-config")
  163. }
  164. // IsEmitNamespaceAnnotationsMetric returns true if cost-model is configured to emit the kube_namespace_annotations metric
  165. // containing the namespace annotations
  166. func IsEmitNamespaceAnnotationsMetric() bool {
  167. return GetBool(EmitNamespaceAnnotationsMetricEnvVar, false)
  168. }
  169. // IsEmitPodAnnotationsMetric returns true if cost-model is configured to emit the kube_pod_annotations metric containing
  170. // pod annotations.
  171. func IsEmitPodAnnotationsMetric() bool {
  172. return GetBool(EmitPodAnnotationsMetricEnvVar, false)
  173. }
  174. // IsEmitKsmV1Metrics returns true if cost-model is configured to emit all necessary KSM v1
  175. // metrics that were removed in KSM v2
  176. func IsEmitKsmV1Metrics() bool {
  177. return GetBool(EmitKsmV1MetricsEnvVar, true)
  178. }
  179. func IsEmitKsmV1MetricsOnly() bool {
  180. return GetBool(EmitKsmV1MetricsOnly, false)
  181. }
  182. // GetAWSAccessKeyID returns the environment variable value for AWSAccessKeyIDEnvVar which represents
  183. // the AWS access key for authentication
  184. func GetAWSAccessKeyID() string {
  185. awsAccessKeyID := Get(AWSAccessKeyIDEnvVar, "")
  186. // If the sample nil service key name is set, zero it out so that it is not
  187. // misinterpreted as a real service key.
  188. if awsAccessKeyID == "AKIXXX" {
  189. awsAccessKeyID = ""
  190. }
  191. return awsAccessKeyID
  192. }
  193. // GetAWSAccessKeySecret returns the environment variable value for AWSAccessKeySecretEnvVar which represents
  194. // the AWS access key secret for authentication
  195. func GetAWSAccessKeySecret() string {
  196. return Get(AWSAccessKeySecretEnvVar, "")
  197. }
  198. // GetAWSClusterID returns the environment variable value for AWSClusterIDEnvVar which represents
  199. // an AWS specific cluster identifier.
  200. func GetAWSClusterID() string {
  201. return Get(AWSClusterIDEnvVar, "")
  202. }
  203. // GetAWSPricingURL returns an optional alternative URL to fetch AWS pricing data from; for use in airgapped environments
  204. func GetAWSPricingURL() string {
  205. return Get(AWSPricingURL, "")
  206. }
  207. // GetAlibabaAccessKeyID returns the environment variable value for AlibabaAccessKeyIDEnvVar which represents
  208. // the Alibaba access key for authentication
  209. func GetAlibabaAccessKeyID() string {
  210. return Get(AlibabaAccessKeyIDEnvVar, "")
  211. }
  212. // GetAlibabaAccessKeySecret returns the environment variable value for AlibabaAccessKeySecretEnvVar which represents
  213. // the Alibaba access key secret for authentication
  214. func GetAlibabaAccessKeySecret() string {
  215. return Get(AlibabaAccessKeySecretEnvVar, "")
  216. }
  217. // GetAzureOfferID returns the environment variable value for AzureOfferIDEnvVar which represents
  218. // the Azure offer ID for determining prices.
  219. func GetAzureOfferID() string {
  220. return Get(AzureOfferIDEnvVar, "")
  221. }
  222. // GetAzureBillingAccount returns the environment variable value for
  223. // AzureBillingAccountEnvVar which represents the Azure billing
  224. // account for determining prices. If this is specified
  225. // customer-specific prices will be downloaded from the consumption
  226. // price sheet API.
  227. func GetAzureBillingAccount() string {
  228. return Get(AzureBillingAccountEnvVar, "")
  229. }
  230. // GetKubecostNamespace returns the environment variable value for KubecostNamespaceEnvVar which
  231. // represents the namespace the cost model exists in.
  232. func GetKubecostNamespace() string {
  233. return Get(KubecostNamespaceEnvVar, "kubecost")
  234. }
  235. // GetPodName returns the name of the current running pod. If this environment variable is not set,
  236. // empty string is returned.
  237. func GetPodName() string {
  238. return Get(PodNameEnvVar, "")
  239. }
  240. // GetClusterProfile returns the environment variable value for ClusterProfileEnvVar which
  241. // represents the cluster profile configured for
  242. func GetClusterProfile() string {
  243. return Get(ClusterProfileEnvVar, "development")
  244. }
  245. // GetClusterID returns the environment variable value for ClusterIDEnvVar which represents the
  246. // configurable identifier used for multi-cluster metric emission.
  247. func GetClusterID() string {
  248. return Get(ClusterIDEnvVar, "")
  249. }
  250. // GetPromClusterFilter returns environment variable value CurrentClusterIdFilterEnabledVar which
  251. // represents additional prometheus filter for all metrics for current cluster id
  252. func GetPromClusterFilter() string {
  253. if GetBool(CurrentClusterIdFilterEnabledVar, false) {
  254. return fmt.Sprintf("%s=\"%s\"", GetPromClusterLabel(), GetClusterID())
  255. }
  256. return ""
  257. }
  258. // GetPrometheusServerEndpoint returns the environment variable value for PrometheusServerEndpointEnvVar which
  259. // represents the prometheus server endpoint used to execute prometheus queries.
  260. func GetPrometheusServerEndpoint() string {
  261. return Get(PrometheusServerEndpointEnvVar, "")
  262. }
  263. func GetInsecureSkipVerify() bool {
  264. return GetBool(InsecureSkipVerify, false)
  265. }
  266. // IsAggregateCostModelCacheDisabled returns the environment variable value for DisableAggregateCostModelCache which
  267. // will inform the aggregator on whether to load cached data. Defaults to false
  268. func IsAggregateCostModelCacheDisabled() bool {
  269. return GetBool(DisableAggregateCostModelCache, false)
  270. }
  271. // IsRemoteEnabled returns the environment variable value for RemoteEnabledEnvVar which represents whether
  272. // or not remote write is enabled for prometheus for use with SQL backed persistent storage.
  273. func IsRemoteEnabled() bool {
  274. return GetBool(RemoteEnabledEnvVar, false)
  275. }
  276. // GetRemotePW returns the environment variable value for RemotePWEnvVar which represents the remote
  277. // persistent storage password.
  278. func GetRemotePW() string {
  279. return Get(RemotePWEnvVar, "")
  280. }
  281. // GetSQLAddress returns the environment variable value for SQLAddressEnvVar which represents the SQL
  282. // database address used with remote persistent storage.
  283. func GetSQLAddress() string {
  284. return Get(SQLAddressEnvVar, "")
  285. }
  286. // IsUseCSVProvider returns the environment variable value for UseCSVProviderEnvVar which represents
  287. // whether or not the use of a CSV cost provider is enabled.
  288. func IsUseCSVProvider() bool {
  289. return GetBool(UseCSVProviderEnvVar, false)
  290. }
  291. // GetCSVRegion returns the environment variable value for CSVRegionEnvVar which represents the
  292. // region configured for a CSV provider.
  293. func GetCSVRegion() string {
  294. return Get(CSVRegionEnvVar, "")
  295. }
  296. // GetCSVEndpoint returns the environment variable value for CSVEndpointEnvVar which represents the
  297. // endpoint configured for a S3 CSV provider another than AWS S3.
  298. func GetCSVEndpoint() string {
  299. return Get(CSVEndpointEnvVar, "")
  300. }
  301. // GetCSVPath returns the environment variable value for CSVPathEnvVar which represents the key path
  302. // configured for a CSV provider.
  303. func GetCSVPath() string {
  304. return Get(CSVPathEnvVar, "")
  305. }
  306. // GetCostAnalyzerVolumeMountPath is an alias of GetConfigPath, which returns the mount path for the
  307. // Cost Analyzer volume, which stores configs, persistent data, etc.
  308. func GetCostAnalyzerVolumeMountPath() string {
  309. return GetConfigPathWithDefault(DefaultConfigMountPath)
  310. }
  311. // GetConfigPath returns the environment variable value for ConfigPathEnvVar which represents the cost
  312. // model configuration path
  313. func GetConfigPathWithDefault(defaultValue string) string {
  314. return Get(ConfigPathEnvVar, defaultValue)
  315. }
  316. // GetCloudProviderAPI returns the environment variable value for CloudProviderAPIEnvVar which represents
  317. // the API key provided for the cloud provider.
  318. func GetCloudProviderAPIKey() string {
  319. return Get(CloudProviderAPIKeyEnvVar, "")
  320. }
  321. // IsThanosEnabled returns the environment variable value for ThanosEnabledEnvVar which represents whether
  322. // or not thanos is enabled.
  323. func IsThanosEnabled() bool {
  324. return GetBool(ThanosEnabledEnvVar, false)
  325. }
  326. // GetThanosQueryUrl returns the environment variable value for ThanosQueryUrlEnvVar which represents the
  327. // target query endpoint for hitting thanos.
  328. func GetThanosQueryUrl() string {
  329. return Get(ThanosQueryUrlEnvVar, "")
  330. }
  331. // GetThanosOffset returns the environment variable value for ThanosOffsetEnvVar which represents the total
  332. // amount of time to offset all queries made to thanos.
  333. func GetThanosOffset() string {
  334. return Get(ThanosOffsetEnvVar, "3h")
  335. }
  336. // GetThanosMaxSourceResolution returns the environment variable value for ThanosMaxSourceResEnvVar which represents
  337. // the max source resolution to use when querying thanos.
  338. func GetThanosMaxSourceResolution() string {
  339. res := Get(ThanosMaxSourceResEnvVar, "raw")
  340. switch res {
  341. case "raw":
  342. return "0s"
  343. case "0s":
  344. fallthrough
  345. case "5m":
  346. fallthrough
  347. case "1h":
  348. return res
  349. default:
  350. return "0s"
  351. }
  352. }
  353. // IsLogCollectionEnabled returns the environment variable value for LogCollectionEnabledEnvVar which represents
  354. // whether or not log collection has been enabled for kubecost deployments.
  355. func IsLogCollectionEnabled() bool {
  356. return GetBool(LogCollectionEnabledEnvVar, true)
  357. }
  358. // IsProductAnalyticsEnabled returns the environment variable value for ProductAnalyticsEnabledEnvVar
  359. func IsProductAnalyticsEnabled() bool {
  360. return GetBool(ProductAnalyticsEnabledEnvVar, true)
  361. }
  362. // IsErrorReportingEnabled returns the environment variable value for ErrorReportingEnabledEnvVar
  363. func IsErrorReportingEnabled() bool {
  364. return GetBool(ErrorReportingEnabledEnvVar, true)
  365. }
  366. // IsValuesReportingEnabled returns the environment variable value for ValuesReportingEnabledEnvVar
  367. func IsValuesReportingEnabled() bool {
  368. return GetBool(ValuesReportingEnabledEnvVar, true)
  369. }
  370. // GetMaxQueryConcurrency returns the environment variable value for MaxQueryConcurrencyEnvVar
  371. func GetMaxQueryConcurrency() int {
  372. return GetInt(MaxQueryConcurrencyEnvVar, 5)
  373. }
  374. // GetQueryLoggingFile returns a file location if query logging is enabled. Otherwise, empty string
  375. func GetQueryLoggingFile() string {
  376. return Get(QueryLoggingFileEnvVar, "")
  377. }
  378. func GetDBBasicAuthUsername() string {
  379. return Get(DBBasicAuthUsername, "")
  380. }
  381. func GetDBBasicAuthUserPassword() string {
  382. return Get(DBBasicAuthPassword, "")
  383. }
  384. func GetDBBearerToken() string {
  385. return Get(DBBearerToken, "")
  386. }
  387. // GetMultiClusterBasicAuthUsername returns the environment variable value for MultiClusterBasicAuthUsername
  388. func GetMultiClusterBasicAuthUsername() string {
  389. return Get(MultiClusterBasicAuthUsername, "")
  390. }
  391. // GetMultiClusterBasicAuthPassword returns the environment variable value for MultiClusterBasicAuthPassword
  392. func GetMultiClusterBasicAuthPassword() string {
  393. return Get(MultiClusterBasicAuthPassword, "")
  394. }
  395. func GetMultiClusterBearerToken() string {
  396. return Get(MultiClusterBearerToken, "")
  397. }
  398. // GetKubeConfigPath returns the environment variable value for KubeConfigPathEnvVar
  399. func GetKubeConfigPath() string {
  400. return Get(KubeConfigPathEnvVar, "")
  401. }
  402. // GetUTCOffset returns the environment variable value for UTCOffset
  403. func GetUTCOffset() string {
  404. return Get(UTCOffsetEnvVar, "")
  405. }
  406. // GetParsedUTCOffset returns the duration of the configured UTC offset
  407. func GetParsedUTCOffset() time.Duration {
  408. offset := time.Duration(0)
  409. if offsetStr := GetUTCOffset(); offsetStr != "" {
  410. match := offsetRegex.FindStringSubmatch(offsetStr)
  411. if match == nil {
  412. log.Warnf("Illegal UTC offset: %s", offsetStr)
  413. return offset
  414. }
  415. sig := 1
  416. if match[1] == "-" {
  417. sig = -1
  418. }
  419. hrs64, _ := strconv.ParseInt(match[2], 10, 64)
  420. hrs := sig * int(hrs64)
  421. mins64, _ := strconv.ParseInt(match[3], 10, 64)
  422. mins := sig * int(mins64)
  423. offset = time.Duration(hrs)*time.Hour + time.Duration(mins)
  424. }
  425. return offset
  426. }
  427. // GetKubecostJobName returns the environment variable value for KubecostJobNameEnvVar
  428. func GetKubecostJobName() string {
  429. return Get(KubecostJobNameEnvVar, "kubecost")
  430. }
  431. func IsCacheWarmingEnabled() bool {
  432. return GetBool(CacheWarmingEnabledEnvVar, true)
  433. }
  434. func IsETLEnabled() bool {
  435. return GetBool(ETLEnabledEnvVar, true)
  436. }
  437. func GetETLMaxPrometheusQueryDuration() time.Duration {
  438. dayMins := 60 * 24
  439. mins := time.Duration(GetInt64(ETLMaxPrometheusQueryDurationMinutes, int64(dayMins)))
  440. return mins * time.Minute
  441. }
  442. // GetETLResolution determines the resolution of ETL queries. The smaller the
  443. // duration, the higher the resolution; the higher the resolution, the more
  444. // accurate the query results, but the more computationally expensive.
  445. func GetETLResolution() time.Duration {
  446. // Use the configured ETL resolution, or default to
  447. // 5m (i.e. 300s)
  448. secs := time.Duration(GetInt64(ETLResolutionSeconds, 300))
  449. return secs * time.Second
  450. }
  451. func LegacyExternalCostsAPIDisabled() bool {
  452. return GetBool(LegacyExternalAPIDisabledVar, false)
  453. }
  454. // GetPromClusterLabel returns the environment variable value for PromClusterIDLabel
  455. func GetPromClusterLabel() string {
  456. return Get(PromClusterIDLabelEnvVar, "cluster_id")
  457. }
  458. // IsIngestingPodUID returns the env variable from ingestPodUID, which alters the
  459. // contents of podKeys in Allocation
  460. func IsIngestingPodUID() bool {
  461. return GetBool(IngestPodUIDEnvVar, false)
  462. }
  463. func GetAllocationNodeLabelsEnabled() bool {
  464. return GetBool(AllocationNodeLabelsEnabled, true)
  465. }
  466. var defaultAllocationNodeLabelsIncludeList []string = []string{
  467. "cloud.google.com/gke-nodepool",
  468. "eks.amazonaws.com/nodegroup",
  469. "kubernetes.azure.com/agentpool",
  470. "node.kubernetes.io/instance-type",
  471. "topology.kubernetes.io/region",
  472. "topology.kubernetes.io/zone",
  473. }
  474. func GetAllocationNodeLabelsIncludeList() []string {
  475. // If node labels are not enabled, return an empty list.
  476. if !GetAllocationNodeLabelsEnabled() {
  477. return []string{}
  478. }
  479. list := GetList(AllocationNodeLabelsIncludeList, ",")
  480. // If node labels are enabled, but the white list is empty, use defaults.
  481. if len(list) == 0 {
  482. return defaultAllocationNodeLabelsIncludeList
  483. }
  484. return list
  485. }
  486. func GetRegionOverrideList() []string {
  487. regionList := GetList(regionOverrideList, ",")
  488. if regionList == nil {
  489. return []string{}
  490. }
  491. return regionList
  492. }