cost-model/core/pkg/source/datasource.go

package source

import (
	"time"

	"github.com/julienschmidt/httprouter"
	"github.com/opencost/opencost/core/pkg/clusters"
	"github.com/opencost/opencost/core/pkg/diagnostics"
)

// Query name constants for use with MockMetricsQuerier.SetOverride.
const (
	// Local Cluster Disks
	QueryLocalStorageActiveMinutes = "QueryLocalStorageActiveMinutes"
	QueryLocalStorageUsedAvg       = "QueryLocalStorageUsedAvg"
	QueryLocalStorageUsedMax       = "QueryLocalStorageUsedMax"
	QueryLocalStorageBytes         = "QueryLocalStorageBytes"
	QueryKMLocalStorageUsedAvg     = "QueryKMLocalStorageUsedAvg"
	QueryKMLocalStorageUsedMax     = "QueryKMLocalStorageUsedMax"
	QueryKMLocalStorageBytes       = "QueryKMLocalStorageBytes"

	// Nodes
	QueryNodeInfo                 = "QueryNodeInfo"
	QueryNodeUptime               = "QueryNodeUptime"
	QueryNodeActiveMinutes        = "QueryNodeActiveMinutes"
	QueryNodeCPUCoresCapacity     = "QueryNodeCPUCoresCapacity"
	QueryNodeCPUCoresAllocatable  = "QueryNodeCPUCoresAllocatable"
	QueryNodeRAMBytesCapacity     = "QueryNodeRAMBytesCapacity"
	QueryNodeRAMBytesAllocatable  = "QueryNodeRAMBytesAllocatable"
	QueryNodeGPUCount             = "QueryNodeGPUCount"
	QueryNodeCPUModeTotal         = "QueryNodeCPUModeTotal"
	QueryNodeIsSpot               = "QueryNodeIsSpot"
	QueryNodeRAMSystemPercent     = "QueryNodeRAMSystemPercent"
	QueryNodeRAMUserPercent       = "QueryNodeRAMUserPercent"
	QueryNodeResourceCapacities   = "QueryNodeResourceCapacities"
	QueryNodeResourcesAllocatable = "QueryNodeResourcesAllocatable"

	// Load Balancers
	QueryLBActiveMinutes = "QueryLBActiveMinutes"
	QueryLBPricePerHr    = "QueryLBPricePerHr"

	// Cluster Management
	QueryClusterInfo                 = "QueryClusterInfo"
	QueryClusterKubeModelVersion     = "QueryClusterKubeModelVersion"
	QueryClusterUptime               = "QueryClusterUptime"
	QueryClusterManagementDuration   = "QueryClusterManagementDuration"
	QueryClusterManagementPricePerHr = "QueryClusterManagementPricePerHr"

	// Pods
	QueryPods                   = "QueryPods"
	QueryPodsUID                = "QueryPodsUID"
	QueryPodInfo                = "QueryPodInfo"
	QueryPodUptime              = "QueryPodUptime"
	QueryPodOwners              = "QueryPodOwners"
	QueryPodPVCVolumes          = "QueryPodPVCVolumes"
	QueryPodNetworkEgressBytes  = "QueryPodNetworkEgressBytes"
	QueryPodNetworkIngressBytes = "QueryPodNetworkIngressBytes"

	// Container
	QueryContainerUptime           = "QueryContainerUptime"
	QueryContainerResourceRequests = "QueryContainerResourceRequests"
	QueryContainerResourceLimits   = "QueryContainerResourceLimits"

	// RAM
	QueryRAMBytesAllocated    = "QueryRAMBytesAllocated"
	QueryRAMRequests          = "QueryRAMRequests"
	QueryRAMLimits            = "QueryRAMLimits"
	QueryRAMUsageAvg          = "QueryRAMUsageAvg"
	QueryRAMUsageMax          = "QueryRAMUsageMax"
	QueryNodeRAMPricePerGiBHr = "QueryNodeRAMPricePerGiBHr"

	// CPU
	QueryCPUCoresAllocated = "QueryCPUCoresAllocated"
	QueryCPURequests       = "QueryCPURequests"
	QueryCPULimits         = "QueryCPULimits"
	QueryCPUUsageAvg       = "QueryCPUUsageAvg"
	QueryCPUUsageMax       = "QueryCPUUsageMax"
	QueryNodeCPUPricePerHr = "QueryNodeCPUPricePerHr"

	// GPU
	QueryGPUsAllocated     = "QueryGPUsAllocated"
	QueryGPUsRequested     = "QueryGPUsRequested"
	QueryGPUsUsageAvg      = "QueryGPUsUsageAvg"
	QueryGPUsUsageMax      = "QueryGPUsUsageMax"
	QueryNodeGPUPricePerHr = "QueryNodeGPUPricePerHr"
	QueryGPUInfo           = "QueryGPUInfo"
	QueryIsGPUShared       = "QueryIsGPUShared"

	// Device
	QueryDCGMDeviceInfo        = "QueryDCGMDeviceInfo"
	QueryDCGMDeviceUptime      = "QueryDCGMDeviceUptime"
	QueryDCGMContainerUsageAvg = "QueryDCGMContainerUsageAvg"
	QueryDCGMContainerUsageMax = "QueryDCGMContainerUsageMax"

	// PVC
	QueryPodPVCAllocation    = "QueryPodPVCAllocation"
	QueryPVCBytesRequested   = "QueryPVCBytesRequested"
	QueryPVCInfo             = "QueryPVCInfo"
	QueryKMPVCInfo           = "QueryKMPVCInfo"
	QueryPVCUptime           = "QueryPVCUptime"
	QueryPVCBytesUsedAverage = "QueryPVCBytesUsedAverage"
	QueryPVCBytesUsedMax     = "QueryPVCBytesUsedMax"

	// PV
	QueryPVBytes           = "QueryPVBytes"
	QueryPVPricePerGiBHour = "QueryPVPricePerGiBHour"
	QueryPVInfo            = "QueryPVInfo"
	QueryPVActiveMinutes   = "QueryPVActiveMinutes"
	QueryPVUsedAverage     = "QueryPVUsedAverage"
	QueryPVUsedMax         = "QueryPVUsedMax"
	QueryKMPVInfo          = "QueryKMPVInfo"
	QueryPVUptime          = "QueryPVUptime"

	// Deployment
	QueryDeploymentInfo        = "QueryDeploymentInfo"
	QueryDeploymentUptime      = "QueryDeploymentUptime"
	QueryDeploymentLabels      = "QueryDeploymentLabels"
	QueryDeploymentAnnotations = "QueryDeploymentAnnotations"
	QueryDeploymentMatchLabels = "QueryDeploymentMatchLabels"

	// StatefulSet
	QueryStatefulSetInfo        = "QueryStatefulSetInfo"
	QueryStatefulSetUptime      = "QueryStatefulSetUptime"
	QueryStatefulSetLabels      = "QueryStatefulSetLabels"
	QueryStatefulSetAnnotations = "QueryStatefulSetAnnotations"
	QueryStatefulSetMatchLabels = "QueryStatefulSetMatchLabels"

	// DaemonSet
	QueryDaemonSetInfo        = "QueryDaemonSetInfo"
	QueryDaemonSetUptime      = "QueryDaemonSetUptime"
	QueryDaemonSetLabels      = "QueryDaemonSetLabels"
	QueryDaemonSetAnnotations = "QueryDaemonSetAnnotations"
	QueryDaemonSetArguments   = "QueryDaemonSetArguments"

	// Job
	QueryJobInfo        = "QueryJobInfo"
	QueryJobUptime      = "QueryJobUptime"
	QueryJobLabels      = "QueryJobLabels"
	QueryJobAnnotations = "QueryJobAnnotations"

	// CronJob
	QueryCronJobInfo        = "QueryCronJobInfo"
	QueryCronJobUptime      = "QueryCronJobUptime"
	QueryCronJobLabels      = "QueryCronJobLabels"
	QueryCronJobAnnotations = "QueryCronJobAnnotations"

	// ReplicaSet
	QueryReplicaSetInfo           = "QueryReplicaSetInfo"
	QueryReplicaSetUptime         = "QueryReplicaSetUptime"
	QueryReplicaSetLabels         = "QueryReplicaSetLabels"
	QueryReplicaSetAnnotations    = "QueryReplicaSetAnnotations"
	QueryReplicaSetOwners         = "QueryReplicaSetOwners"
	QueryPodsWithReplicaSetOwner  = "QueryPodsWithReplicaSetOwner"
	QueryReplicaSetsWithoutOwners = "QueryReplicaSetsWithoutOwners"
	QueryReplicaSetsWithRollout   = "QueryReplicaSetsWithRollout"

	// Namespace
	QueryNamespaceInfo        = "QueryNamespaceInfo"
	QueryNamespaceUptime      = "QueryNamespaceUptime"
	QueryNamespaceAnnotations = "QueryNamespaceAnnotations"
	QueryNamespaceLabels      = "QueryNamespaceLabels"

	// Service
	QueryServiceInfo           = "QueryServiceInfo"
	QueryServiceUptime         = "QueryServiceUptime"
	QueryServiceSelectorLabels = "QueryServiceSelectorLabels"

	// Network Egress
	QueryNetZoneGiB               = "QueryNetZoneGiB"
	QueryNetZonePricePerGiB       = "QueryNetZonePricePerGiB"
	QueryNetRegionGiB             = "QueryNetRegionGiB"
	QueryNetRegionPricePerGiB     = "QueryNetRegionPricePerGiB"
	QueryNetInternetGiB           = "QueryNetInternetGiB"
	QueryNetInternetPricePerGiB   = "QueryNetInternetPricePerGiB"
	QueryNetInternetServiceGiB    = "QueryNetInternetServiceGiB"
	QueryNetNatGatewayPricePerGiB = "QueryNetNatGatewayPricePerGiB"
	QueryNetNatGatewayGiB         = "QueryNetNatGatewayGiB"
	QueryNetTransferBytes         = "QueryNetTransferBytes"

	// Network Ingress
	QueryNetZoneIngressGiB               = "QueryNetZoneIngressGiB"
	QueryNetRegionIngressGiB             = "QueryNetRegionIngressGiB"
	QueryNetInternetIngressGiB           = "QueryNetInternetIngressGiB"
	QueryNetInternetServiceIngressGiB    = "QueryNetInternetServiceIngressGiB"
	QueryNetNatGatewayIngressPricePerGiB = "QueryNetNatGatewayIngressPricePerGiB"
	QueryNetNatGatewayIngressGiB         = "QueryNetNatGatewayIngressGiB"
	QueryNetReceiveBytes                 = "QueryNetReceiveBytes"

	// Labels
	QueryNodeLabels = "QueryNodeLabels"
	QueryPodLabels  = "QueryPodLabels"

	// Pod ownership
	QueryPodAnnotations         = "QueryPodAnnotations"
	QueryPodsWithDaemonSetOwner = "QueryPodsWithDaemonSetOwner"
	QueryPodsWithJobOwner       = "QueryPodsWithJobOwner"

	// ResourceQuotas
	QueryResourceQuotaInfo                        = "QueryResourceQuotaInfo"
	QueryResourceQuotaUptime                      = "QueryResourceQuotaUptime"
	QueryResourceQuotaSpecCPURequestAverage       = "QueryResourceQuotaSpecCPURequestAverage"
	QueryResourceQuotaSpecCPURequestMax           = "QueryResourceQuotaSpecCPURequestMax"
	QueryResourceQuotaSpecRAMRequestAverage       = "QueryResourceQuotaSpecRAMRequestAverage"
	QueryResourceQuotaSpecRAMRequestMax           = "QueryResourceQuotaSpecRAMRequestMax"
	QueryResourceQuotaSpecCPULimitAverage         = "QueryResourceQuotaSpecCPULimitAverage"
	QueryResourceQuotaSpecCPULimitMax             = "QueryResourceQuotaSpecCPULimitMax"
	QueryResourceQuotaSpecRAMLimitAverage         = "QueryResourceQuotaSpecRAMLimitAverage"
	QueryResourceQuotaSpecRAMLimitMax             = "QueryResourceQuotaSpecRAMLimitMax"
	QueryResourceQuotaStatusUsedCPURequestAverage = "QueryResourceQuotaStatusUsedCPURequestAverage"
	QueryResourceQuotaStatusUsedCPURequestMax     = "QueryResourceQuotaStatusUsedCPURequestMax"
	QueryResourceQuotaStatusUsedRAMRequestAverage = "QueryResourceQuotaStatusUsedRAMRequestAverage"
	QueryResourceQuotaStatusUsedRAMRequestMax     = "QueryResourceQuotaStatusUsedRAMRequestMax"
	QueryResourceQuotaStatusUsedCPULimitAverage   = "QueryResourceQuotaStatusUsedCPULimitAverage"
	QueryResourceQuotaStatusUsedCPULimitMax       = "QueryResourceQuotaStatusUsedCPULimitMax"
	QueryResourceQuotaStatusUsedRAMLimitAverage   = "QueryResourceQuotaStatusUsedRAMLimitAverage"
	QueryResourceQuotaStatusUsedRAMLimitMax       = "QueryResourceQuotaStatusUsedRAMLimitMax"

	// Data Coverage
	QueryDataCoverage = "QueryDataCoverage"

	// Inference Metrics
	QueryInferencePromptTokens         = "QueryInferencePromptTokens"
	QueryInferenceGenerationTokens     = "QueryInferenceGenerationTokens"
	QueryInferenceInputProcessingTime  = "QueryInferenceInputProcessingTime"
	QueryInferenceOutputProcessingTime = "QueryInferenceOutputProcessingTime"
	QueryInferenceCachedTokens         = "QueryInferenceCachedTokens"
	QueryInferenceCacheConfig          = "QueryInferenceCacheConfig"
)

