source

package
v1.121.0 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2026 License: Apache-2.0 Imports: 12 Imported by: 4

Documentation

Index

Constants

View Source 
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"

	// 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"
)

Query name constants for use with MockMetricsQuerier.SetOverride.

View Source 
const (
	ProviderLabel        = "provider"
	AccountIDLabel       = "account_id"
	ClusterNameLabel     = "cluster_name"
	RegionLabel          = "region"
	ClusterIDLabel       = "cluster_id"
	NamespaceLabel       = "namespace"
	NamespaceUIDLabel    = "namespace_uid"
	NodeLabel            = "node"
	NodeUIDLabel         = "node_uid"
	InstanceLabel        = "instance"
	InstanceTypeLabel    = "instance_type"
	ContainerLabel       = "container"
	PodLabel             = "pod"
	PodUIDLabel          = "pod_uid"
	PodNameLabel         = "pod_name"
	PodVolumeNameLabel   = "pod_volume_name"
	ProviderIDLabel      = "provider_id"
	DeviceLabel          = "device"
	PVCLabel             = "persistentvolumeclaim"
	PVCUIDLabel          = "persistentvolumeclaim_uid"
	PVLabel              = "persistentvolume"
	CSIVolumeHandleLabel = "csi_volume_handle"
	StorageClassLabel    = "storageclass"
	VolumeNameLabel      = "volumename"
	PVUIDLabel           = "persistentvolume_uid"
	ServiceLabel         = "service"
	ServiceNameLabel     = "service_name"
	ServiceTypeLabel     = "service_type"
	IngressIPLabel       = "ingress_ip"
	LBIngressAddress     = "lb_ingress_address"
	ProvisionerNameLabel = "provisioner_name"
	UIDLabel             = "uid"
	KubernetesNodeLabel  = "kubernetes_node"
	ModeLabel            = "mode"
	ModelNameLabel       = "modelName"
	HostNameLabel        = "Hostname"
	UUIDLabel            = "UUID"
	ResourceLabel        = "resource"
	DeploymentLabel      = "deployment"
	StatefulSetLabel     = "statefulSet"
	DaemonSetLabel       = "daemonset"
	JobLabel             = "job"
	CronJobLabel         = "cronjob"
	ReplicaSetLabel      = "replicaset"
	ResourceQuotaLabel   = "resourcequota"
	OwnerNameLabel       = "owner_name"
	OwnerKindLabel       = "owner_kind"
	OwnerUIDLabel        = "owner_uid"
	ControllerLabel      = "controller"
	UnitLabel            = "unit"
	InternetLabel        = "internet"
	SameZoneLabel        = "same_zone"
	SameRegionLabel      = "same_region"
	NatGatewayLabel      = "nat_gateway"
	KubeModelVersion     = "kubemodel_version"
)
View Source 
const NoStoreAPIWarning string = "No StoreAPIs matched for this query"

NoStoreAPIWarning is a warning that we would consider an error. It returns partial data relating only to the store apis which were reachable. In order to ensure integrity of data across all clusters, we'll need to identify this warning and convert it to an error.

View Source 
const (
	NoneLabelValue = "<none>"
)

Variables

This section is empty.

Functions

func AllErrorsFor 

func AllErrorsFor(collection QueryErrorCollection) []error

func DecodeAll 

func DecodeAll[T any](results []*QueryResult, decode ResultDecoder[T]) []*T

func IsCommError 

func IsCommError(err error) bool

IsCommError returns true if the given error is a CommError

func IsErrorCollection 

func IsErrorCollection(err error) bool

IsErrorCollection returns true if the provided error is an ErrorCollection

func IsNoDataError 

func IsNoDataError(err error) bool

IsNoDataError returns true if the given error is a NoDataError

func IsNoStoreAPIWarning 

func IsNoStoreAPIWarning(warning string) bool

IsNoStoreAPIWarning checks a warning to determine if it is equivalent to a no store API query.

func IsRetryable 

func IsRetryable(err error) bool

func NewHelpRetryError 

func NewHelpRetryError(cause error) error

func WrapError 

func WrapError(err error, msg string) error

WrapError wraps the given error with the given message, usually for adding context, but persists the existing type of error.

Types

type AnnotationsResult added in v1.121.0 

type AnnotationsResult struct {
	UID         string
	Cluster     string
	Annotations map[string]string
}

func DecodeAnnotationsResult added in v1.121.0 

func DecodeAnnotationsResult(result *QueryResult) *AnnotationsResult

type CPUCoresAllocatedResult 

type CPUCoresAllocatedResult = ContainerMetricResult

func DecodeCPUCoresAllocatedResult 

func DecodeCPUCoresAllocatedResult(result *QueryResult) *CPUCoresAllocatedResult

type CPULimitsResult added in v1.118.1 

type CPULimitsResult = ContainerMetricResult

func DecodeCPULimitsResult added in v1.118.1 

func DecodeCPULimitsResult(result *QueryResult) *CPULimitsResult

type CPURequestsResult 

type CPURequestsResult = ContainerMetricResult

func DecodeCPURequestsResult 

func DecodeCPURequestsResult(result *QueryResult) *CPURequestsResult

type CPUUsageAvgResult 

type CPUUsageAvgResult = ContainerMetricResult

func DecodeCPUUsageAvgResult 

func DecodeCPUUsageAvgResult(result *QueryResult) *CPUUsageAvgResult

type CPUUsageMaxResult 

type CPUUsageMaxResult = ContainerMetricResult

func DecodeCPUUsageMaxResult 

func DecodeCPUUsageMaxResult(result *QueryResult) *CPUUsageMaxResult

type ClusterInfoResult added in v1.121.0 

type ClusterInfoResult struct {
	UID         string
	Cluster     string
	Provider    string
	AccountID   string
	Provisioner string
	Region      string
}

func DecodeClusterInfoResult added in v1.121.0 

func DecodeClusterInfoResult(result *QueryResult) *ClusterInfoResult

type ClusterKubeModelVersionResult added in v1.121.0 

type ClusterKubeModelVersionResult struct {
	UID     string
	Version string
}

func DecodeClusterKubeModelVersionResult added in v1.121.0 

func DecodeClusterKubeModelVersionResult(result *QueryResult) *ClusterKubeModelVersionResult

type ClusterManagementDurationResult 

type ClusterManagementDurationResult struct {
	UID         string
	Cluster     string
	Provisioner string
	Data        []*util.Vector
}

func DecodeClusterManagementDurationResult 

func DecodeClusterManagementDurationResult(result *QueryResult) *ClusterManagementDurationResult

type ClusterManagementPricePerHrResult 

type ClusterManagementPricePerHrResult = ClusterManagementDurationResult

func DecodeClusterManagementPricePerHrResult 

func DecodeClusterManagementPricePerHrResult(result *QueryResult) *ClusterManagementPricePerHrResult

type CommError 

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

CommError describes an error communicating with Prometheus

func CommErrorf 

func CommErrorf(format string, args ...interface{}) CommError

CommErrorf creates a new CommError using a string formatter

func NewCommError 

func NewCommError(messages ...string) CommError

NewCommError creates a new CommError

func (CommError) Error 

func (pce CommError) Error() string

Error prints the error as a string

func (CommError) Wrap 

func (pce CommError) Wrap(message string) CommError

Wrap wraps the error with the given message, but persists the error type.

type ContainerMetricResult 

type ContainerMetricResult struct {
	UID       string
	Cluster   string
	Node      string
	Instance  string
	Namespace string
	Pod       string
	Container string

	Data []*util.Vector
}

func DecodeContainerMetricResult 

func DecodeContainerMetricResult(result *QueryResult) *ContainerMetricResult

type ContainerResourceResult added in v1.121.0 

type ContainerResourceResult struct {
	ResourceResult
	Container string
}

func DecodeContainerResourceResult added in v1.121.0 

func DecodeContainerResourceResult(result *QueryResult) *ContainerResourceResult

type ContainerUptimeResult added in v1.121.0 

type ContainerUptimeResult struct {
	UptimeResult
	Container string
}

func DecodeContainerUptimeResult added in v1.121.0 

func DecodeContainerUptimeResult(result *QueryResult) *ContainerUptimeResult

type CronJobInfoResult added in v1.121.0 

type CronJobInfoResult struct {
	UID          string
	Cluster      string
	NamespaceUID string
	CronJob      string
}

func DecodeCronJobInfoResult added in v1.121.0 

func DecodeCronJobInfoResult(result *QueryResult) *CronJobInfoResult

type DCGMDeviceContainerUsageResult added in v1.121.0 

type DCGMDeviceContainerUsageResult struct {
	UUID      string
	PodUID    string
	Container string
	Value     float64
}

func DecodeDCGMDeviceContainerUsageResult added in v1.121.0 

func DecodeDCGMDeviceContainerUsageResult(result *QueryResult) *DCGMDeviceContainerUsageResult

type DCGMDeviceInfoResult added in v1.121.0 

type DCGMDeviceInfoResult struct {
	UUID      string
	Device    string
	ModelName string
	HostName  string
}

DCGM needs specialized results because it uses UUID instead of the uid label that we use.

func DecodeDCGMDeviceInfoResult added in v1.121.0 

func DecodeDCGMDeviceInfoResult(result *QueryResult) *DCGMDeviceInfoResult

type DCGMDeviceUptimeResult added in v1.121.0 

type DCGMDeviceUptimeResult struct {
	UUID  string
	First time.Time
	Last  time.Time
}

func DecodeDCGMDeviceUptimeResult added in v1.121.0 

func DecodeDCGMDeviceUptimeResult(result *QueryResult) *DCGMDeviceUptimeResult

func (*DCGMDeviceUptimeResult) GetStartEnd added in v1.121.0 

func (res *DCGMDeviceUptimeResult) GetStartEnd(windowStart, windowEnd time.Time, resolution time.Duration) (time.Time, time.Time)

type DaemonSetInfoResult added in v1.121.0 

type DaemonSetInfoResult struct {
	UID          string
	Cluster      string
	NamespaceUID string
	DaemonSet    string
}

func DecodeDaemonSetInfoResult added in v1.121.0 

func DecodeDaemonSetInfoResult(result *QueryResult) *DaemonSetInfoResult

type DeploymentInfoResult added in v1.121.0 

type DeploymentInfoResult struct {
	UID          string
	Cluster      string
	NamespaceUID string
	Deployment   string
}

func DecodeDeploymentInfoResult added in v1.121.0 

func DecodeDeploymentInfoResult(result *QueryResult) *DeploymentInfoResult

type DeploymentLabelsResult 

type DeploymentLabelsResult struct {
	UID        string
	Cluster    string
	Namespace  string
	Deployment string
	Labels     map[string]string
	Data       []*util.Vector
}

func DecodeDeploymentLabelsResult 

func DecodeDeploymentLabelsResult(result *QueryResult) *DeploymentLabelsResult

type ErrorsAndWarningStrings 

type ErrorsAndWarningStrings struct {
	Errors   []string
	Warnings []string
}

ErrorsAndWarningStrings is a container struct for string representation storage/caching

type Future 

type Future[T any] struct {
	// contains filtered or unexported fields
}

Future[T] is a async future/promise/task that will resolve into a []*T return or error when awaited. This type provides a type-safe way of interfacing with `QueryResultsChan` via a `ResultDecoder[T]` function.

func NewFuture 

func NewFuture[T any](decoder ResultDecoder[T], resultsChan QueryResultsChan) *Future[T]

NewFuture Creates a new `Future[T]` with the given `ResultDecoder[T]` and `QueryResultsChan`.

func NewFutureFrom 

func NewFutureFrom[T any](results []*T) *Future[T]

NewFutureFrom accepts a result set to wrap in the a Future implementation for passthrough.

func (*Future[T]) Await 

func (f *Future[T]) Await() ([]*T, error)

Await blocks and waits for the `Future` to resolve, and returns the results if successful, or an error otherwise.

type GPUInfoResult 

type GPUInfoResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	Container string
	Device    string
	ModelName string
	UUID      string
	Data      []*util.Vector
}

func DecodeGPUInfoResult 

func DecodeGPUInfoResult(result *QueryResult) *GPUInfoResult

type GPUsAllocatedResult 

type GPUsAllocatedResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	Container string
	Data      []*util.Vector
}

func DecodeGPUsAllocatedResult 

func DecodeGPUsAllocatedResult(result *QueryResult) *GPUsAllocatedResult

type GPUsRequestedResult 

type GPUsRequestedResult = GPUsAllocatedResult

type alias requested result to allocated result, as you can only request a full GPU

func DecodeGPUsRequestedResult 

func DecodeGPUsRequestedResult(result *QueryResult) *GPUsRequestedResult

type GPUsUsageAvgResult 

type GPUsUsageAvgResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	Container string

	Data []*util.Vector
}

func DecodeGPUsUsageAvgResult 

func DecodeGPUsUsageAvgResult(result *QueryResult) *GPUsUsageAvgResult

type GPUsUsageMaxResult 

type GPUsUsageMaxResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	Container string
	Data      []*util.Vector
}

func DecodeGPUsUsageMaxResult 

func DecodeGPUsUsageMaxResult(result *QueryResult) *GPUsUsageMaxResult

type HelpRetryError 

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

HelpRetryError is a wrapper error type which indicates an error should induce a retry, and is non-fatal

func (*HelpRetryError) Error 

func (h *HelpRetryError) Error() string

func (*HelpRetryError) Unwrap 

func (h *HelpRetryError) Unwrap() error

type InferenceCacheConfig added in v1.121.0 

type InferenceCacheConfig struct {
	PrefixCachingEnabled bool
}

InferenceCacheConfig holds cache configuration for a model.

type InferenceCacheConfigResult added in v1.121.0 

type InferenceCacheConfigResult struct {
	// Configs maps "model_name:namespace" to cache configuration
	Configs map[string]*InferenceCacheConfig
}

InferenceCacheConfigResult represents cache configuration.

func DecodeInferenceCacheConfigResult added in v1.121.0 

func DecodeInferenceCacheConfigResult(result *QueryResult) *InferenceCacheConfigResult

type InferenceProcessingTimeResult added in v1.121.0 

type InferenceProcessingTimeResult struct {
	// Values maps "model_name:namespace" to processing time in seconds
	Values map[string]float64
}

InferenceProcessingTimeResult represents processing time in seconds. Used for input processing time and output processing time.

func DecodeInferenceProcessingTimeResult added in v1.121.0 

func DecodeInferenceProcessingTimeResult(result *QueryResult) *InferenceProcessingTimeResult

type InferenceTokensResult added in v1.121.0 

type InferenceTokensResult struct {
	// Values maps "model_name:namespace" to token count
	Values map[string]float64
}

InferenceTokensResult represents token counts. Used for prompt tokens, generation tokens, and cached tokens.

func DecodeInferenceTokensResult added in v1.121.0 

func DecodeInferenceTokensResult(result *QueryResult) *InferenceTokensResult

type IsGPUSharedResult 

type IsGPUSharedResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	Container string
	Resource  string
	Data      []*util.Vector
}

func DecodeIsGPUSharedResult 

func DecodeIsGPUSharedResult(result *QueryResult) *IsGPUSharedResult

type JobInfoResult added in v1.121.0 

type JobInfoResult struct {
	UID          string
	Cluster      string
	NamespaceUID string
	Job          string
}

func DecodeJobInfoResult added in v1.121.0 

func DecodeJobInfoResult(result *QueryResult) *JobInfoResult

