diskscaler

Documentation

Overview

All the available custom error types of disk auto scaler

Index

• Constants
• func Setup(mux *http.ServeMux, clientConfig *rest.Config, k8sClient kubernetes.Interface, ...) error
• type DiskScaler
  • func NewDiskScaler(clientConfig *rest.Config, basicK8sClient kubernetes.Interface, ...) (*DiskScaler, error)
• type DiskScalerDeploymentWorkload
• type DiskScalerService
  • func NewDiskScalerService(clientConfig *rest.Config, k8sClient kubernetes.Interface, ...) (*DiskScalerService, error)
• type DiskScalingAllFailedError
  • func (e *DiskScalingAllFailedError) Error() string
• type DiskScalingPartialFailedError
  • func (e *DiskScalingPartialFailedError) Error() string
• type RunStatus

Constants

const (
	AnnotationEnabled           = "request.autodiskscaling.kubecost.com/enabled"
	AnnotationExcluded          = "request.autodiskscaling.kubecost.com/excluded"
	AnnotationLastScaled        = "request.autodiskscaling.kubecost.com/lastScaled"
	AnnotationInterval          = "request.autodiskscaling.kubecost.com/interval"
	AnnotationTargetUtilization = "request.autodiskscaling.kubecost.com/targetUtilization"
	PVCAnnotationExtendBy       = "request.autodiskscaling.kubecost.com/volumeExtendedBy"
	PVCAnnotationCreatedBy      = "request.autodiskscaling.kubecost.com/volumeCreatedBy"
	DiskAutoScaler              = "kubecost_disk_auto_scaler"
)

const (
	KubecostNamespace = "kubecost"
)

Functions

func Setup

func Setup(mux *http.ServeMux, clientConfig *rest.Config, k8sClient kubernetes.Interface, dynamicK8sClient *dynamic.DynamicClient) error

Types

type DiskScaler

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

func NewDiskScaler

func NewDiskScaler(clientConfig *rest.Config,
	basicK8sClient kubernetes.Interface,
	dynamicK8sClient *dynamic.DynamicClient,
	clusterID string,
	kubecostsvc *pvsizingrecommendation.KubecostService,
	auditMode bool) (*DiskScaler, error)

type DiskScalerDeploymentWorkload

type DiskScalerDeploymentWorkload struct {
	Namespace  string `json:"namespace"`
	Deployment string `json:"deployment"`
}

type DiskScalerService

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

func NewDiskScalerService

func NewDiskScalerService(clientConfig *rest.Config,
	k8sClient kubernetes.Interface,
	dynamicK8sClient *dynamic.DynamicClient,
	resizeAll bool,
	auditMode bool,
	kubecostSvc *pvsizingrecommendation.KubecostService,
	excludedNamespaces []string) (*DiskScalerService, error)

type DiskScalingAllFailedError

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

Custom error to return to the service calling the disk autoscaler workflow all PVC scaling failed

func (*DiskScalingAllFailedError) Error

func (e *DiskScalingAllFailedError) Error() string

type DiskScalingPartialFailedError

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

Custom error to return to the service calling the disk autoscaler workflow when some of PVC in scaling failed

func (*DiskScalingPartialFailedError) Error

func (e *DiskScalingPartialFailedError) Error() string

type RunStatus

type RunStatus struct {
	NumEnabled  int
	NumEligible int
	SuccessRun  int
	FailedRun   int
}