client

Documentation

Index

• type CachedMetricsClient
  • func NewCachedMetricsClient(metricsclientset metricsclientv1beta1.MetricsV1beta1Interface, ...) *CachedMetricsClient
  • func (c *CachedMetricsClient) GetCustomMetricForNode(ctx context.Context, name string, metricName string) (*custommetricsv1beta2.MetricValue, error)
  • func (c *CachedMetricsClient) GetNodeMetrics(ctx context.Context, name string) (*metricsv1beta1.NodeMetrics, error)
  • func (c *CachedMetricsClient) GetPodMetrics(ctx context.Context, namespace string, name string) (*metricsv1beta1.PodMetrics, error)
• type CachedPredictorClient
  • func NewCachedPredictorClient(client kubernetes.Interface, ttl time.Duration) *CachedPredictorClient
  • func (c *CachedPredictorClient) GetPredictorEndpoint(ctx context.Context, namespace string, ep *waov1beta1.EndpointTerm, ...) (*waov1beta1.EndpointTerm, error)
  • func (c *CachedPredictorClient) PredictPowerConsumption(ctx context.Context, namespace string, ep *waov1beta1.EndpointTerm, ...) (watt float64, err error)

Types

type CachedMetricsClient

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

func NewCachedMetricsClient

func NewCachedMetricsClient(metricsclientset metricsclientv1beta1.MetricsV1beta1Interface, custommetricsclient custommetricsclient.CustomMetricsClient, ttl time.Duration) *CachedMetricsClient

func (*CachedMetricsClient) GetCustomMetricForNode

func (c *CachedMetricsClient) GetCustomMetricForNode(ctx context.Context, name string, metricName string) (*custommetricsv1beta2.MetricValue, error)

func (*CachedMetricsClient) GetNodeMetrics

func (c *CachedMetricsClient) GetNodeMetrics(ctx context.Context, name string) (*metricsv1beta1.NodeMetrics, error)

func (*CachedMetricsClient) GetPodMetrics

func (c *CachedMetricsClient) GetPodMetrics(ctx context.Context, namespace string, name string) (*metricsv1beta1.PodMetrics, error)

type CachedPredictorClient

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

func NewCachedPredictorClient

func NewCachedPredictorClient(client kubernetes.Interface, ttl time.Duration) *CachedPredictorClient

func (*CachedPredictorClient) GetPredictorEndpoint

func (c *CachedPredictorClient) GetPredictorEndpoint(ctx context.Context, namespace string, ep *waov1beta1.EndpointTerm, predictorType predictor.PredictorType) (*waov1beta1.EndpointTerm, error)

func (*CachedPredictorClient) PredictPowerConsumption

func (c *CachedPredictorClient) PredictPowerConsumption(ctx context.Context, namespace string, ep *waov1beta1.EndpointTerm, cpuUsage, inletTemp, deltaP float64) (watt float64, err error)