type LBActiveMinutesResult 

type LBActiveMinutesResult struct {
	UID       string
	Cluster   string
	Namespace string
	Service   string
	IngressIP string

	Data []*util.Vector
}

func DecodeLBActiveMinutesResult 

func DecodeLBActiveMinutesResult(result *QueryResult) *LBActiveMinutesResult

type LBPricePerHrResult 

type LBPricePerHrResult = LBActiveMinutesResult

func DecodeLBPricePerHrResult 

func DecodeLBPricePerHrResult(result *QueryResult) *LBPricePerHrResult

type LabelsResult added in v1.121.0 

type LabelsResult struct {
	UID     string
	Cluster string
	Labels  map[string]string
}

func DecodeLabelsResult added in v1.121.0 

func DecodeLabelsResult(result *QueryResult) *LabelsResult

type LocalStorageActiveMinutesResult 

type LocalStorageActiveMinutesResult struct {
	Cluster    string
	Node       string
	ProviderID string

	Data []*util.Vector
}

func DecodeLocalStorageActiveMinutesResult 

func DecodeLocalStorageActiveMinutesResult(result *QueryResult) *LocalStorageActiveMinutesResult

type LocalStorageBytesResult 

type LocalStorageBytesResult struct {
	UID      string
	Cluster  string
	Instance string
	Device   string
	Data     []*util.Vector
}

func DecodeLocalStorageBytesResult 

func DecodeLocalStorageBytesResult(result *QueryResult) *LocalStorageBytesResult

type LocalStorageCostResult 

type LocalStorageCostResult struct {
	UID      string
	Cluster  string
	Instance string
	Device   string

	Data []*util.Vector
}

func DecodeLocalStorageCostResult 

func DecodeLocalStorageCostResult(result *QueryResult) *LocalStorageCostResult

type LocalStorageUsedAvgResult 

type LocalStorageUsedAvgResult struct {
	UID      string
	Cluster  string
	Instance string
	Device   string
	Data     []*util.Vector
}

func DecodeLocalStorageUsedAvgResult 

func DecodeLocalStorageUsedAvgResult(result *QueryResult) *LocalStorageUsedAvgResult

type LocalStorageUsedCostResult 

type LocalStorageUsedCostResult struct {
	UID      string
	Cluster  string
	Instance string
	Device   string
	Data     []*util.Vector
}

func DecodeLocalStorageUsedCostResult 

func DecodeLocalStorageUsedCostResult(result *QueryResult) *LocalStorageUsedCostResult

type LocalStorageUsedMaxResult 

type LocalStorageUsedMaxResult struct {
	UID      string
	Cluster  string
	Instance string
	Device   string
	Data     []*util.Vector
}

func DecodeLocalStorageUsedMaxResult 

func DecodeLocalStorageUsedMaxResult(result *QueryResult) *LocalStorageUsedMaxResult

type MetricsQuerier 

type MetricsQuerier interface {

	// 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]

	// 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 MockMetricsQuerier added in v1.121.0 

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

MockMetricsQuerier is a test double for MetricsQuerier. Set a field to a non-nil *Future[T] to override what a specific method returns; unset methods fall back to NoOpMetricsQuerier (empty results, no error).

func NewMockMetricsQuerier added in v1.121.0 

func NewMockMetricsQuerier() *MockMetricsQuerier

func (*MockMetricsQuerier) QueryCPUCoresAllocated added in v1.121.0 

func (m *MockMetricsQuerier) QueryCPUCoresAllocated(start, end time.Time) *Future[CPUCoresAllocatedResult]

func (*MockMetricsQuerier) QueryCPULimits added in v1.121.0 

func (m *MockMetricsQuerier) QueryCPULimits(start, end time.Time) *Future[CPULimitsResult]

func (*MockMetricsQuerier) QueryCPURequests added in v1.121.0 

func (m *MockMetricsQuerier) QueryCPURequests(start, end time.Time) *Future[CPURequestsResult]

func (*MockMetricsQuerier) QueryCPUUsageAvg added in v1.121.0 

func (m *MockMetricsQuerier) QueryCPUUsageAvg(start, end time.Time) *Future[CPUUsageAvgResult]

func (*MockMetricsQuerier) QueryCPUUsageMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryCPUUsageMax(start, end time.Time) *Future[CPUUsageMaxResult]

func (*MockMetricsQuerier) QueryClusterInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryClusterInfo(start, end time.Time) *Future[ClusterInfoResult]

func (*MockMetricsQuerier) QueryClusterKubeModelVersion added in v1.121.0 

func (m *MockMetricsQuerier) QueryClusterKubeModelVersion(start, end time.Time) *Future[ClusterKubeModelVersionResult]

func (*MockMetricsQuerier) QueryClusterManagementDuration added in v1.121.0 

func (m *MockMetricsQuerier) QueryClusterManagementDuration(start, end time.Time) *Future[ClusterManagementDurationResult]

func (*MockMetricsQuerier) QueryClusterManagementPricePerHr added in v1.121.0 

func (m *MockMetricsQuerier) QueryClusterManagementPricePerHr(start, end time.Time) *Future[ClusterManagementPricePerHrResult]

func (*MockMetricsQuerier) QueryClusterUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryClusterUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryContainerResourceLimits added in v1.121.0 

func (m *MockMetricsQuerier) QueryContainerResourceLimits(start, end time.Time) *Future[ContainerResourceResult]

func (*MockMetricsQuerier) QueryContainerResourceRequests added in v1.121.0 

func (m *MockMetricsQuerier) QueryContainerResourceRequests(start, end time.Time) *Future[ContainerResourceResult]

func (*MockMetricsQuerier) QueryContainerUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryContainerUptime(start, end time.Time) *Future[ContainerUptimeResult]

func (*MockMetricsQuerier) QueryCronJobAnnotations added in v1.121.0 

func (m *MockMetricsQuerier) QueryCronJobAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*MockMetricsQuerier) QueryCronJobInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryCronJobInfo(start, end time.Time) *Future[CronJobInfoResult]

func (*MockMetricsQuerier) QueryCronJobLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryCronJobLabels(start, end time.Time) *Future[LabelsResult]

func (*MockMetricsQuerier) QueryCronJobUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryCronJobUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryDCGMContainerUsageAvg added in v1.121.0 

func (m *MockMetricsQuerier) QueryDCGMContainerUsageAvg(start, end time.Time) *Future[DCGMDeviceContainerUsageResult]

func (*MockMetricsQuerier) QueryDCGMContainerUsageMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryDCGMContainerUsageMax(start, end time.Time) *Future[DCGMDeviceContainerUsageResult]

func (*MockMetricsQuerier) QueryDCGMDeviceInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryDCGMDeviceInfo(start, end time.Time) *Future[DCGMDeviceInfoResult]

func (*MockMetricsQuerier) QueryDCGMDeviceUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryDCGMDeviceUptime(start, end time.Time) *Future[DCGMDeviceUptimeResult]

func (*MockMetricsQuerier) QueryDaemonSetAnnotations added in v1.121.0 

func (m *MockMetricsQuerier) QueryDaemonSetAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*MockMetricsQuerier) QueryDaemonSetInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryDaemonSetInfo(start, end time.Time) *Future[DaemonSetInfoResult]

func (*MockMetricsQuerier) QueryDaemonSetLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryDaemonSetLabels(start, end time.Time) *Future[LabelsResult]

func (*MockMetricsQuerier) QueryDaemonSetUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryDaemonSetUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryDataCoverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryDataCoverage(limitDays int) (time.Time, time.Time, error)

func (*MockMetricsQuerier) QueryDeploymentAnnotations added in v1.121.0 

func (m *MockMetricsQuerier) QueryDeploymentAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*MockMetricsQuerier) QueryDeploymentInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryDeploymentInfo(start, end time.Time) *Future[DeploymentInfoResult]

func (*MockMetricsQuerier) QueryDeploymentLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryDeploymentLabels(start, end time.Time) *Future[LabelsResult]

func (*MockMetricsQuerier) QueryDeploymentMatchLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryDeploymentMatchLabels(start, end time.Time) *Future[DeploymentLabelsResult]

func (*MockMetricsQuerier) QueryDeploymentUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryDeploymentUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryGPUInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryGPUInfo(start, end time.Time) *Future[GPUInfoResult]

func (*MockMetricsQuerier) QueryGPUsAllocated added in v1.121.0 

func (m *MockMetricsQuerier) QueryGPUsAllocated(start, end time.Time) *Future[GPUsAllocatedResult]

func (*MockMetricsQuerier) QueryGPUsRequested added in v1.121.0 

func (m *MockMetricsQuerier) QueryGPUsRequested(start, end time.Time) *Future[GPUsRequestedResult]

func (*MockMetricsQuerier) QueryGPUsUsageAvg added in v1.121.0 

func (m *MockMetricsQuerier) QueryGPUsUsageAvg(start, end time.Time) *Future[GPUsUsageAvgResult]

func (*MockMetricsQuerier) QueryGPUsUsageMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryGPUsUsageMax(start, end time.Time) *Future[GPUsUsageMaxResult]

func (*MockMetricsQuerier) QueryInferenceCacheConfig added in v1.121.0 

func (m *MockMetricsQuerier) QueryInferenceCacheConfig(t time.Time) *Future[InferenceCacheConfigResult]

func (*MockMetricsQuerier) QueryInferenceCachedTokens added in v1.121.0 

func (m *MockMetricsQuerier) QueryInferenceCachedTokens(start, end time.Time) *Future[InferenceTokensResult]

func (*MockMetricsQuerier) QueryInferenceGenerationTokens added in v1.121.0 

func (m *MockMetricsQuerier) QueryInferenceGenerationTokens(start, end time.Time) *Future[InferenceTokensResult]

func (*MockMetricsQuerier) QueryInferenceInputProcessingTime added in v1.121.0 

func (m *MockMetricsQuerier) QueryInferenceInputProcessingTime(start, end time.Time) *Future[InferenceProcessingTimeResult]

func (*MockMetricsQuerier) QueryInferenceOutputProcessingTime added in v1.121.0 

func (m *MockMetricsQuerier) QueryInferenceOutputProcessingTime(start, end time.Time) *Future[InferenceProcessingTimeResult]

func (*MockMetricsQuerier) QueryInferencePromptTokens added in v1.121.0 

func (m *MockMetricsQuerier) QueryInferencePromptTokens(start, end time.Time) *Future[InferenceTokensResult]

func (*MockMetricsQuerier) QueryIsGPUShared added in v1.121.0 

func (m *MockMetricsQuerier) QueryIsGPUShared(start, end time.Time) *Future[IsGPUSharedResult]

func (*MockMetricsQuerier) QueryJobAnnotations added in v1.121.0 

func (m *MockMetricsQuerier) QueryJobAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*MockMetricsQuerier) QueryJobInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryJobInfo(start, end time.Time) *Future[JobInfoResult]

func (*MockMetricsQuerier) QueryJobLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryJobLabels(start, end time.Time) *Future[LabelsResult]

func (*MockMetricsQuerier) QueryJobUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryJobUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryKMLocalStorageBytes added in v1.121.0 

func (m *MockMetricsQuerier) QueryKMLocalStorageBytes(start, end time.Time) *Future[UIDValueResult]

func (*MockMetricsQuerier) QueryKMLocalStorageUsedAvg added in v1.121.0 

func (m *MockMetricsQuerier) QueryKMLocalStorageUsedAvg(start, end time.Time) *Future[NodeUIDValueResult]

func (*MockMetricsQuerier) QueryKMLocalStorageUsedMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryKMLocalStorageUsedMax(start, end time.Time) *Future[NodeUIDValueResult]

func (*MockMetricsQuerier) QueryKMPVCInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryKMPVCInfo(start, end time.Time) *Future[PVCInfoResult]

func (*MockMetricsQuerier) QueryKMPVInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryKMPVInfo(start, end time.Time) *Future[PVInfoResult]

func (*MockMetricsQuerier) QueryLBActiveMinutes added in v1.121.0 

func (m *MockMetricsQuerier) QueryLBActiveMinutes(start, end time.Time) *Future[LBActiveMinutesResult]

func (*MockMetricsQuerier) QueryLBPricePerHr added in v1.121.0 

func (m *MockMetricsQuerier) QueryLBPricePerHr(start, end time.Time) *Future[LBPricePerHrResult]

func (*MockMetricsQuerier) QueryLocalStorageActiveMinutes added in v1.121.0 

func (m *MockMetricsQuerier) QueryLocalStorageActiveMinutes(start, end time.Time) *Future[LocalStorageActiveMinutesResult]

func (*MockMetricsQuerier) QueryLocalStorageBytes added in v1.121.0 

func (m *MockMetricsQuerier) QueryLocalStorageBytes(start, end time.Time) *Future[LocalStorageBytesResult]

func (*MockMetricsQuerier) QueryLocalStorageUsedAvg added in v1.121.0 

func (m *MockMetricsQuerier) QueryLocalStorageUsedAvg(start, end time.Time) *Future[LocalStorageUsedAvgResult]

func (*MockMetricsQuerier) QueryLocalStorageUsedMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryLocalStorageUsedMax(start, end time.Time) *Future[LocalStorageUsedMaxResult]

func (*MockMetricsQuerier) QueryNamespaceAnnotations added in v1.121.0 

func (m *MockMetricsQuerier) QueryNamespaceAnnotations(start, end time.Time) *Future[NamespaceAnnotationsResult]

func (*MockMetricsQuerier) QueryNamespaceInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryNamespaceInfo(start, end time.Time) *Future[NamespaceInfoResult]

func (*MockMetricsQuerier) QueryNamespaceLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryNamespaceLabels(start, end time.Time) *Future[NamespaceLabelsResult]

func (*MockMetricsQuerier) QueryNamespaceUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryNamespaceUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryNetInternetGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetInternetGiB(start, end time.Time) *Future[NetInternetGiBResult]

func (*MockMetricsQuerier) QueryNetInternetIngressGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetInternetIngressGiB(start, end time.Time) *Future[NetInternetIngressGiBResult]

func (*MockMetricsQuerier) QueryNetInternetPricePerGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetInternetPricePerGiB(start, end time.Time) *Future[NetInternetPricePerGiBResult]

func (*MockMetricsQuerier) QueryNetInternetServiceGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetInternetServiceGiB(start, end time.Time) *Future[NetInternetServiceGiBResult]

func (*MockMetricsQuerier) QueryNetInternetServiceIngressGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetInternetServiceIngressGiB(start, end time.Time) *Future[NetInternetServiceIngressGiBResult]

func (*MockMetricsQuerier) QueryNetNatGatewayGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetNatGatewayGiB(start, end time.Time) *Future[NetNatGatewayGiBResult]

func (*MockMetricsQuerier) QueryNetNatGatewayIngressGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetNatGatewayIngressGiB(start, end time.Time) *Future[NetNatGatewayIngressGiBResult]

func (*MockMetricsQuerier) QueryNetNatGatewayIngressPricePerGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetNatGatewayIngressPricePerGiB(start, end time.Time) *Future[NetNatGatewayPricePerGiBResult]

func (*MockMetricsQuerier) QueryNetNatGatewayPricePerGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetNatGatewayPricePerGiB(start, end time.Time) *Future[NetNatGatewayPricePerGiBResult]

func (*MockMetricsQuerier) QueryNetReceiveBytes added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetReceiveBytes(start, end time.Time) *Future[NetReceiveBytesResult]