type MetricsQuerier interface {
	// Cluster Disks

	// Local Cluster Disks
	QueryLocalStorageActiveMinutes(start, end time.Time) *Future[LocalStorageActiveMinutesResult]
	QueryLocalStorageUsedAvg(start, end time.Time) *Future[LocalStorageUsedAvgResult]
	QueryLocalStorageUsedMax(start, end time.Time) *Future[LocalStorageUsedMaxResult]
	QueryLocalStorageBytes(start, end time.Time) *Future[LocalStorageBytesResult]

	// Local Storage Metrics aggregated exclusively on NodeUID
	QueryKMLocalStorageUsedAvg(start, end time.Time) *Future[NodeUIDValueResult]
	QueryKMLocalStorageUsedMax(start, end time.Time) *Future[NodeUIDValueResult]
	QueryKMLocalStorageBytes(start, end time.Time) *Future[UIDValueResult]

	// Nodes
	QueryNodeInfo(start, end time.Time) *Future[NodeInfoResult]
	QueryNodeUptime(start, end time.Time) *Future[UptimeResult]
	QueryNodeActiveMinutes(start, end time.Time) *Future[NodeActiveMinutesResult]
	QueryNodeCPUCoresCapacity(start, end time.Time) *Future[NodeCPUCoresCapacityResult]
	QueryNodeCPUCoresAllocatable(start, end time.Time) *Future[NodeCPUCoresAllocatableResult]
	QueryNodeRAMBytesCapacity(start, end time.Time) *Future[NodeRAMBytesCapacityResult]
	QueryNodeRAMBytesAllocatable(start, end time.Time) *Future[NodeRAMBytesAllocatableResult]
	QueryNodeGPUCount(start, end time.Time) *Future[NodeGPUCountResult]
	QueryNodeCPUModeTotal(start, end time.Time) *Future[NodeCPUModeTotalResult]
	QueryNodeIsSpot(start, end time.Time) *Future[NodeIsSpotResult]
	QueryNodeRAMSystemPercent(start, end time.Time) *Future[NodeRAMSystemPercentResult]
	QueryNodeRAMUserPercent(start, end time.Time) *Future[NodeRAMUserPercentResult]
	QueryNodeResourceCapacities(start, end time.Time) *Future[ResourceResult]
	QueryNodeResourcesAllocatable(start, end time.Time) *Future[ResourceResult]

	// Load Balancers
	QueryLBActiveMinutes(start, end time.Time) *Future[LBActiveMinutesResult]
	QueryLBPricePerHr(start, end time.Time) *Future[LBPricePerHrResult]

	// Cluster Management
	QueryClusterInfo(start, end time.Time) *Future[ClusterInfoResult]
	QueryClusterKubeModelVersion(start, end time.Time) *Future[ClusterKubeModelVersionResult]
	QueryClusterUptime(start, end time.Time) *Future[UptimeResult]
	QueryClusterManagementDuration(start, end time.Time) *Future[ClusterManagementDurationResult]
	QueryClusterManagementPricePerHr(start, end time.Time) *Future[ClusterManagementPricePerHrResult]

	// Pods
	QueryPods(start, end time.Time) *Future[PodsResult]
	QueryPodsUID(start, end time.Time) *Future[PodsResult]
	QueryPodInfo(start, end time.Time) *Future[PodInfoResult]
	QueryPodUptime(start, end time.Time) *Future[UptimeResult]
	QueryPodOwners(start, end time.Time) *Future[OwnerResult]
	QueryPodPVCVolumes(start, end time.Time) *Future[PodPVCVolumeResult]
	QueryPodNetworkEgressBytes(start, end time.Time) *Future[PodNetworkBytesResult]
	QueryPodNetworkIngressBytes(start, end time.Time) *Future[PodNetworkBytesResult]

	// Container
	QueryContainerUptime(start, end time.Time) *Future[ContainerUptimeResult]
	QueryContainerResourceRequests(start, end time.Time) *Future[ContainerResourceResult]
	QueryContainerResourceLimits(start, end time.Time) *Future[ContainerResourceResult]

	// RAM
	QueryRAMBytesAllocated(start, end time.Time) *Future[RAMBytesAllocatedResult]
	QueryRAMRequests(start, end time.Time) *Future[RAMRequestsResult]
	QueryRAMLimits(start, end time.Time) *Future[RAMLimitsResult]
	QueryRAMUsageAvg(start, end time.Time) *Future[RAMUsageAvgResult]
	QueryRAMUsageMax(start, end time.Time) *Future[RAMUsageMaxResult]
	QueryNodeRAMPricePerGiBHr(start, end time.Time) *Future[NodeRAMPricePerGiBHrResult]

	// CPU
	QueryCPUCoresAllocated(start, end time.Time) *Future[CPUCoresAllocatedResult]
	QueryCPURequests(start, end time.Time) *Future[CPURequestsResult]
	QueryCPULimits(start, end time.Time) *Future[CPULimitsResult]
	QueryCPUUsageAvg(start, end time.Time) *Future[CPUUsageAvgResult]
	QueryCPUUsageMax(start, end time.Time) *Future[CPUUsageMaxResult]
	QueryNodeCPUPricePerHr(start, end time.Time) *Future[NodeCPUPricePerHrResult]

	// GPU
	QueryGPUsAllocated(start, end time.Time) *Future[GPUsAllocatedResult]
	QueryGPUsRequested(start, end time.Time) *Future[GPUsRequestedResult]
	QueryGPUsUsageAvg(start, end time.Time) *Future[GPUsUsageAvgResult]
	QueryGPUsUsageMax(start, end time.Time) *Future[GPUsUsageMaxResult]
	QueryNodeGPUPricePerHr(start, end time.Time) *Future[NodeGPUPricePerHrResult]
	QueryGPUInfo(start, end time.Time) *Future[GPUInfoResult]
	QueryIsGPUShared(start, end time.Time) *Future[IsGPUSharedResult]

	// Device
	QueryDCGMDeviceInfo(start, end time.Time) *Future[DCGMDeviceInfoResult]
	QueryDCGMDeviceUptime(start, end time.Time) *Future[DCGMDeviceUptimeResult]
	QueryDCGMContainerUsageAvg(start, end time.Time) *Future[DCGMDeviceContainerUsageResult]
	QueryDCGMContainerUsageMax(start, end time.Time) *Future[DCGMDeviceContainerUsageResult]

	// PVC
	QueryPodPVCAllocation(start, end time.Time) *Future[PodPVCAllocationResult]
	QueryPVCBytesRequested(start, end time.Time) *Future[PVCBytesRequestedResult]
	QueryPVCInfo(start, end time.Time) *Future[PVCInfoResult]
	// UID aggregated version of PVCInfo query
	QueryKMPVCInfo(start, end time.Time) *Future[PVCInfoResult]
	QueryPVCUptime(start, end time.Time) *Future[UptimeResult]
	QueryPVCBytesUsedAverage(start, end time.Time) *Future[PVCUIDValueResult]
	QueryPVCBytesUsedMax(start, end time.Time) *Future[PVCUIDValueResult]

	// PV
	QueryPVBytes(start, end time.Time) *Future[PVBytesResult]
	QueryPVPricePerGiBHour(start, end time.Time) *Future[PVPricePerGiBHourResult]
	QueryPVInfo(start, end time.Time) *Future[PVInfoResult]
	QueryPVActiveMinutes(start, end time.Time) *Future[PVActiveMinutesResult]
	QueryPVUsedAverage(start, end time.Time) *Future[PVUsedAvgResult]
	QueryPVUsedMax(start, end time.Time) *Future[PVUsedMaxResult]
	QueryKMPVInfo(start, end time.Time) *Future[PVInfoResult]
	QueryPVUptime(start, end time.Time) *Future[UptimeResult]

	// Deployment
	QueryDeploymentInfo(start, end time.Time) *Future[DeploymentInfoResult]
	QueryDeploymentUptime(start, end time.Time) *Future[UptimeResult]
	QueryDeploymentLabels(start, end time.Time) *Future[LabelsResult]
	QueryDeploymentAnnotations(start, end time.Time) *Future[AnnotationsResult]
	QueryDeploymentMatchLabels(start, end time.Time) *Future[DeploymentLabelsResult]

	// StatefulSet
	QueryStatefulSetInfo(start, end time.Time) *Future[StatefulSetInfoResult]
	QueryStatefulSetUptime(start, end time.Time) *Future[UptimeResult]
	QueryStatefulSetLabels(start, end time.Time) *Future[LabelsResult]
	QueryStatefulSetAnnotations(start, end time.Time) *Future[AnnotationsResult]
	QueryStatefulSetMatchLabels(start, end time.Time) *Future[StatefulSetLabelsResult]

	// DaemonSet
	QueryDaemonSetInfo(start, end time.Time) *Future[DaemonSetInfoResult]
	QueryDaemonSetUptime(start, end time.Time) *Future[UptimeResult]
	QueryDaemonSetLabels(start, end time.Time) *Future[LabelsResult]
	QueryDaemonSetAnnotations(start, end time.Time) *Future[AnnotationsResult]
	QueryDaemonSetArguments(start, end time.Time) *Future[DaemonSetArgumentResult]

	// Job
	QueryJobInfo(start, end time.Time) *Future[JobInfoResult]
	QueryJobUptime(start, end time.Time) *Future[UptimeResult]
	QueryJobLabels(start, end time.Time) *Future[LabelsResult]
	QueryJobAnnotations(start, end time.Time) *Future[AnnotationsResult]

	// CronJob
	QueryCronJobInfo(start, end time.Time) *Future[CronJobInfoResult]
	QueryCronJobUptime(start, end time.Time) *Future[UptimeResult]
	QueryCronJobLabels(start, end time.Time) *Future[LabelsResult]
	QueryCronJobAnnotations(start, end time.Time) *Future[AnnotationsResult]

	// ReplicaSet
	QueryReplicaSetInfo(start, end time.Time) *Future[ReplicaSetInfoResult]
	QueryReplicaSetUptime(start, end time.Time) *Future[UptimeResult]
	QueryReplicaSetLabels(start, end time.Time) *Future[LabelsResult]
	QueryReplicaSetAnnotations(start, end time.Time) *Future[AnnotationsResult]
	QueryReplicaSetOwners(start, end time.Time) *Future[OwnerResult]

	// Namespace
	QueryNamespaceInfo(start, end time.Time) *Future[NamespaceInfoResult]
	QueryNamespaceUptime(start, end time.Time) *Future[UptimeResult]

	// Service
	QueryServiceInfo(start, end time.Time) *Future[ServiceInfoResult]
	QueryServiceUptime(start, end time.Time) *Future[UptimeResult]
	QueryServiceSelectorLabels(start, end time.Time) *Future[ServiceLabelsResult]

	// Network Egress
	QueryNetZoneGiB(start, end time.Time) *Future[NetZoneGiBResult]
	QueryNetZonePricePerGiB(start, end time.Time) *Future[NetZonePricePerGiBResult]
	QueryNetRegionGiB(start, end time.Time) *Future[NetRegionGiBResult]
	QueryNetRegionPricePerGiB(start, end time.Time) *Future[NetRegionPricePerGiBResult]
	QueryNetInternetGiB(start, end time.Time) *Future[NetInternetGiBResult]
	QueryNetInternetPricePerGiB(start, end time.Time) *Future[NetInternetPricePerGiBResult]
	QueryNetInternetServiceGiB(start, end time.Time) *Future[NetInternetServiceGiBResult]
	QueryNetNatGatewayPricePerGiB(start, end time.Time) *Future[NetNatGatewayPricePerGiBResult]
	QueryNetNatGatewayGiB(start, end time.Time) *Future[NetNatGatewayGiBResult]
	QueryNetTransferBytes(start, end time.Time) *Future[NetTransferBytesResult]

	// Network Ingress
	QueryNetZoneIngressGiB(start, end time.Time) *Future[NetZoneIngressGiBResult]
	QueryNetRegionIngressGiB(start, end time.Time) *Future[NetRegionIngressGiBResult]
	QueryNetInternetIngressGiB(start, end time.Time) *Future[NetInternetIngressGiBResult]
	QueryNetInternetServiceIngressGiB(start, end time.Time) *Future[NetInternetServiceIngressGiBResult]
	QueryNetNatGatewayIngressPricePerGiB(start, end time.Time) *Future[NetNatGatewayPricePerGiBResult]
	QueryNetNatGatewayIngressGiB(start, end time.Time) *Future[NetNatGatewayIngressGiBResult]
	QueryNetReceiveBytes(start, end time.Time) *Future[NetReceiveBytesResult]

	// Annotations
	QueryNamespaceAnnotations(start, end time.Time) *Future[NamespaceAnnotationsResult]
	QueryPodAnnotations(start, end time.Time) *Future[PodAnnotationsResult]

	// Labels
	QueryNodeLabels(start, end time.Time) *Future[NodeLabelsResult]
	QueryNamespaceLabels(start, end time.Time) *Future[NamespaceLabelsResult]
	QueryPodLabels(start, end time.Time) *Future[PodLabelsResult]

	QueryPodsWithDaemonSetOwner(start, end time.Time) *Future[PodsWithDaemonSetOwnerResult]
	QueryPodsWithJobOwner(start, end time.Time) *Future[PodsWithJobOwnerResult]

	// ReplicaSet -> Controller mapping
	QueryPodsWithReplicaSetOwner(start, end time.Time) *Future[PodsWithReplicaSetOwnerResult]
	QueryReplicaSetsWithoutOwners(start, end time.Time) *Future[ReplicaSetsWithoutOwnersResult]
	QueryReplicaSetsWithRollout(start, end time.Time) *Future[ReplicaSetsWithRolloutResult]

	// ResourceQuotas
	QueryResourceQuotaInfo(start, end time.Time) *Future[ResourceQuotaInfoResult]
	QueryResourceQuotaUptime(start, end time.Time) *Future[UptimeResult]
	QueryResourceQuotaSpecCPURequestAverage(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaSpecCPURequestMax(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaSpecRAMRequestAverage(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaSpecRAMRequestMax(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaSpecCPULimitAverage(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaSpecCPULimitMax(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaSpecRAMLimitAverage(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaSpecRAMLimitMax(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaStatusUsedCPURequestAverage(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaStatusUsedCPURequestMax(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaStatusUsedRAMRequestAverage(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaStatusUsedRAMRequestMax(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaStatusUsedCPULimitAverage(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaStatusUsedCPULimitMax(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaStatusUsedRAMLimitAverage(start, end time.Time) *Future[ResourceResult]
	QueryResourceQuotaStatusUsedRAMLimitMax(start, end time.Time) *Future[ResourceResult]

	// Data Coverage Query
	QueryDataCoverage(limitDays int) (time.Time, time.Time, error)

	// Inference Metrics (vLLM) - relevant when INFERENCE_COST_ENABLED is set to true
	// QueryInferencePromptTokens returns prompt token counts by model_name and namespace
	QueryInferencePromptTokens(start, end time.Time) *Future[InferenceTokensResult]

	// QueryInferenceGenerationTokens returns generation token counts by model_name and namespace
	QueryInferenceGenerationTokens(start, end time.Time) *Future[InferenceTokensResult]

	// QueryInferenceInputProcessingTime returns input processing time in seconds by model_name and namespace
	QueryInferenceInputProcessingTime(start, end time.Time) *Future[InferenceProcessingTimeResult]

	// QueryInferenceOutputProcessingTime returns output processing time in seconds by model_name and namespace
	QueryInferenceOutputProcessingTime(start, end time.Time) *Future[InferenceProcessingTimeResult]

	// QueryInferenceCachedTokens returns KV cache hit counts by model_name and namespace
	QueryInferenceCachedTokens(start, end time.Time) *Future[InferenceTokensResult]

	// QueryInferenceCacheConfig returns cache configuration (prefix caching enabled) by model_name and namespace
	QueryInferenceCacheConfig(t time.Time) *Future[InferenceCacheConfigResult]
}

type OpenCostDataSource interface {
	// RegisterEndPoints registers any custom endpoints that can be used for diagnostics or debug purposes.
	RegisterEndPoints(router *httprouter.Router)

	// RegisterDiagnostics registers any custom data source diagnostics with the `DiagnosticService` that can
	// be used to report externally.
	RegisterDiagnostics(diagService diagnostics.DiagnosticService)

	// Metrics returns a MetricsQuerier that can be used to query historical metrics data from the data source.
	Metrics() MetricsQuerier

	// ClusterMap returns a mapping of cluster identifier to ClusterInfo for all known clusters (local only for
	// single cluster deployments).
	ClusterMap() clusters.ClusterMap

	// ClusterInfo returns the ClusterInfoProvider for the local cluster.
	ClusterInfo() clusters.ClusterInfoProvider

	BatchDuration() time.Duration
	Resolution() time.Duration
}