func (*MockMetricsQuerier) QueryNetRegionGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetRegionGiB(start, end time.Time) *Future[NetRegionGiBResult]

func (*MockMetricsQuerier) QueryNetRegionIngressGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetRegionIngressGiB(start, end time.Time) *Future[NetRegionIngressGiBResult]

func (*MockMetricsQuerier) QueryNetRegionPricePerGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetRegionPricePerGiB(start, end time.Time) *Future[NetRegionPricePerGiBResult]

func (*MockMetricsQuerier) QueryNetTransferBytes added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetTransferBytes(start, end time.Time) *Future[NetTransferBytesResult]

func (*MockMetricsQuerier) QueryNetZoneGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetZoneGiB(start, end time.Time) *Future[NetZoneGiBResult]

func (*MockMetricsQuerier) QueryNetZoneIngressGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetZoneIngressGiB(start, end time.Time) *Future[NetZoneIngressGiBResult]

func (*MockMetricsQuerier) QueryNetZonePricePerGiB added in v1.121.0 

func (m *MockMetricsQuerier) QueryNetZonePricePerGiB(start, end time.Time) *Future[NetZonePricePerGiBResult]

func (*MockMetricsQuerier) QueryNodeActiveMinutes added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeActiveMinutes(start, end time.Time) *Future[NodeActiveMinutesResult]

func (*MockMetricsQuerier) QueryNodeCPUCoresAllocatable added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeCPUCoresAllocatable(start, end time.Time) *Future[NodeCPUCoresAllocatableResult]

func (*MockMetricsQuerier) QueryNodeCPUCoresCapacity added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeCPUCoresCapacity(start, end time.Time) *Future[NodeCPUCoresCapacityResult]

func (*MockMetricsQuerier) QueryNodeCPUModeTotal added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeCPUModeTotal(start, end time.Time) *Future[NodeCPUModeTotalResult]

func (*MockMetricsQuerier) QueryNodeCPUPricePerHr added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeCPUPricePerHr(start, end time.Time) *Future[NodeCPUPricePerHrResult]

func (*MockMetricsQuerier) QueryNodeGPUCount added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeGPUCount(start, end time.Time) *Future[NodeGPUCountResult]

func (*MockMetricsQuerier) QueryNodeGPUPricePerHr added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeGPUPricePerHr(start, end time.Time) *Future[NodeGPUPricePerHrResult]

func (*MockMetricsQuerier) QueryNodeInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeInfo(start, end time.Time) *Future[NodeInfoResult]

func (*MockMetricsQuerier) QueryNodeIsSpot added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeIsSpot(start, end time.Time) *Future[NodeIsSpotResult]

func (*MockMetricsQuerier) QueryNodeLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeLabels(start, end time.Time) *Future[NodeLabelsResult]

func (*MockMetricsQuerier) QueryNodeRAMBytesAllocatable added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeRAMBytesAllocatable(start, end time.Time) *Future[NodeRAMBytesAllocatableResult]

func (*MockMetricsQuerier) QueryNodeRAMBytesCapacity added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeRAMBytesCapacity(start, end time.Time) *Future[NodeRAMBytesCapacityResult]

func (*MockMetricsQuerier) QueryNodeRAMPricePerGiBHr added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeRAMPricePerGiBHr(start, end time.Time) *Future[NodeRAMPricePerGiBHrResult]

func (*MockMetricsQuerier) QueryNodeRAMSystemPercent added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeRAMSystemPercent(start, end time.Time) *Future[NodeRAMSystemPercentResult]

func (*MockMetricsQuerier) QueryNodeRAMUserPercent added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeRAMUserPercent(start, end time.Time) *Future[NodeRAMUserPercentResult]

func (*MockMetricsQuerier) QueryNodeResourceCapacities added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeResourceCapacities(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryNodeResourcesAllocatable added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeResourcesAllocatable(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryNodeUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryNodeUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryPVActiveMinutes added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVActiveMinutes(start, end time.Time) *Future[PVActiveMinutesResult]

func (*MockMetricsQuerier) QueryPVBytes added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVBytes(start, end time.Time) *Future[PVBytesResult]

func (*MockMetricsQuerier) QueryPVCBytesRequested added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVCBytesRequested(start, end time.Time) *Future[PVCBytesRequestedResult]

func (*MockMetricsQuerier) QueryPVCBytesUsedAverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVCBytesUsedAverage(start, end time.Time) *Future[PVCUIDValueResult]

func (*MockMetricsQuerier) QueryPVCBytesUsedMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVCBytesUsedMax(start, end time.Time) *Future[PVCUIDValueResult]

func (*MockMetricsQuerier) QueryPVCInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVCInfo(start, end time.Time) *Future[PVCInfoResult]

func (*MockMetricsQuerier) QueryPVCUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVCUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryPVInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVInfo(start, end time.Time) *Future[PVInfoResult]

func (*MockMetricsQuerier) QueryPVPricePerGiBHour added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVPricePerGiBHour(start, end time.Time) *Future[PVPricePerGiBHourResult]

func (*MockMetricsQuerier) QueryPVUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryPVUsedAverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVUsedAverage(start, end time.Time) *Future[PVUsedAvgResult]

func (*MockMetricsQuerier) QueryPVUsedMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryPVUsedMax(start, end time.Time) *Future[PVUsedMaxResult]

func (*MockMetricsQuerier) QueryPodAnnotations added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodAnnotations(start, end time.Time) *Future[PodAnnotationsResult]

func (*MockMetricsQuerier) QueryPodInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodInfo(start, end time.Time) *Future[PodInfoResult]

func (*MockMetricsQuerier) QueryPodLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodLabels(start, end time.Time) *Future[PodLabelsResult]

func (*MockMetricsQuerier) QueryPodNetworkEgressBytes added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodNetworkEgressBytes(start, end time.Time) *Future[PodNetworkBytesResult]

func (*MockMetricsQuerier) QueryPodNetworkIngressBytes added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodNetworkIngressBytes(start, end time.Time) *Future[PodNetworkBytesResult]

func (*MockMetricsQuerier) QueryPodOwners added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodOwners(start, end time.Time) *Future[OwnerResult]

func (*MockMetricsQuerier) QueryPodPVCAllocation added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodPVCAllocation(start, end time.Time) *Future[PodPVCAllocationResult]

func (*MockMetricsQuerier) QueryPodPVCVolumes added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodPVCVolumes(start, end time.Time) *Future[PodPVCVolumeResult]

func (*MockMetricsQuerier) QueryPodUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryPods added in v1.121.0 

func (m *MockMetricsQuerier) QueryPods(start, end time.Time) *Future[PodsResult]

func (*MockMetricsQuerier) QueryPodsUID added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodsUID(start, end time.Time) *Future[PodsResult]

func (*MockMetricsQuerier) QueryPodsWithDaemonSetOwner added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodsWithDaemonSetOwner(start, end time.Time) *Future[PodsWithDaemonSetOwnerResult]

func (*MockMetricsQuerier) QueryPodsWithJobOwner added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodsWithJobOwner(start, end time.Time) *Future[PodsWithJobOwnerResult]

func (*MockMetricsQuerier) QueryPodsWithReplicaSetOwner added in v1.121.0 

func (m *MockMetricsQuerier) QueryPodsWithReplicaSetOwner(start, end time.Time) *Future[PodsWithReplicaSetOwnerResult]

func (*MockMetricsQuerier) QueryRAMBytesAllocated added in v1.121.0 

func (m *MockMetricsQuerier) QueryRAMBytesAllocated(start, end time.Time) *Future[RAMBytesAllocatedResult]

func (*MockMetricsQuerier) QueryRAMLimits added in v1.121.0 

func (m *MockMetricsQuerier) QueryRAMLimits(start, end time.Time) *Future[RAMLimitsResult]

func (*MockMetricsQuerier) QueryRAMRequests added in v1.121.0 

func (m *MockMetricsQuerier) QueryRAMRequests(start, end time.Time) *Future[RAMRequestsResult]

func (*MockMetricsQuerier) QueryRAMUsageAvg added in v1.121.0 

func (m *MockMetricsQuerier) QueryRAMUsageAvg(start, end time.Time) *Future[RAMUsageAvgResult]

func (*MockMetricsQuerier) QueryRAMUsageMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryRAMUsageMax(start, end time.Time) *Future[RAMUsageMaxResult]

func (*MockMetricsQuerier) QueryReplicaSetAnnotations added in v1.121.0 

func (m *MockMetricsQuerier) QueryReplicaSetAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*MockMetricsQuerier) QueryReplicaSetInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryReplicaSetInfo(start, end time.Time) *Future[ReplicaSetInfoResult]

func (*MockMetricsQuerier) QueryReplicaSetLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryReplicaSetLabels(start, end time.Time) *Future[LabelsResult]

func (*MockMetricsQuerier) QueryReplicaSetOwners added in v1.121.0 

func (m *MockMetricsQuerier) QueryReplicaSetOwners(start, end time.Time) *Future[OwnerResult]

func (*MockMetricsQuerier) QueryReplicaSetUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryReplicaSetUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryReplicaSetsWithRollout added in v1.121.0 

func (m *MockMetricsQuerier) QueryReplicaSetsWithRollout(start, end time.Time) *Future[ReplicaSetsWithRolloutResult]

func (*MockMetricsQuerier) QueryReplicaSetsWithoutOwners added in v1.121.0 

func (m *MockMetricsQuerier) QueryReplicaSetsWithoutOwners(start, end time.Time) *Future[ReplicaSetsWithoutOwnersResult]

func (*MockMetricsQuerier) QueryResourceQuotaInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaInfo(start, end time.Time) *Future[ResourceQuotaInfoResult]

func (*MockMetricsQuerier) QueryResourceQuotaSpecCPULimitAverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaSpecCPULimitAverage(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaSpecCPULimitMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaSpecCPULimitMax(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaSpecCPURequestAverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaSpecCPURequestAverage(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaSpecCPURequestMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaSpecCPURequestMax(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaSpecRAMLimitAverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaSpecRAMLimitAverage(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaSpecRAMLimitMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaSpecRAMLimitMax(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaSpecRAMRequestAverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaSpecRAMRequestAverage(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaSpecRAMRequestMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaSpecRAMRequestMax(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitAverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitAverage(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitMax(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestAverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestAverage(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestMax(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitAverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitAverage(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitMax(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestAverage added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestAverage(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestMax added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestMax(start, end time.Time) *Future[ResourceResult]

func (*MockMetricsQuerier) QueryResourceQuotaUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryResourceQuotaUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryServiceInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryServiceInfo(start, end time.Time) *Future[ServiceInfoResult]

func (*MockMetricsQuerier) QueryServiceSelectorLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryServiceSelectorLabels(start, end time.Time) *Future[ServiceLabelsResult]

func (*MockMetricsQuerier) QueryServiceUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryServiceUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) QueryStatefulSetAnnotations added in v1.121.0 

func (m *MockMetricsQuerier) QueryStatefulSetAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*MockMetricsQuerier) QueryStatefulSetInfo added in v1.121.0 

func (m *MockMetricsQuerier) QueryStatefulSetInfo(start, end time.Time) *Future[StatefulSetInfoResult]

func (*MockMetricsQuerier) QueryStatefulSetLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryStatefulSetLabels(start, end time.Time) *Future[LabelsResult]

func (*MockMetricsQuerier) QueryStatefulSetMatchLabels added in v1.121.0 

func (m *MockMetricsQuerier) QueryStatefulSetMatchLabels(start, end time.Time) *Future[StatefulSetLabelsResult]

func (*MockMetricsQuerier) QueryStatefulSetUptime added in v1.121.0 

func (m *MockMetricsQuerier) QueryStatefulSetUptime(start, end time.Time) *Future[UptimeResult]

func (*MockMetricsQuerier) SetOverride added in v1.121.0 

func (m *MockMetricsQuerier) SetOverride(method string, result any)

SetOverride registers a []*T result slice to be returned when method is called. Pass nil to clear an override.

type MockOpenCostDataSource added in v1.121.0 

type MockOpenCostDataSource struct {
	Querier            *MockMetricsQuerier
	ClusterMapValue    clusters.ClusterMap
	ClusterInfoValue   clusters.ClusterInfoProvider
	BatchDurationValue time.Duration
	ResolutionValue    time.Duration
}

MockOpenCostDataSource is a minimal OpenCostDataSource for tests. Set fields directly to configure what the data source returns.

func NewMockOpenCostDataSource added in v1.121.0 

func NewMockOpenCostDataSource() *MockOpenCostDataSource

func (*MockOpenCostDataSource) BatchDuration added in v1.121.0 

func (m *MockOpenCostDataSource) BatchDuration() time.Duration

func (*MockOpenCostDataSource) ClusterInfo added in v1.121.0 

func (m *MockOpenCostDataSource) ClusterInfo() clusters.ClusterInfoProvider

func (*MockOpenCostDataSource) ClusterMap added in v1.121.0 

func (m *MockOpenCostDataSource) ClusterMap() clusters.ClusterMap

func (*MockOpenCostDataSource) Metrics added in v1.121.0 

func (m *MockOpenCostDataSource) Metrics() MetricsQuerier

func (*MockOpenCostDataSource) RegisterDiagnostics added in v1.121.0 

func (m *MockOpenCostDataSource) RegisterDiagnostics(_ diagnostics.DiagnosticService)

func (*MockOpenCostDataSource) RegisterEndPoints added in v1.121.0 

func (m *MockOpenCostDataSource) RegisterEndPoints(_ *httprouter.Router)

func (*MockOpenCostDataSource) Resolution added in v1.121.0 

func (m *MockOpenCostDataSource) Resolution() time.Duration

type NamespaceAnnotationsResult 

type NamespaceAnnotationsResult struct {
	UID         string
	Cluster     string
	Namespace   string
	Annotations map[string]string

	Data []*util.Vector
}

func DecodeNamespaceAnnotationsResult 

func DecodeNamespaceAnnotationsResult(result *QueryResult) *NamespaceAnnotationsResult

type NamespaceInfoResult added in v1.121.0 

type NamespaceInfoResult struct {
	UID       string
	Cluster   string
	Namespace string
}

func DecodeNamespaceInfoResult added in v1.121.0 

func DecodeNamespaceInfoResult(result *QueryResult) *NamespaceInfoResult

type NamespaceLabelsResult 

type NamespaceLabelsResult struct {
	UID       string
	Cluster   string
	Namespace string
	Labels    map[string]string
	Data      []*util.Vector
}

func DecodeNamespaceLabelsResult 

func DecodeNamespaceLabelsResult(result *QueryResult) *NamespaceLabelsResult

type NetInternetGiBResult 

type NetInternetGiBResult = NetworkGiBResult

func DecodeNetInternetGiBResult 

func DecodeNetInternetGiBResult(result *QueryResult) *NetInternetGiBResult

type NetInternetIngressGiBResult 

type NetInternetIngressGiBResult = NetworkGiBResult

func DecodeNetInternetIngressGiBResult 

func DecodeNetInternetIngressGiBResult(result *QueryResult) *NetInternetIngressGiBResult

type NetInternetPricePerGiBResult 

type NetInternetPricePerGiBResult = NetworkPricePerGiBResult

func DecodeNetInternetPricePerGiBResult 

func DecodeNetInternetPricePerGiBResult(result *QueryResult) *NetInternetPricePerGiBResult

type NetInternetServiceGiBResult 

type NetInternetServiceGiBResult = NetworkGiBResult

func DecodeNetInternetServiceGiBResult 

func DecodeNetInternetServiceGiBResult(result *QueryResult) *NetInternetServiceGiBResult

type NetInternetServiceIngressGiBResult 

type NetInternetServiceIngressGiBResult = NetworkGiBResult

func DecodeNetInternetServiceIngressGiBResult 

func DecodeNetInternetServiceIngressGiBResult(result *QueryResult) *NetInternetServiceIngressGiBResult

type NetNatGatewayGiBResult added in v1.119.2 

type NetNatGatewayGiBResult = NetworkGiBResult

func DecodeNetNatGatewayGiBResult added in v1.119.2 

func DecodeNetNatGatewayGiBResult(result *QueryResult) *NetNatGatewayGiBResult

type NetNatGatewayIngressGiBResult added in v1.119.2 

type NetNatGatewayIngressGiBResult = NetworkGiBResult

func DecodeNetNatGatewayIngressGiBResult added in v1.119.2 

func DecodeNetNatGatewayIngressGiBResult(result *QueryResult) *NetNatGatewayIngressGiBResult

type NetNatGatewayPricePerGiBResult added in v1.119.2 

type NetNatGatewayPricePerGiBResult = NetworkPricePerGiBResult

func DecodeNetNatGatewayPricePerGiBResult added in v1.119.2 

func DecodeNetNatGatewayPricePerGiBResult(result *QueryResult) *NetNatGatewayPricePerGiBResult

type NetReceiveBytesResult 

type NetReceiveBytesResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	Container string
	Data      []*util.Vector
}

func DecodeNetReceiveBytesResult 

func DecodeNetReceiveBytesResult(result *QueryResult) *NetReceiveBytesResult

type NetRegionGiBResult 

type NetRegionGiBResult = NetworkGiBResult

func DecodeNetRegionGiBResult 

func DecodeNetRegionGiBResult(result *QueryResult) *NetRegionGiBResult

type NetRegionIngressGiBResult 

type NetRegionIngressGiBResult = NetworkGiBResult

func DecodeNetRegionIngressGiBResult 

func DecodeNetRegionIngressGiBResult(result *QueryResult) *NetRegionIngressGiBResult

type NetRegionPricePerGiBResult 

type NetRegionPricePerGiBResult = NetworkPricePerGiBResult

func DecodeNetRegionPricePerGiBResult 

func DecodeNetRegionPricePerGiBResult(result *QueryResult) *NetRegionPricePerGiBResult

type NetTransferBytesResult 

type NetTransferBytesResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	Container string

	Data []*util.Vector
}

func DecodeNetTransferBytesResult 

func DecodeNetTransferBytesResult(result *QueryResult) *NetTransferBytesResult

type NetZoneGiBResult 

type NetZoneGiBResult = NetworkGiBResult

Type alias the specific network subclassification results AND price results

func DecodeNetZoneGiBResult 

func DecodeNetZoneGiBResult(result *QueryResult) *NetZoneGiBResult

type NetZoneIngressGiBResult 

type NetZoneIngressGiBResult = NetworkGiBResult

func DecodeNetZoneIngressGiBResult 

func DecodeNetZoneIngressGiBResult(result *QueryResult) *NetZoneIngressGiBResult

type NetZonePricePerGiBResult 

type NetZonePricePerGiBResult = NetworkPricePerGiBResult

func DecodeNetZonePricePerGiBResult 

func DecodeNetZonePricePerGiBResult(result *QueryResult) *NetZonePricePerGiBResult

type NetworkGiBResult 

type NetworkGiBResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	Service   string

	Data []*util.Vector
}

Base type for network usage results

func DecodeNetworkGiBResult 

func DecodeNetworkGiBResult(result *QueryResult) *NetworkGiBResult

type NetworkPricePerGiBResult 

type NetworkPricePerGiBResult struct {
	UID     string
	Cluster string

	Data []*util.Vector
}

Base type for network price results

func DecodeNetworkPricePerGiBResult 

func DecodeNetworkPricePerGiBResult(result *QueryResult) *NetworkPricePerGiBResult

type NoDataError 

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

NoDataError indicates that no data was returned by Prometheus. This should be treated like an EOF error, in that it may be expected.

func NewNoDataError 

func NewNoDataError(messages ...string) NoDataError

NewNoDataError creates a new NoDataError

func (NoDataError) Error 

func (nde NoDataError) Error() string

Error prints the error as a string

func (NoDataError) Wrap 

func (nde NoDataError) Wrap(message string) NoDataError

Wrap wraps the error with the given message, but persists the error type.

type NoOpMetricsQuerier added in v1.121.0 

type NoOpMetricsQuerier struct{}

NoOpMetricsQuerier is a no-op implementation of the MetricsQuerier interface that returns empty results for all queries.

func NewNoOpMetricsQuerier added in v1.121.0 

func NewNoOpMetricsQuerier() *NoOpMetricsQuerier

NewNoOpMetricsQuerier creates a new mock metrics querier

func (*NoOpMetricsQuerier) QueryCPUCoresAllocated added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryCPUCoresAllocated(start, end time.Time) *Future[CPUCoresAllocatedResult]

func (*NoOpMetricsQuerier) QueryCPULimits added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryCPULimits(start, end time.Time) *Future[CPULimitsResult]

func (*NoOpMetricsQuerier) QueryCPURequests added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryCPURequests(start, end time.Time) *Future[CPURequestsResult]

func (*NoOpMetricsQuerier) QueryCPUUsageAvg added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryCPUUsageAvg(start, end time.Time) *Future[CPUUsageAvgResult]

func (*NoOpMetricsQuerier) QueryCPUUsageMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryCPUUsageMax(start, end time.Time) *Future[CPUUsageMaxResult]

func (*NoOpMetricsQuerier) QueryClusterInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryClusterInfo(start, end time.Time) *Future[ClusterInfoResult]

func (*NoOpMetricsQuerier) QueryClusterKubeModelVersion added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryClusterKubeModelVersion(start, end time.Time) *Future[ClusterKubeModelVersionResult]

func (*NoOpMetricsQuerier) QueryClusterManagementDuration added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryClusterManagementDuration(start, end time.Time) *Future[ClusterManagementDurationResult]

func (*NoOpMetricsQuerier) QueryClusterManagementPricePerHr added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryClusterManagementPricePerHr(start, end time.Time) *Future[ClusterManagementPricePerHrResult]

func (*NoOpMetricsQuerier) QueryClusterUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryClusterUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryContainerResourceLimits added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryContainerResourceLimits(start, end time.Time) *Future[ContainerResourceResult]

func (*NoOpMetricsQuerier) QueryContainerResourceRequests added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryContainerResourceRequests(start, end time.Time) *Future[ContainerResourceResult]

func (*NoOpMetricsQuerier) QueryContainerUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryContainerUptime(start, end time.Time) *Future[ContainerUptimeResult]

func (*NoOpMetricsQuerier) QueryCronJobAnnotations added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryCronJobAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*NoOpMetricsQuerier) QueryCronJobInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryCronJobInfo(start, end time.Time) *Future[CronJobInfoResult]

func (*NoOpMetricsQuerier) QueryCronJobLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryCronJobLabels(start, end time.Time) *Future[LabelsResult]

func (*NoOpMetricsQuerier) QueryCronJobUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryCronJobUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryDCGMContainerUsageAvg added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDCGMContainerUsageAvg(start, end time.Time) *Future[DCGMDeviceContainerUsageResult]

func (*NoOpMetricsQuerier) QueryDCGMContainerUsageMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDCGMContainerUsageMax(start, end time.Time) *Future[DCGMDeviceContainerUsageResult]

func (*NoOpMetricsQuerier) QueryDCGMDeviceInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDCGMDeviceInfo(start, end time.Time) *Future[DCGMDeviceInfoResult]

func (*NoOpMetricsQuerier) QueryDCGMDeviceUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDCGMDeviceUptime(start, end time.Time) *Future[DCGMDeviceUptimeResult]

func (*NoOpMetricsQuerier) QueryDaemonSetAnnotations added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDaemonSetAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*NoOpMetricsQuerier) QueryDaemonSetInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDaemonSetInfo(start, end time.Time) *Future[DaemonSetInfoResult]

func (*NoOpMetricsQuerier) QueryDaemonSetLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDaemonSetLabels(start, end time.Time) *Future[LabelsResult]

func (*NoOpMetricsQuerier) QueryDaemonSetUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDaemonSetUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryDataCoverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDataCoverage(_ int) (time.Time, time.Time, error)

func (*NoOpMetricsQuerier) QueryDeploymentAnnotations added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDeploymentAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*NoOpMetricsQuerier) QueryDeploymentInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDeploymentInfo(start, end time.Time) *Future[DeploymentInfoResult]

func (*NoOpMetricsQuerier) QueryDeploymentLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDeploymentLabels(start, end time.Time) *Future[LabelsResult]

func (*NoOpMetricsQuerier) QueryDeploymentMatchLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDeploymentMatchLabels(start, end time.Time) *Future[DeploymentLabelsResult]

func (*NoOpMetricsQuerier) QueryDeploymentUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryDeploymentUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryGPUInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryGPUInfo(start, end time.Time) *Future[GPUInfoResult]

func (*NoOpMetricsQuerier) QueryGPUsAllocated added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryGPUsAllocated(start, end time.Time) *Future[GPUsAllocatedResult]

func (*NoOpMetricsQuerier) QueryGPUsRequested added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryGPUsRequested(start, end time.Time) *Future[GPUsRequestedResult]

func (*NoOpMetricsQuerier) QueryGPUsUsageAvg added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryGPUsUsageAvg(start, end time.Time) *Future[GPUsUsageAvgResult]

func (*NoOpMetricsQuerier) QueryGPUsUsageMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryGPUsUsageMax(start, end time.Time) *Future[GPUsUsageMaxResult]

func (*NoOpMetricsQuerier) QueryInferenceCacheConfig added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryInferenceCacheConfig(t time.Time) *Future[InferenceCacheConfigResult]

func (*NoOpMetricsQuerier) QueryInferenceCachedTokens added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryInferenceCachedTokens(start, end time.Time) *Future[InferenceTokensResult]

func (*NoOpMetricsQuerier) QueryInferenceGenerationTokens added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryInferenceGenerationTokens(start, end time.Time) *Future[InferenceTokensResult]

func (*NoOpMetricsQuerier) QueryInferenceInputProcessingTime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryInferenceInputProcessingTime(start, end time.Time) *Future[InferenceProcessingTimeResult]

func (*NoOpMetricsQuerier) QueryInferenceOutputProcessingTime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryInferenceOutputProcessingTime(start, end time.Time) *Future[InferenceProcessingTimeResult]

func (*NoOpMetricsQuerier) QueryInferencePromptTokens added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryInferencePromptTokens(start, end time.Time) *Future[InferenceTokensResult]

func (*NoOpMetricsQuerier) QueryIsGPUShared added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryIsGPUShared(start, end time.Time) *Future[IsGPUSharedResult]

func (*NoOpMetricsQuerier) QueryJobAnnotations added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryJobAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*NoOpMetricsQuerier) QueryJobInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryJobInfo(start, end time.Time) *Future[JobInfoResult]

func (*NoOpMetricsQuerier) QueryJobLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryJobLabels(start, end time.Time) *Future[LabelsResult]

func (*NoOpMetricsQuerier) QueryJobUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryJobUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryKMLocalStorageBytes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryKMLocalStorageBytes(start, end time.Time) *Future[UIDValueResult]

func (*NoOpMetricsQuerier) QueryKMLocalStorageUsedAvg added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryKMLocalStorageUsedAvg(start, end time.Time) *Future[NodeUIDValueResult]

func (*NoOpMetricsQuerier) QueryKMLocalStorageUsedMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryKMLocalStorageUsedMax(start, end time.Time) *Future[NodeUIDValueResult]

func (*NoOpMetricsQuerier) QueryKMPVCInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryKMPVCInfo(start, end time.Time) *Future[PVCInfoResult]

func (*NoOpMetricsQuerier) QueryKMPVInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryKMPVInfo(start, end time.Time) *Future[PVInfoResult]

func (*NoOpMetricsQuerier) QueryLBActiveMinutes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryLBActiveMinutes(start, end time.Time) *Future[LBActiveMinutesResult]

func (*NoOpMetricsQuerier) QueryLBPricePerHr added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryLBPricePerHr(start, end time.Time) *Future[LBPricePerHrResult]

func (*NoOpMetricsQuerier) QueryLocalStorageActiveMinutes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryLocalStorageActiveMinutes(start, end time.Time) *Future[LocalStorageActiveMinutesResult]

func (*NoOpMetricsQuerier) QueryLocalStorageBytes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryLocalStorageBytes(start, end time.Time) *Future[LocalStorageBytesResult]

func (*NoOpMetricsQuerier) QueryLocalStorageCost added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryLocalStorageCost(start, end time.Time) *Future[LocalStorageCostResult]

func (*NoOpMetricsQuerier) QueryLocalStorageUsedAvg added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryLocalStorageUsedAvg(start, end time.Time) *Future[LocalStorageUsedAvgResult]

func (*NoOpMetricsQuerier) QueryLocalStorageUsedCost added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryLocalStorageUsedCost(start, end time.Time) *Future[LocalStorageUsedCostResult]

func (*NoOpMetricsQuerier) QueryLocalStorageUsedMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryLocalStorageUsedMax(start, end time.Time) *Future[LocalStorageUsedMaxResult]

func (*NoOpMetricsQuerier) QueryNamespaceAnnotations added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNamespaceAnnotations(start, end time.Time) *Future[NamespaceAnnotationsResult]

func (*NoOpMetricsQuerier) QueryNamespaceInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNamespaceInfo(start, end time.Time) *Future[NamespaceInfoResult]

func (*NoOpMetricsQuerier) QueryNamespaceLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNamespaceLabels(start, end time.Time) *Future[NamespaceLabelsResult]

func (*NoOpMetricsQuerier) QueryNamespaceUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNamespaceUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryNetInternetGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetInternetGiB(start, end time.Time) *Future[NetInternetGiBResult]

func (*NoOpMetricsQuerier) QueryNetInternetIngressGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetInternetIngressGiB(start, end time.Time) *Future[NetInternetIngressGiBResult]

func (*NoOpMetricsQuerier) QueryNetInternetPricePerGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetInternetPricePerGiB(start, end time.Time) *Future[NetInternetPricePerGiBResult]

func (*NoOpMetricsQuerier) QueryNetInternetServiceGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetInternetServiceGiB(start, end time.Time) *Future[NetInternetServiceGiBResult]

func (*NoOpMetricsQuerier) QueryNetInternetServiceIngressGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetInternetServiceIngressGiB(start, end time.Time) *Future[NetInternetServiceIngressGiBResult]

func (*NoOpMetricsQuerier) QueryNetNatGatewayGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetNatGatewayGiB(start, end time.Time) *Future[NetNatGatewayGiBResult]

func (*NoOpMetricsQuerier) QueryNetNatGatewayIngressGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetNatGatewayIngressGiB(start, end time.Time) *Future[NetNatGatewayIngressGiBResult]

func (*NoOpMetricsQuerier) QueryNetNatGatewayIngressPricePerGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetNatGatewayIngressPricePerGiB(start, end time.Time) *Future[NetNatGatewayPricePerGiBResult]

func (*NoOpMetricsQuerier) QueryNetNatGatewayPricePerGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetNatGatewayPricePerGiB(start, end time.Time) *Future[NetNatGatewayPricePerGiBResult]

func (*NoOpMetricsQuerier) QueryNetReceiveBytes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetReceiveBytes(start, end time.Time) *Future[NetReceiveBytesResult]

func (*NoOpMetricsQuerier) QueryNetRegionGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetRegionGiB(start, end time.Time) *Future[NetRegionGiBResult]

func (*NoOpMetricsQuerier) QueryNetRegionIngressGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetRegionIngressGiB(start, end time.Time) *Future[NetRegionIngressGiBResult]

func (*NoOpMetricsQuerier) QueryNetRegionPricePerGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetRegionPricePerGiB(start, end time.Time) *Future[NetRegionPricePerGiBResult]

func (*NoOpMetricsQuerier) QueryNetTransferBytes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetTransferBytes(start, end time.Time) *Future[NetTransferBytesResult]

func (*NoOpMetricsQuerier) QueryNetZoneGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetZoneGiB(start, end time.Time) *Future[NetZoneGiBResult]

func (*NoOpMetricsQuerier) QueryNetZoneIngressGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetZoneIngressGiB(start, end time.Time) *Future[NetZoneIngressGiBResult]

func (*NoOpMetricsQuerier) QueryNetZonePricePerGiB added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNetZonePricePerGiB(start, end time.Time) *Future[NetZonePricePerGiBResult]

func (*NoOpMetricsQuerier) QueryNodeActiveMinutes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeActiveMinutes(start, end time.Time) *Future[NodeActiveMinutesResult]

func (*NoOpMetricsQuerier) QueryNodeCPUCoresAllocatable added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeCPUCoresAllocatable(start, end time.Time) *Future[NodeCPUCoresAllocatableResult]

func (*NoOpMetricsQuerier) QueryNodeCPUCoresCapacity added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeCPUCoresCapacity(start, end time.Time) *Future[NodeCPUCoresCapacityResult]

func (*NoOpMetricsQuerier) QueryNodeCPUModeTotal added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeCPUModeTotal(start, end time.Time) *Future[NodeCPUModeTotalResult]

func (*NoOpMetricsQuerier) QueryNodeCPUPricePerHr added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeCPUPricePerHr(start, end time.Time) *Future[NodeCPUPricePerHrResult]

func (*NoOpMetricsQuerier) QueryNodeGPUCount added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeGPUCount(start, end time.Time) *Future[NodeGPUCountResult]

func (*NoOpMetricsQuerier) QueryNodeGPUPricePerHr added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeGPUPricePerHr(start, end time.Time) *Future[NodeGPUPricePerHrResult]

func (*NoOpMetricsQuerier) QueryNodeInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeInfo(start, end time.Time) *Future[NodeInfoResult]

func (*NoOpMetricsQuerier) QueryNodeIsSpot added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeIsSpot(start, end time.Time) *Future[NodeIsSpotResult]

func (*NoOpMetricsQuerier) QueryNodeLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeLabels(start, end time.Time) *Future[NodeLabelsResult]

func (*NoOpMetricsQuerier) QueryNodeRAMBytesAllocatable added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeRAMBytesAllocatable(start, end time.Time) *Future[NodeRAMBytesAllocatableResult]

func (*NoOpMetricsQuerier) QueryNodeRAMBytesCapacity added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeRAMBytesCapacity(start, end time.Time) *Future[NodeRAMBytesCapacityResult]

func (*NoOpMetricsQuerier) QueryNodeRAMPricePerGiBHr added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeRAMPricePerGiBHr(start, end time.Time) *Future[NodeRAMPricePerGiBHrResult]

func (*NoOpMetricsQuerier) QueryNodeRAMSystemPercent added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeRAMSystemPercent(start, end time.Time) *Future[NodeRAMSystemPercentResult]

func (*NoOpMetricsQuerier) QueryNodeRAMUserPercent added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeRAMUserPercent(start, end time.Time) *Future[NodeRAMUserPercentResult]

func (*NoOpMetricsQuerier) QueryNodeResourceCapacities added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeResourceCapacities(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryNodeResourcesAllocatable added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeResourcesAllocatable(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryNodeUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryNodeUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryPVActiveMinutes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVActiveMinutes(start, end time.Time) *Future[PVActiveMinutesResult]

func (*NoOpMetricsQuerier) QueryPVBytes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVBytes(start, end time.Time) *Future[PVBytesResult]

func (*NoOpMetricsQuerier) QueryPVCBytesRequested added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVCBytesRequested(start, end time.Time) *Future[PVCBytesRequestedResult]

func (*NoOpMetricsQuerier) QueryPVCBytesUsedAverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVCBytesUsedAverage(start, end time.Time) *Future[PVCUIDValueResult]

func (*NoOpMetricsQuerier) QueryPVCBytesUsedMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVCBytesUsedMax(start, end time.Time) *Future[PVCUIDValueResult]

func (*NoOpMetricsQuerier) QueryPVCInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVCInfo(start, end time.Time) *Future[PVCInfoResult]

func (*NoOpMetricsQuerier) QueryPVCUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVCUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryPVInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVInfo(start, end time.Time) *Future[PVInfoResult]

func (*NoOpMetricsQuerier) QueryPVPricePerGiBHour added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVPricePerGiBHour(start, end time.Time) *Future[PVPricePerGiBHourResult]

func (*NoOpMetricsQuerier) QueryPVUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryPVUsedAverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVUsedAverage(start, end time.Time) *Future[PVUsedAvgResult]

func (*NoOpMetricsQuerier) QueryPVUsedMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPVUsedMax(start, end time.Time) *Future[PVUsedMaxResult]

func (*NoOpMetricsQuerier) QueryPodAnnotations added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodAnnotations(start, end time.Time) *Future[PodAnnotationsResult]

func (*NoOpMetricsQuerier) QueryPodInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodInfo(start, end time.Time) *Future[PodInfoResult]

func (*NoOpMetricsQuerier) QueryPodLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodLabels(start, end time.Time) *Future[PodLabelsResult]

func (*NoOpMetricsQuerier) QueryPodNetworkEgressBytes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodNetworkEgressBytes(start, end time.Time) *Future[PodNetworkBytesResult]

func (*NoOpMetricsQuerier) QueryPodNetworkIngressBytes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodNetworkIngressBytes(start, end time.Time) *Future[PodNetworkBytesResult]

func (*NoOpMetricsQuerier) QueryPodOwners added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodOwners(start, end time.Time) *Future[OwnerResult]

func (*NoOpMetricsQuerier) QueryPodPVCAllocation added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodPVCAllocation(start, end time.Time) *Future[PodPVCAllocationResult]

func (*NoOpMetricsQuerier) QueryPodPVCVolumes added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodPVCVolumes(start, end time.Time) *Future[PodPVCVolumeResult]

func (*NoOpMetricsQuerier) QueryPodUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryPods added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPods(start, end time.Time) *Future[PodsResult]

func (*NoOpMetricsQuerier) QueryPodsUID added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodsUID(start, end time.Time) *Future[PodsResult]

func (*NoOpMetricsQuerier) QueryPodsWithDaemonSetOwner added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodsWithDaemonSetOwner(start, end time.Time) *Future[PodsWithDaemonSetOwnerResult]

func (*NoOpMetricsQuerier) QueryPodsWithJobOwner added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodsWithJobOwner(start, end time.Time) *Future[PodsWithJobOwnerResult]

func (*NoOpMetricsQuerier) QueryPodsWithReplicaSetOwner added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryPodsWithReplicaSetOwner(start, end time.Time) *Future[PodsWithReplicaSetOwnerResult]

func (*NoOpMetricsQuerier) QueryRAMBytesAllocated added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryRAMBytesAllocated(start, end time.Time) *Future[RAMBytesAllocatedResult]

func (*NoOpMetricsQuerier) QueryRAMLimits added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryRAMLimits(start, end time.Time) *Future[RAMLimitsResult]

func (*NoOpMetricsQuerier) QueryRAMRequests added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryRAMRequests(start, end time.Time) *Future[RAMRequestsResult]

func (*NoOpMetricsQuerier) QueryRAMUsageAvg added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryRAMUsageAvg(start, end time.Time) *Future[RAMUsageAvgResult]

func (*NoOpMetricsQuerier) QueryRAMUsageMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryRAMUsageMax(start, end time.Time) *Future[RAMUsageMaxResult]

func (*NoOpMetricsQuerier) QueryReplicaSetAnnotations added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryReplicaSetAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*NoOpMetricsQuerier) QueryReplicaSetInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryReplicaSetInfo(start, end time.Time) *Future[ReplicaSetInfoResult]

func (*NoOpMetricsQuerier) QueryReplicaSetLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryReplicaSetLabels(start, end time.Time) *Future[LabelsResult]

func (*NoOpMetricsQuerier) QueryReplicaSetOwners added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryReplicaSetOwners(start, end time.Time) *Future[OwnerResult]

func (*NoOpMetricsQuerier) QueryReplicaSetUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryReplicaSetUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryReplicaSetsWithRollout added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryReplicaSetsWithRollout(start, end time.Time) *Future[ReplicaSetsWithRolloutResult]

func (*NoOpMetricsQuerier) QueryReplicaSetsWithoutOwners added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryReplicaSetsWithoutOwners(start, end time.Time) *Future[ReplicaSetsWithoutOwnersResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaInfo(start, end time.Time) *Future[ResourceQuotaInfoResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaSpecCPULimitAverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaSpecCPULimitAverage(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaSpecCPULimitMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaSpecCPULimitMax(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaSpecCPURequestAverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaSpecCPURequestAverage(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaSpecCPURequestMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaSpecCPURequestMax(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaSpecRAMLimitAverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaSpecRAMLimitAverage(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaSpecRAMLimitMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaSpecRAMLimitMax(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaSpecRAMRequestAverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaSpecRAMRequestAverage(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaSpecRAMRequestMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaSpecRAMRequestMax(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitAverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitAverage(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitMax(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestAverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestAverage(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestMax(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitAverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitAverage(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitMax(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestAverage added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestAverage(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestMax added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestMax(start, end time.Time) *Future[ResourceResult]

func (*NoOpMetricsQuerier) QueryResourceQuotaUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryResourceQuotaUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryServiceInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryServiceInfo(start, end time.Time) *Future[ServiceInfoResult]

func (*NoOpMetricsQuerier) QueryServiceLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryServiceLabels(start, end time.Time) *Future[ServiceLabelsResult]

func (*NoOpMetricsQuerier) QueryServiceSelectorLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryServiceSelectorLabels(start, end time.Time) *Future[ServiceLabelsResult]

func (*NoOpMetricsQuerier) QueryServiceUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryServiceUptime(start, end time.Time) *Future[UptimeResult]

func (*NoOpMetricsQuerier) QueryStatefulSetAnnotations added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryStatefulSetAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*NoOpMetricsQuerier) QueryStatefulSetInfo added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryStatefulSetInfo(start, end time.Time) *Future[StatefulSetInfoResult]

func (*NoOpMetricsQuerier) QueryStatefulSetLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryStatefulSetLabels(start, end time.Time) *Future[LabelsResult]

func (*NoOpMetricsQuerier) QueryStatefulSetMatchLabels added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryStatefulSetMatchLabels(start, end time.Time) *Future[StatefulSetLabelsResult]

func (*NoOpMetricsQuerier) QueryStatefulSetUptime added in v1.121.0 

func (m *NoOpMetricsQuerier) QueryStatefulSetUptime(start, end time.Time) *Future[UptimeResult]

type NodeActiveMinutesResult 

type NodeActiveMinutesResult struct {
	UID        string
	Cluster    string
	Node       string
	ProviderID string
	Data       []*util.Vector
}

func DecodeNodeActiveMinutesResult 

func DecodeNodeActiveMinutesResult(result *QueryResult) *NodeActiveMinutesResult

type NodeCPUCoresAllocatableResult 

type NodeCPUCoresAllocatableResult = NodeCPUCoresCapacityResult

func DecodeNodeCPUCoresAllocatableResult 

func DecodeNodeCPUCoresAllocatableResult(result *QueryResult) *NodeCPUCoresAllocatableResult

type NodeCPUCoresCapacityResult 

type NodeCPUCoresCapacityResult struct {
	UID      string
	Cluster  string
	Node     string
	CPUCores float64
}

func DecodeNodeCPUCoresCapacityResult 

func DecodeNodeCPUCoresCapacityResult(result *QueryResult) *NodeCPUCoresCapacityResult

type NodeCPUModeTotalResult 

type NodeCPUModeTotalResult struct {
	UID     string
	Cluster string
	Node    string
	Mode    string
	Data    []*util.Vector
}

func DecodeNodeCPUModeTotalResult 

func DecodeNodeCPUModeTotalResult(result *QueryResult) *NodeCPUModeTotalResult

type NodeCPUPricePerHrResult 

type NodeCPUPricePerHrResult struct {
	UID          string
	Cluster      string
	Node         string
	InstanceType string
	ProviderID   string
	Data         []*util.Vector
}

func DecodeNodeCPUPricePerHrResult 

func DecodeNodeCPUPricePerHrResult(result *QueryResult) *NodeCPUPricePerHrResult

type NodeGPUCountResult 

type NodeGPUCountResult struct {
	UID        string
	Cluster    string
	Node       string
	ProviderID string
	GPUCount   float64
}

func DecodeNodeGPUCountResult 

func DecodeNodeGPUCountResult(result *QueryResult) *NodeGPUCountResult

type NodeGPUPricePerHrResult 

type NodeGPUPricePerHrResult struct {
	UID          string
	Cluster      string
	Node         string
	InstanceType string
	ProviderID   string
	Data         []*util.Vector
}

func DecodeNodeGPUPricePerHrResult 

func DecodeNodeGPUPricePerHrResult(result *QueryResult) *NodeGPUPricePerHrResult

type NodeInfoResult added in v1.121.0 

type NodeInfoResult struct {
	UID          string
	Cluster      string
	Node         string
	ProviderID   string
	InstanceType string
}

func DecodeNodeInfoResult added in v1.121.0 

func DecodeNodeInfoResult(result *QueryResult) *NodeInfoResult

type NodeIsSpotResult 

type NodeIsSpotResult struct {
	UID        string
	Cluster    string
	Node       string
	ProviderID string
	Data       []*util.Vector
}

func DecodeNodeIsSpotResult 

func DecodeNodeIsSpotResult(result *QueryResult) *NodeIsSpotResult

type NodeLabelsResult 

type NodeLabelsResult struct {
	UID     string
	Cluster string
	Node    string
	Labels  map[string]string
}

func DecodeNodeLabelsResult 

func DecodeNodeLabelsResult(result *QueryResult) *NodeLabelsResult

type NodeRAMBytesAllocatableResult 

type NodeRAMBytesAllocatableResult = NodeRAMBytesCapacityResult

func DecodeNodeRAMBytesAllocatableResult 

func DecodeNodeRAMBytesAllocatableResult(result *QueryResult) *NodeRAMBytesAllocatableResult

type NodeRAMBytesCapacityResult 

type NodeRAMBytesCapacityResult struct {
	UID      string
	Cluster  string
	Node     string
	RAMBytes float64
}

func DecodeNodeRAMBytesCapacityResult 

func DecodeNodeRAMBytesCapacityResult(result *QueryResult) *NodeRAMBytesCapacityResult

type NodeRAMPricePerGiBHrResult 

type NodeRAMPricePerGiBHrResult struct {
	UID          string
	Cluster      string
	Node         string
	InstanceType string
	ProviderID   string
	Data         []*util.Vector
}

func DecodeNodeRAMPricePerGiBHrResult 

func DecodeNodeRAMPricePerGiBHrResult(result *QueryResult) *NodeRAMPricePerGiBHrResult

type NodeRAMSystemPercentResult 

type NodeRAMSystemPercentResult struct {
	UID      string
	Cluster  string
	Instance string
	Data     []*util.Vector
}

func DecodeNodeRAMSystemPercentResult 

func DecodeNodeRAMSystemPercentResult(result *QueryResult) *NodeRAMSystemPercentResult

type NodeRAMUserPercentResult 

type NodeRAMUserPercentResult = NodeRAMSystemPercentResult

func DecodeNodeRAMUserPercentResult 

func DecodeNodeRAMUserPercentResult(result *QueryResult) *NodeRAMUserPercentResult

type NodeUIDValueResult added in v1.121.0 

type NodeUIDValueResult UIDValueResult

func DecodeNodeUIDValueResult added in v1.121.0 

func DecodeNodeUIDValueResult(result *QueryResult) *NodeUIDValueResult

type OpenCostDataSource 

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
}

type OwnerResult added in v1.121.0 

type OwnerResult struct {
	UID        string
	Cluster    string
	OwnerUID   string
	OwnerKind  string
	Controller bool
}

func DecodeOwnerResult added in v1.121.0 

func DecodeOwnerResult(result *QueryResult) *OwnerResult

type PVActiveMinutesResult 

type PVActiveMinutesResult struct {
	UID              string
	Cluster          string
	PersistentVolume string

	Data []*util.Vector
}

func DecodePVActiveMinutesResult 

func DecodePVActiveMinutesResult(result *QueryResult) *PVActiveMinutesResult

type PVBytesResult 

type PVBytesResult struct {
	UID              string
	Cluster          string
	PersistentVolume string
	Value            float64
}

func DecodePVBytesResult 

func DecodePVBytesResult(result *QueryResult) *PVBytesResult

type PVCBytesRequestedResult 

type PVCBytesRequestedResult struct {
	UID                   string
	Cluster               string
	Namespace             string
	PersistentVolumeClaim string

	Data []*util.Vector
}

func DecodePVCBytesRequestedResult 

func DecodePVCBytesRequestedResult(result *QueryResult) *PVCBytesRequestedResult

type PVCInfoResult 

type PVCInfoResult struct {
	UID                   string
	Cluster               string
	NamespaceUID          string
	Namespace             string
	VolumeName            string
	PVUID                 string
	PersistentVolumeClaim string
	StorageClass          string
	Data                  []*util.Vector
}

func DecodePVCInfoResult 

func DecodePVCInfoResult(result *QueryResult) *PVCInfoResult

type PVCUIDValueResult added in v1.121.0 

type PVCUIDValueResult UIDValueResult

func DecodePVCUIDValueResult added in v1.121.0 

func DecodePVCUIDValueResult(result *QueryResult) *PVCUIDValueResult

type PVInfoResult 

type PVInfoResult struct {
	UID              string
	Cluster          string
	PersistentVolume string
	StorageClass     string
	ProviderID       string
	CSIVolumeHandle  string
	Data             []*util.Vector
}

func DecodePVInfoResult 

func DecodePVInfoResult(result *QueryResult) *PVInfoResult

type PVPricePerGiBHourResult 

type PVPricePerGiBHourResult struct {
	UID              string
	Cluster          string
	VolumeName       string
	PersistentVolume string
	ProviderID       string

	Data []*util.Vector
}

func DecodePVPricePerGiBHourResult 

func DecodePVPricePerGiBHourResult(result *QueryResult) *PVPricePerGiBHourResult

type PVResult 

type PVResult struct {
	Cluster          string
	PersistentVolume string
}

type PVUsedAvgResult 

type PVUsedAvgResult struct {
	Cluster               string
	Namespace             string
	PersistentVolumeClaim string

	Data []*util.Vector
}

func DecodePVUsedAvgResult 

func DecodePVUsedAvgResult(result *QueryResult) *PVUsedAvgResult

type PVUsedMaxResult 

type PVUsedMaxResult struct {
	Cluster               string
	Namespace             string
	PersistentVolumeClaim string
	Data                  []*util.Vector
}

func DecodePVUsedMaxResult 

func DecodePVUsedMaxResult(result *QueryResult) *PVUsedMaxResult

type PodAnnotationsResult 

type PodAnnotationsResult struct {
	UID         string
	Cluster     string
	Namespace   string
	Pod         string
	Annotations map[string]string

	Data []*util.Vector
}

func DecodePodAnnotationsResult 

func DecodePodAnnotationsResult(result *QueryResult) *PodAnnotationsResult

type PodInfoResult added in v1.121.0 

type PodInfoResult struct {
	UID          string
	Cluster      string
	Pod          string
	NamespaceUID string
	NodeUID      string
}

func DecodePodInfoResult added in v1.121.0 

func DecodePodInfoResult(result *QueryResult) *PodInfoResult

type PodLabelsResult 

type PodLabelsResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	Labels    map[string]string
	Data      []*util.Vector
}

func DecodePodLabelsResult 

func DecodePodLabelsResult(result *QueryResult) *PodLabelsResult

type PodNetworkBytesResult added in v1.121.0 

type PodNetworkBytesResult struct {
	UID        string
	Cluster    string
	Service    string
	Internet   bool
	SameRegion bool
	SameZone   bool
	NatGateway bool
	Value      float64
}

func DecodePodNetworkBytesResult added in v1.121.0 

func DecodePodNetworkBytesResult(result *QueryResult) *PodNetworkBytesResult

type PodPVCAllocationResult 

type PodPVCAllocationResult struct {
	UID                   string
	Cluster               string
	Namespace             string
	Pod                   string
	PersistentVolume      string
	PersistentVolumeClaim string
	Data                  []*util.Vector
}

func DecodePodPVCAllocationResult 

func DecodePodPVCAllocationResult(result *QueryResult) *PodPVCAllocationResult

type PodPVCVolumeResult added in v1.121.0 

type PodPVCVolumeResult struct {
	UID           string
	Cluster       string
	PVCUID        string
	PodVolumeName string
}

func DecodePodPVCVolumeResult added in v1.121.0 

func DecodePodPVCVolumeResult(result *QueryResult) *PodPVCVolumeResult

type PodsResult 

type PodsResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string

	Data []*util.Vector
}

func DecodePodsResult 

func DecodePodsResult(result *QueryResult) *PodsResult

type PodsWithDaemonSetOwnerResult added in v1.121.0 

type PodsWithDaemonSetOwnerResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	DaemonSet string
}

func DecodePodsWithDaemonSetOwnerResult added in v1.121.0 

func DecodePodsWithDaemonSetOwnerResult(result *QueryResult) *PodsWithDaemonSetOwnerResult

type PodsWithJobOwnerResult added in v1.121.0 

type PodsWithJobOwnerResult struct {
	UID       string
	Cluster   string
	Namespace string
	Pod       string
	Job       string
}

func DecodePodsWithJobOwnerResult added in v1.121.0 

func DecodePodsWithJobOwnerResult(result *QueryResult) *PodsWithJobOwnerResult

type PodsWithReplicaSetOwnerResult 

type PodsWithReplicaSetOwnerResult struct {
	UID        string
	Cluster    string
	Namespace  string
	Pod        string
	ReplicaSet string

	Data []*util.Vector
}

func DecodePodsWithReplicaSetOwnerResult 

func DecodePodsWithReplicaSetOwnerResult(result *QueryResult) *PodsWithReplicaSetOwnerResult

type QueryError 

type QueryError struct {
	Query      string `json:"query"`
	Error      error  `json:"error"`
	ParseError error  `json:"parseError"`
}

func (*QueryError) String 

func (qe *QueryError) String() string

String returns a string representation of the QueryError

type QueryErrorCollection 

type QueryErrorCollection interface {
	// Warnings is a slice of the QueryWarning instances
	Warnings() []*QueryWarning

	// Errors is a slice of the QueryError instances
	Errors() []*QueryError

	// ToErrorAndWarningStrings returns the errors and warnings in the collection
	// as two string slices.
	ToErrorAndWarningStrings() (errors []string, warnings []string)
}

QueryErrorCollection represents a collection of query errors and warnings made via context.

type QueryErrorCollector 

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

QueryErrorCollector is used to collect prometheus query errors and warnings, and also meets the Error interface

func (*QueryErrorCollector) AppendError 

func (ec *QueryErrorCollector) AppendError(err *QueryError)

Appends a QueryError to the errors list

func (*QueryErrorCollector) AppendWarning 

func (ec *QueryErrorCollector) AppendWarning(warn *QueryWarning)

Appends a QueryWarning to the warnings list

func (*QueryErrorCollector) As 

func (ec *QueryErrorCollector) As(target interface{}) bool

As is a special method that implicitly works with the `errors.As()` go helper to locate the _first_ instance of the provided target type in the collection.

func (*QueryErrorCollector) Error 

func (ec *QueryErrorCollector) Error() string

Implement the error interface to allow returning as an aggregated error

func (*QueryErrorCollector) Errors 

func (ec *QueryErrorCollector) Errors() []*QueryError

Errors caught by the collector

func (*QueryErrorCollector) IsError 

func (ec *QueryErrorCollector) IsError() bool

Whether or not the collector caught errors

func (*QueryErrorCollector) IsWarning 

func (ec *QueryErrorCollector) IsWarning() bool

Whether or not the collector caught any warnings

func (*QueryErrorCollector) Report 

func (ec *QueryErrorCollector) Report(query string, warnings []string, requestError error, parseError error)

Reports an error to the collector. Ignores if the error is nil and the warnings are empty

func (*QueryErrorCollector) ToErrorAndWarningStrings 

func (ec *QueryErrorCollector) ToErrorAndWarningStrings() (errors []string, warnings []string)

ToErrorAndWarningStrings returns the errors and warnings in the collection as two string slices.

func (*QueryErrorCollector) Warnings 

func (ec *QueryErrorCollector) Warnings() []*QueryWarning

Warnings caught by the collector

type QueryGroup 

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

QueryGroup is a representation of multiple async queries. It provides a shared error collector for all queries in the group.

Example: 

grp := NewQueryGroup()
q1 := WithGroup(grp, QueryFoo())
q2 := WithGroup(grp, QueryBar())

results1, _ := q1.Await()
results2, _ := q2.Await()

if grp.HasErrors() {
	return grp.Error() // <-- error return type
}

func NewQueryGroup 

func NewQueryGroup() *QueryGroup

NewQueryGroup creates a new QueryGroup instance which can be used to group non-typed async queries with the `With(QueryResultsChan)` instance method, or with the package function `WithGroup[T](*QueryGroup, *Future[T])`

func (*QueryGroup) Error 

func (qg *QueryGroup) Error() error

Error returns nil if there were no errors in the group. Otherwise, it returns all of the errors that occurred grouped into a single error.

func (*QueryGroup) Errors 

func (qg *QueryGroup) Errors() []*QueryError

Errors returns all of individual errors that occurred in the group.

func (*QueryGroup) HasErrors 

func (qg *QueryGroup) HasErrors() bool

HasErrors returns true if any of the async queries in the group have errored. Note that all results must be awaited in order to be checked for errors.

func (*QueryGroup) With 

func (qg *QueryGroup) With(resultsChan QueryResultsChan) *QueryGroupAsyncResult

With adds the given `QueryResultsChan` to the QueryGroup instance and returns a `QueryGroupAsyncResult` instance to be awaited

type QueryGroupAsyncResult 

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

QueryGroupAsyncResult is a representation of a single async query in a group.

func (*QueryGroupAsyncResult) Await 

func (qgar *QueryGroupAsyncResult) Await() ([]*QueryResult, error)

Await blocks and waits for the `QueryGroupAsyncResult` to resolve, and returns a slice of generic `QueryResult` instances if successful, or an error otherwise.

type QueryGroupFuture 

type QueryGroupFuture[T any] struct {
	// contains filtered or unexported fields
}

QueryGroupFuture[T] is a representation of a single async query in a group with a typed result.

func WithGroup 

func WithGroup[T any](g *QueryGroup, f *Future[T]) *QueryGroupFuture[T]

WithGroup creates a new QueryGroupFuture[T] instance with the given QueryGroup and Future instances. This is the specific way to add a typed `Future[T]` to a `QueryGroup`.

func (*QueryGroupFuture[T]) Await 

func (qgf *QueryGroupFuture[T]) Await() ([]*T, error)

Await blocks and waits for the `QueryGroupFuture[T]` to resolve, and returns a slice of `*T` instances if successful, or an error otherwise.

type QueryResult 

type QueryResult struct {
	Metric map[string]interface{} `json:"metric"`
	Values []*util.Vector         `json:"values"`
	// contains filtered or unexported fields
}

QueryResult contains a single result from a prometheus query. It's common to refer to query results as a slice of QueryResult

func NewQueryResult 

func NewQueryResult(metrics map[string]any, values []*util.Vector, keys *ResultKeys) *QueryResult

func (*QueryResult) GetAnnotations 

func (qr *QueryResult) GetAnnotations() map[string]string

GetAnnotations returns all annotations and their values from the query result

func (*QueryResult) GetBool added in v1.121.0 

func (qr *QueryResult) GetBool(field string) (bool, error)

func (*QueryResult) GetCluster 

func (qr *QueryResult) GetCluster() (string, error)

func (*QueryResult) GetContainer 

func (qr *QueryResult) GetContainer() (string, error)

func (*QueryResult) GetDevice 

func (qr *QueryResult) GetDevice() (string, error)

func (*QueryResult) GetInstance 

func (qr *QueryResult) GetInstance() (string, error)

func (*QueryResult) GetInstanceType 

func (qr *QueryResult) GetInstanceType() (string, error)

func (*QueryResult) GetLabels 

func (qr *QueryResult) GetLabels() map[string]string

GetLabels returns all labels and their values from the query result

func (*QueryResult) GetNamespace 

func (qr *QueryResult) GetNamespace() (string, error)

func (*QueryResult) GetNode 

func (qr *QueryResult) GetNode() (string, error)

func (*QueryResult) GetPod 

func (qr *QueryResult) GetPod() (string, error)

func (*QueryResult) GetProviderID 

func (qr *QueryResult) GetProviderID() (string, error)

func (*QueryResult) GetString 

func (qr *QueryResult) GetString(field string) (string, error)

GetString returns the requested field, or an error if it does not exist

func (*QueryResult) GetStrings 

func (qr *QueryResult) GetStrings(fields ...string) (map[string]string, error)

GetStrings returns the requested fields, or an error if it does not exist

type QueryResults 

type QueryResults struct {
	Query   string
	Error   error
	Results []*QueryResult
}

QueryResults contains all of the query results and the source query string.

func NewQueryResults 

func NewQueryResults(query string) *QueryResults

type QueryResultsChan 

type QueryResultsChan chan *QueryResults

QueryResultsChan is a channel of query results

func (QueryResultsChan) Await 

func (qrc QueryResultsChan) Await() ([]*QueryResult, error)

Await returns query results, blocking until they are made available, and deferring the closure of the underlying channel

type QueryWarning 

type QueryWarning struct {
	Query    string   `json:"query"`
	Warnings []string `json:"warnings"`
}

func (*QueryWarning) String 

func (qw *QueryWarning) String() string

String returns a string representation of the QueryWarning

type RAMBytesAllocatedResult 

type RAMBytesAllocatedResult = ContainerMetricResult

func DecodeRAMBytesAllocatedResult 

func DecodeRAMBytesAllocatedResult(result *QueryResult) *RAMBytesAllocatedResult

type RAMLimitsResult added in v1.118.1 

type RAMLimitsResult = ContainerMetricResult

func DecodeRAMLimitsResult added in v1.118.1 

func DecodeRAMLimitsResult(result *QueryResult) *RAMLimitsResult

type RAMRequestsResult 

type RAMRequestsResult = ContainerMetricResult

func DecodeRAMRequestsResult 

func DecodeRAMRequestsResult(result *QueryResult) *RAMRequestsResult

type RAMUsageAvgResult 

type RAMUsageAvgResult = ContainerMetricResult

func DecodeRAMUsageAvgResult 

func DecodeRAMUsageAvgResult(result *QueryResult) *RAMUsageAvgResult

type RAMUsageMaxResult 

type RAMUsageMaxResult = ContainerMetricResult

func DecodeRAMUsageMaxResult 

func DecodeRAMUsageMaxResult(result *QueryResult) *RAMUsageMaxResult

type RecordMetricsQuerier added in v1.121.0 

type RecordMetricsQuerier struct {
	Calls   map[string]int
	Querier MetricsQuerier
}

RecordMetricsQuerier is a wrapper implementation of MetricsQuerier which counts the number of times each function is called

func NewRecordMetricsQuerier added in v1.121.0 

func NewRecordMetricsQuerier(querier MetricsQuerier) *RecordMetricsQuerier

NewRecordMetricsQuerier creates a new mock metrics querier

func (*RecordMetricsQuerier) QueryCPUCoresAllocated added in v1.121.0 

func (m *RecordMetricsQuerier) QueryCPUCoresAllocated(start, end time.Time) *Future[CPUCoresAllocatedResult]

func (*RecordMetricsQuerier) QueryCPULimits added in v1.121.0 

func (m *RecordMetricsQuerier) QueryCPULimits(start, end time.Time) *Future[CPULimitsResult]

func (*RecordMetricsQuerier) QueryCPURequests added in v1.121.0 

func (m *RecordMetricsQuerier) QueryCPURequests(start, end time.Time) *Future[CPURequestsResult]

func (*RecordMetricsQuerier) QueryCPUUsageAvg added in v1.121.0 

func (m *RecordMetricsQuerier) QueryCPUUsageAvg(start, end time.Time) *Future[CPUUsageAvgResult]

func (*RecordMetricsQuerier) QueryCPUUsageMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryCPUUsageMax(start, end time.Time) *Future[CPUUsageMaxResult]

func (*RecordMetricsQuerier) QueryClusterInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryClusterInfo(start, end time.Time) *Future[ClusterInfoResult]

func (*RecordMetricsQuerier) QueryClusterKubeModelVersion added in v1.121.0 

func (m *RecordMetricsQuerier) QueryClusterKubeModelVersion(start, end time.Time) *Future[ClusterKubeModelVersionResult]

func (*RecordMetricsQuerier) QueryClusterManagementDuration added in v1.121.0 

func (m *RecordMetricsQuerier) QueryClusterManagementDuration(start, end time.Time) *Future[ClusterManagementDurationResult]

func (*RecordMetricsQuerier) QueryClusterManagementPricePerHr added in v1.121.0 

func (m *RecordMetricsQuerier) QueryClusterManagementPricePerHr(start, end time.Time) *Future[ClusterManagementPricePerHrResult]

func (*RecordMetricsQuerier) QueryClusterUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryClusterUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryContainerResourceLimits added in v1.121.0 

func (m *RecordMetricsQuerier) QueryContainerResourceLimits(start, end time.Time) *Future[ContainerResourceResult]

func (*RecordMetricsQuerier) QueryContainerResourceRequests added in v1.121.0 

func (m *RecordMetricsQuerier) QueryContainerResourceRequests(start, end time.Time) *Future[ContainerResourceResult]

func (*RecordMetricsQuerier) QueryContainerUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryContainerUptime(start, end time.Time) *Future[ContainerUptimeResult]

func (*RecordMetricsQuerier) QueryCronJobAnnotations added in v1.121.0 

func (m *RecordMetricsQuerier) QueryCronJobAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*RecordMetricsQuerier) QueryCronJobInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryCronJobInfo(start, end time.Time) *Future[CronJobInfoResult]

func (*RecordMetricsQuerier) QueryCronJobLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryCronJobLabels(start, end time.Time) *Future[LabelsResult]

func (*RecordMetricsQuerier) QueryCronJobUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryCronJobUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryDCGMContainerUsageAvg added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDCGMContainerUsageAvg(start, end time.Time) *Future[DCGMDeviceContainerUsageResult]

func (*RecordMetricsQuerier) QueryDCGMContainerUsageMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDCGMContainerUsageMax(start, end time.Time) *Future[DCGMDeviceContainerUsageResult]

func (*RecordMetricsQuerier) QueryDCGMDeviceInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDCGMDeviceInfo(start, end time.Time) *Future[DCGMDeviceInfoResult]

func (*RecordMetricsQuerier) QueryDCGMDeviceUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDCGMDeviceUptime(start, end time.Time) *Future[DCGMDeviceUptimeResult]

func (*RecordMetricsQuerier) QueryDaemonSetAnnotations added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDaemonSetAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*RecordMetricsQuerier) QueryDaemonSetInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDaemonSetInfo(start, end time.Time) *Future[DaemonSetInfoResult]

func (*RecordMetricsQuerier) QueryDaemonSetLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDaemonSetLabels(start, end time.Time) *Future[LabelsResult]

func (*RecordMetricsQuerier) QueryDaemonSetUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDaemonSetUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryDataCoverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDataCoverage(limitDays int) (time.Time, time.Time, error)

func (*RecordMetricsQuerier) QueryDeploymentAnnotations added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDeploymentAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*RecordMetricsQuerier) QueryDeploymentInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDeploymentInfo(start, end time.Time) *Future[DeploymentInfoResult]

func (*RecordMetricsQuerier) QueryDeploymentLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDeploymentLabels(start, end time.Time) *Future[LabelsResult]

func (*RecordMetricsQuerier) QueryDeploymentMatchLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDeploymentMatchLabels(start, end time.Time) *Future[DeploymentLabelsResult]

func (*RecordMetricsQuerier) QueryDeploymentUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryDeploymentUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryGPUInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryGPUInfo(start, end time.Time) *Future[GPUInfoResult]

func (*RecordMetricsQuerier) QueryGPUsAllocated added in v1.121.0 

func (m *RecordMetricsQuerier) QueryGPUsAllocated(start, end time.Time) *Future[GPUsAllocatedResult]

func (*RecordMetricsQuerier) QueryGPUsRequested added in v1.121.0 

func (m *RecordMetricsQuerier) QueryGPUsRequested(start, end time.Time) *Future[GPUsRequestedResult]

func (*RecordMetricsQuerier) QueryGPUsUsageAvg added in v1.121.0 

func (m *RecordMetricsQuerier) QueryGPUsUsageAvg(start, end time.Time) *Future[GPUsUsageAvgResult]

func (*RecordMetricsQuerier) QueryGPUsUsageMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryGPUsUsageMax(start, end time.Time) *Future[GPUsUsageMaxResult]

func (*RecordMetricsQuerier) QueryInferenceCacheConfig added in v1.121.0 

func (m *RecordMetricsQuerier) QueryInferenceCacheConfig(t time.Time) *Future[InferenceCacheConfigResult]

func (*RecordMetricsQuerier) QueryInferenceCachedTokens added in v1.121.0 

func (m *RecordMetricsQuerier) QueryInferenceCachedTokens(start, end time.Time) *Future[InferenceTokensResult]

func (*RecordMetricsQuerier) QueryInferenceGenerationTokens added in v1.121.0 

func (m *RecordMetricsQuerier) QueryInferenceGenerationTokens(start, end time.Time) *Future[InferenceTokensResult]

func (*RecordMetricsQuerier) QueryInferenceInputProcessingTime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryInferenceInputProcessingTime(start, end time.Time) *Future[InferenceProcessingTimeResult]

func (*RecordMetricsQuerier) QueryInferenceOutputProcessingTime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryInferenceOutputProcessingTime(start, end time.Time) *Future[InferenceProcessingTimeResult]

func (*RecordMetricsQuerier) QueryInferencePromptTokens added in v1.121.0 

func (m *RecordMetricsQuerier) QueryInferencePromptTokens(start, end time.Time) *Future[InferenceTokensResult]

func (*RecordMetricsQuerier) QueryIsGPUShared added in v1.121.0 

func (m *RecordMetricsQuerier) QueryIsGPUShared(start, end time.Time) *Future[IsGPUSharedResult]

func (*RecordMetricsQuerier) QueryJobAnnotations added in v1.121.0 

func (m *RecordMetricsQuerier) QueryJobAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*RecordMetricsQuerier) QueryJobInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryJobInfo(start, end time.Time) *Future[JobInfoResult]

func (*RecordMetricsQuerier) QueryJobLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryJobLabels(start, end time.Time) *Future[LabelsResult]

func (*RecordMetricsQuerier) QueryJobUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryJobUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryKMLocalStorageBytes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryKMLocalStorageBytes(start, end time.Time) *Future[UIDValueResult]

func (*RecordMetricsQuerier) QueryKMLocalStorageUsedAvg added in v1.121.0 

func (m *RecordMetricsQuerier) QueryKMLocalStorageUsedAvg(start, end time.Time) *Future[NodeUIDValueResult]

func (*RecordMetricsQuerier) QueryKMLocalStorageUsedMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryKMLocalStorageUsedMax(start, end time.Time) *Future[NodeUIDValueResult]

func (*RecordMetricsQuerier) QueryKMPVCInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryKMPVCInfo(start, end time.Time) *Future[PVCInfoResult]

func (*RecordMetricsQuerier) QueryKMPVInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryKMPVInfo(start, end time.Time) *Future[PVInfoResult]

func (*RecordMetricsQuerier) QueryLBActiveMinutes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryLBActiveMinutes(start, end time.Time) *Future[LBActiveMinutesResult]

func (*RecordMetricsQuerier) QueryLBPricePerHr added in v1.121.0 

func (m *RecordMetricsQuerier) QueryLBPricePerHr(start, end time.Time) *Future[LBPricePerHrResult]

func (*RecordMetricsQuerier) QueryLocalStorageActiveMinutes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryLocalStorageActiveMinutes(start, end time.Time) *Future[LocalStorageActiveMinutesResult]

func (*RecordMetricsQuerier) QueryLocalStorageBytes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryLocalStorageBytes(start, end time.Time) *Future[LocalStorageBytesResult]

func (*RecordMetricsQuerier) QueryLocalStorageUsedAvg added in v1.121.0 

func (m *RecordMetricsQuerier) QueryLocalStorageUsedAvg(start, end time.Time) *Future[LocalStorageUsedAvgResult]

func (*RecordMetricsQuerier) QueryLocalStorageUsedMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryLocalStorageUsedMax(start, end time.Time) *Future[LocalStorageUsedMaxResult]

func (*RecordMetricsQuerier) QueryNamespaceAnnotations added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNamespaceAnnotations(start, end time.Time) *Future[NamespaceAnnotationsResult]

func (*RecordMetricsQuerier) QueryNamespaceInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNamespaceInfo(start, end time.Time) *Future[NamespaceInfoResult]

func (*RecordMetricsQuerier) QueryNamespaceLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNamespaceLabels(start, end time.Time) *Future[NamespaceLabelsResult]

func (*RecordMetricsQuerier) QueryNamespaceUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNamespaceUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryNetInternetGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetInternetGiB(start, end time.Time) *Future[NetInternetGiBResult]

func (*RecordMetricsQuerier) QueryNetInternetIngressGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetInternetIngressGiB(start, end time.Time) *Future[NetInternetIngressGiBResult]

func (*RecordMetricsQuerier) QueryNetInternetPricePerGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetInternetPricePerGiB(start, end time.Time) *Future[NetInternetPricePerGiBResult]

func (*RecordMetricsQuerier) QueryNetInternetServiceGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetInternetServiceGiB(start, end time.Time) *Future[NetInternetServiceGiBResult]

func (*RecordMetricsQuerier) QueryNetInternetServiceIngressGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetInternetServiceIngressGiB(start, end time.Time) *Future[NetInternetServiceIngressGiBResult]

func (*RecordMetricsQuerier) QueryNetNatGatewayGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetNatGatewayGiB(start, end time.Time) *Future[NetNatGatewayGiBResult]

func (*RecordMetricsQuerier) QueryNetNatGatewayIngressGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetNatGatewayIngressGiB(start, end time.Time) *Future[NetNatGatewayIngressGiBResult]

func (*RecordMetricsQuerier) QueryNetNatGatewayIngressPricePerGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetNatGatewayIngressPricePerGiB(start, end time.Time) *Future[NetNatGatewayPricePerGiBResult]

func (*RecordMetricsQuerier) QueryNetNatGatewayPricePerGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetNatGatewayPricePerGiB(start, end time.Time) *Future[NetNatGatewayPricePerGiBResult]

func (*RecordMetricsQuerier) QueryNetReceiveBytes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetReceiveBytes(start, end time.Time) *Future[NetReceiveBytesResult]

func (*RecordMetricsQuerier) QueryNetRegionGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetRegionGiB(start, end time.Time) *Future[NetRegionGiBResult]

func (*RecordMetricsQuerier) QueryNetRegionIngressGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetRegionIngressGiB(start, end time.Time) *Future[NetRegionIngressGiBResult]

func (*RecordMetricsQuerier) QueryNetRegionPricePerGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetRegionPricePerGiB(start, end time.Time) *Future[NetRegionPricePerGiBResult]

func (*RecordMetricsQuerier) QueryNetTransferBytes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetTransferBytes(start, end time.Time) *Future[NetTransferBytesResult]

func (*RecordMetricsQuerier) QueryNetZoneGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetZoneGiB(start, end time.Time) *Future[NetZoneGiBResult]

func (*RecordMetricsQuerier) QueryNetZoneIngressGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetZoneIngressGiB(start, end time.Time) *Future[NetZoneIngressGiBResult]

func (*RecordMetricsQuerier) QueryNetZonePricePerGiB added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNetZonePricePerGiB(start, end time.Time) *Future[NetZonePricePerGiBResult]

func (*RecordMetricsQuerier) QueryNodeActiveMinutes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeActiveMinutes(start, end time.Time) *Future[NodeActiveMinutesResult]

func (*RecordMetricsQuerier) QueryNodeCPUCoresAllocatable added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeCPUCoresAllocatable(start, end time.Time) *Future[NodeCPUCoresAllocatableResult]

func (*RecordMetricsQuerier) QueryNodeCPUCoresCapacity added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeCPUCoresCapacity(start, end time.Time) *Future[NodeCPUCoresCapacityResult]

func (*RecordMetricsQuerier) QueryNodeCPUModeTotal added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeCPUModeTotal(start, end time.Time) *Future[NodeCPUModeTotalResult]

func (*RecordMetricsQuerier) QueryNodeCPUPricePerHr added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeCPUPricePerHr(start, end time.Time) *Future[NodeCPUPricePerHrResult]

func (*RecordMetricsQuerier) QueryNodeGPUCount added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeGPUCount(start, end time.Time) *Future[NodeGPUCountResult]

func (*RecordMetricsQuerier) QueryNodeGPUPricePerHr added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeGPUPricePerHr(start, end time.Time) *Future[NodeGPUPricePerHrResult]

func (*RecordMetricsQuerier) QueryNodeInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeInfo(start, end time.Time) *Future[NodeInfoResult]

func (*RecordMetricsQuerier) QueryNodeIsSpot added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeIsSpot(start, end time.Time) *Future[NodeIsSpotResult]

func (*RecordMetricsQuerier) QueryNodeLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeLabels(start, end time.Time) *Future[NodeLabelsResult]

func (*RecordMetricsQuerier) QueryNodeRAMBytesAllocatable added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeRAMBytesAllocatable(start, end time.Time) *Future[NodeRAMBytesAllocatableResult]

func (*RecordMetricsQuerier) QueryNodeRAMBytesCapacity added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeRAMBytesCapacity(start, end time.Time) *Future[NodeRAMBytesCapacityResult]

func (*RecordMetricsQuerier) QueryNodeRAMPricePerGiBHr added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeRAMPricePerGiBHr(start, end time.Time) *Future[NodeRAMPricePerGiBHrResult]

func (*RecordMetricsQuerier) QueryNodeRAMSystemPercent added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeRAMSystemPercent(start, end time.Time) *Future[NodeRAMSystemPercentResult]

func (*RecordMetricsQuerier) QueryNodeRAMUserPercent added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeRAMUserPercent(start, end time.Time) *Future[NodeRAMUserPercentResult]

func (*RecordMetricsQuerier) QueryNodeResourceCapacities added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeResourceCapacities(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryNodeResourcesAllocatable added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeResourcesAllocatable(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryNodeUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryNodeUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryPVActiveMinutes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVActiveMinutes(start, end time.Time) *Future[PVActiveMinutesResult]

func (*RecordMetricsQuerier) QueryPVBytes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVBytes(start, end time.Time) *Future[PVBytesResult]

func (*RecordMetricsQuerier) QueryPVCBytesRequested added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVCBytesRequested(start, end time.Time) *Future[PVCBytesRequestedResult]

func (*RecordMetricsQuerier) QueryPVCBytesUsedAverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVCBytesUsedAverage(start, end time.Time) *Future[PVCUIDValueResult]

func (*RecordMetricsQuerier) QueryPVCBytesUsedMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVCBytesUsedMax(start, end time.Time) *Future[PVCUIDValueResult]

func (*RecordMetricsQuerier) QueryPVCInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVCInfo(start, end time.Time) *Future[PVCInfoResult]

func (*RecordMetricsQuerier) QueryPVCUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVCUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryPVInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVInfo(start, end time.Time) *Future[PVInfoResult]

func (*RecordMetricsQuerier) QueryPVPricePerGiBHour added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVPricePerGiBHour(start, end time.Time) *Future[PVPricePerGiBHourResult]

func (*RecordMetricsQuerier) QueryPVUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryPVUsedAverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVUsedAverage(start, end time.Time) *Future[PVUsedAvgResult]

func (*RecordMetricsQuerier) QueryPVUsedMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPVUsedMax(start, end time.Time) *Future[PVUsedMaxResult]

func (*RecordMetricsQuerier) QueryPodAnnotations added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodAnnotations(start, end time.Time) *Future[PodAnnotationsResult]

func (*RecordMetricsQuerier) QueryPodInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodInfo(start, end time.Time) *Future[PodInfoResult]

func (*RecordMetricsQuerier) QueryPodLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodLabels(start, end time.Time) *Future[PodLabelsResult]

func (*RecordMetricsQuerier) QueryPodNetworkEgressBytes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodNetworkEgressBytes(start, end time.Time) *Future[PodNetworkBytesResult]

func (*RecordMetricsQuerier) QueryPodNetworkIngressBytes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodNetworkIngressBytes(start, end time.Time) *Future[PodNetworkBytesResult]

func (*RecordMetricsQuerier) QueryPodOwners added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodOwners(start, end time.Time) *Future[OwnerResult]

func (*RecordMetricsQuerier) QueryPodPVCAllocation added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodPVCAllocation(start, end time.Time) *Future[PodPVCAllocationResult]

func (*RecordMetricsQuerier) QueryPodPVCVolumes added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodPVCVolumes(start, end time.Time) *Future[PodPVCVolumeResult]

func (*RecordMetricsQuerier) QueryPodUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryPods added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPods(start, end time.Time) *Future[PodsResult]

func (*RecordMetricsQuerier) QueryPodsUID added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodsUID(start, end time.Time) *Future[PodsResult]

func (*RecordMetricsQuerier) QueryPodsWithDaemonSetOwner added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodsWithDaemonSetOwner(start, end time.Time) *Future[PodsWithDaemonSetOwnerResult]

func (*RecordMetricsQuerier) QueryPodsWithJobOwner added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodsWithJobOwner(start, end time.Time) *Future[PodsWithJobOwnerResult]

func (*RecordMetricsQuerier) QueryPodsWithReplicaSetOwner added in v1.121.0 

func (m *RecordMetricsQuerier) QueryPodsWithReplicaSetOwner(start, end time.Time) *Future[PodsWithReplicaSetOwnerResult]

func (*RecordMetricsQuerier) QueryRAMBytesAllocated added in v1.121.0 

func (m *RecordMetricsQuerier) QueryRAMBytesAllocated(start, end time.Time) *Future[RAMBytesAllocatedResult]

func (*RecordMetricsQuerier) QueryRAMLimits added in v1.121.0 

func (m *RecordMetricsQuerier) QueryRAMLimits(start, end time.Time) *Future[RAMLimitsResult]

func (*RecordMetricsQuerier) QueryRAMRequests added in v1.121.0 

func (m *RecordMetricsQuerier) QueryRAMRequests(start, end time.Time) *Future[RAMRequestsResult]

func (*RecordMetricsQuerier) QueryRAMUsageAvg added in v1.121.0 

func (m *RecordMetricsQuerier) QueryRAMUsageAvg(start, end time.Time) *Future[RAMUsageAvgResult]

func (*RecordMetricsQuerier) QueryRAMUsageMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryRAMUsageMax(start, end time.Time) *Future[RAMUsageMaxResult]

func (*RecordMetricsQuerier) QueryReplicaSetAnnotations added in v1.121.0 

func (m *RecordMetricsQuerier) QueryReplicaSetAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*RecordMetricsQuerier) QueryReplicaSetInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryReplicaSetInfo(start, end time.Time) *Future[ReplicaSetInfoResult]

func (*RecordMetricsQuerier) QueryReplicaSetLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryReplicaSetLabels(start, end time.Time) *Future[LabelsResult]

func (*RecordMetricsQuerier) QueryReplicaSetOwners added in v1.121.0 

func (m *RecordMetricsQuerier) QueryReplicaSetOwners(start, end time.Time) *Future[OwnerResult]

func (*RecordMetricsQuerier) QueryReplicaSetUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryReplicaSetUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryReplicaSetsWithRollout added in v1.121.0 

func (m *RecordMetricsQuerier) QueryReplicaSetsWithRollout(start, end time.Time) *Future[ReplicaSetsWithRolloutResult]

func (*RecordMetricsQuerier) QueryReplicaSetsWithoutOwners added in v1.121.0 

func (m *RecordMetricsQuerier) QueryReplicaSetsWithoutOwners(start, end time.Time) *Future[ReplicaSetsWithoutOwnersResult]

func (*RecordMetricsQuerier) QueryResourceQuotaInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaInfo(start, end time.Time) *Future[ResourceQuotaInfoResult]

func (*RecordMetricsQuerier) QueryResourceQuotaSpecCPULimitAverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaSpecCPULimitAverage(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaSpecCPULimitMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaSpecCPULimitMax(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaSpecCPURequestAverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaSpecCPURequestAverage(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaSpecCPURequestMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaSpecCPURequestMax(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaSpecRAMLimitAverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaSpecRAMLimitAverage(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaSpecRAMLimitMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaSpecRAMLimitMax(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaSpecRAMRequestAverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaSpecRAMRequestAverage(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaSpecRAMRequestMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaSpecRAMRequestMax(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitAverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitAverage(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaStatusUsedCPULimitMax(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestAverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestAverage(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaStatusUsedCPURequestMax(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitAverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitAverage(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaStatusUsedRAMLimitMax(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestAverage added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestAverage(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestMax added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaStatusUsedRAMRequestMax(start, end time.Time) *Future[ResourceResult]

func (*RecordMetricsQuerier) QueryResourceQuotaUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryResourceQuotaUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryServiceInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryServiceInfo(start, end time.Time) *Future[ServiceInfoResult]

func (*RecordMetricsQuerier) QueryServiceSelectorLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryServiceSelectorLabels(start, end time.Time) *Future[ServiceLabelsResult]

func (*RecordMetricsQuerier) QueryServiceUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryServiceUptime(start, end time.Time) *Future[UptimeResult]

func (*RecordMetricsQuerier) QueryStatefulSetAnnotations added in v1.121.0 

func (m *RecordMetricsQuerier) QueryStatefulSetAnnotations(start, end time.Time) *Future[AnnotationsResult]

func (*RecordMetricsQuerier) QueryStatefulSetInfo added in v1.121.0 

func (m *RecordMetricsQuerier) QueryStatefulSetInfo(start, end time.Time) *Future[StatefulSetInfoResult]

func (*RecordMetricsQuerier) QueryStatefulSetLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryStatefulSetLabels(start, end time.Time) *Future[LabelsResult]

func (*RecordMetricsQuerier) QueryStatefulSetMatchLabels added in v1.121.0 

func (m *RecordMetricsQuerier) QueryStatefulSetMatchLabels(start, end time.Time) *Future[StatefulSetLabelsResult]

func (*RecordMetricsQuerier) QueryStatefulSetUptime added in v1.121.0 

func (m *RecordMetricsQuerier) QueryStatefulSetUptime(start, end time.Time) *Future[UptimeResult]

type ReplicaSetInfoResult added in v1.121.0 

type ReplicaSetInfoResult struct {
	UID          string
	Cluster      string
	NamespaceUID string
	ReplicaSet   string
}

func DecodeReplicaSetInfoResult added in v1.121.0 

func DecodeReplicaSetInfoResult(result *QueryResult) *ReplicaSetInfoResult

type ReplicaSetsWithRolloutResult 

type ReplicaSetsWithRolloutResult struct {
	UID        string
	Cluster    string
	Namespace  string
	ReplicaSet string
	OwnerName  string
	OwnerKind  string
	Data       []*util.Vector
}

func DecodeReplicaSetsWithRolloutResult 

func DecodeReplicaSetsWithRolloutResult(result *QueryResult) *ReplicaSetsWithRolloutResult

type ReplicaSetsWithoutOwnersResult 

type ReplicaSetsWithoutOwnersResult struct {
	UID        string
	Cluster    string
	Namespace  string
	ReplicaSet string

	Data []*util.Vector
}

func DecodeReplicaSetsWithoutOwnersResult 

func DecodeReplicaSetsWithoutOwnersResult(result *QueryResult) *ReplicaSetsWithoutOwnersResult

type ResourceQuotaInfoResult added in v1.121.0 

type ResourceQuotaInfoResult struct {
	UID           string
	NamespaceUID  string
	ResourceQuota string
}

func DecodeResourceQuotaInfoResult added in v1.121.0 

func DecodeResourceQuotaInfoResult(result *QueryResult) *ResourceQuotaInfoResult

type ResourceResult added in v1.121.0 

type ResourceResult struct {
	UID      string
	Resource string
	Unit     string
	Value    float64
}

func DecodeResourceResult added in v1.121.0 

func DecodeResourceResult(result *QueryResult) *ResourceResult

type ResultDecoder 

type ResultDecoder[T any] func(*QueryResult) *T

ResultDecoder[T] is a function that decodes a `QueryResult` into a `*T` type.

type ResultKeys 

type ResultKeys struct {
	ClusterKey      string
	NamespaceKey    string
	NodeKey         string
	InstanceKey     string
	InstanceTypeKey string
	ContainerKey    string
	PodKey          string
	ProviderIDKey   string
	DeviceKey       string
}

ResultKeys is a "configuration" struct that contains the keys/labels used to resolve labeled query results. ResultKeys can be defined with every QueryResults instance if necessary, and alter the keys used to fetch results when calling the following methods on QueryResults: 

GetCluster()
GetNamespace()
GetNode()
GetInstance()
GetInstanceType()
GetContainer()
GetPod()
GetProviderID()
GetDevice()

func ClusterKeyWithDefaults 

func ClusterKeyWithDefaults(clusterKey string) *ResultKeys

ClusterKeyWithDefaults returns a new ResultKeys instance with the provided cluster key and the rest of the keys set to their default values.

func DefaultResultKeys 

func DefaultResultKeys() *ResultKeys

DefaultResultKeys returns a new ResultKeys instance with typical default values.

type ServiceInfoResult added in v1.121.0 

type ServiceInfoResult struct {
	UID              string
	Cluster          string
	NamespaceUID     string
	Service          string
	ServiceType      string
	LBIngressAddress string
}

func DecodeServiceInfoResult added in v1.121.0 

func DecodeServiceInfoResult(result *QueryResult) *ServiceInfoResult

type ServiceLabelsResult 

type ServiceLabelsResult struct {
	UID       string
	Cluster   string
	Namespace string
	Service   string
	Labels    map[string]string

	Data []*util.Vector
}

func DecodeServiceLabelsResult 

func DecodeServiceLabelsResult(result *QueryResult) *ServiceLabelsResult

type StatefulSetInfoResult added in v1.121.0 

type StatefulSetInfoResult struct {
	UID          string
	Cluster      string
	NamespaceUID string
	StatefulSet  string
}

func DecodeStatefulSetInfoResult added in v1.121.0 

func DecodeStatefulSetInfoResult(result *QueryResult) *StatefulSetInfoResult

type StatefulSetLabelsResult 

type StatefulSetLabelsResult struct {
	UID         string
	Cluster     string
	Namespace   string
	StatefulSet string
	Labels      map[string]string
	Data        []*util.Vector
}

func DecodeStatefulSetLabelsResult 

func DecodeStatefulSetLabelsResult(result *QueryResult) *StatefulSetLabelsResult

type UIDValueResult added in v1.121.0 

type UIDValueResult struct {
	UID   string
	Value float64
}

func DecodeUIDValueResult added in v1.121.0 

func DecodeUIDValueResult(result *QueryResult) *UIDValueResult

type UptimeResult added in v1.119.0 

type UptimeResult struct {
	UID   string
	First time.Time
	Last  time.Time
}

UptimeResult represents the first and last recorded sample timestamp within the query window

func DecodeUptimeResult added in v1.119.0 

func DecodeUptimeResult(result *QueryResult) *UptimeResult

func (*UptimeResult) GetStartEnd added in v1.119.0 

func (res *UptimeResult) GetStartEnd(windowStart, windowEnd time.Time, resolution time.Duration) (time.Time, time.Time)

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.