model

package

Go to main page

Versions in this module

v1

v1.2.1

Aug 19, 2024

v1.2.0

Jul 29, 2024

v1.1.2

May 16, 2024

v1.1.1

Apr 25, 2024

v1.1.0

Apr 5, 2024

v1.0.0

Oct 5, 2023

Changes in this version

type Vpa

+ APIVersion string

+ func (vpa *Vpa) SetAPIVersion(to string)

v0

v0.14.0

Jun 20, 2023

v0.13.0

Feb 2, 2023

Changes in this version

+ const DefaultOOMBumpUpRatio

+ const DefaultOOMMinBumpUp

type AggregationsConfig

+ OOMBumpUpRatio float64

+ OOMMinBumpUp float64

v0.12.0

Sep 14, 2022

v0.11.0

May 31, 2022

v0.10.0

Jan 25, 2022

Changes in this version

type ClusterState

+ func (cluster *ClusterState) GetControllerForPodUnderVPA(pod *PodState, controllerFetcher controllerfetcher.ControllerFetcher) *controllerfetcher.ControllerKeyWithAPIVersion

+ func (cluster *ClusterState) GetControllingVPA(pod *PodState) *Vpa

+ func (cluster *ClusterState) RateLimitedGarbageCollectAggregateCollectionStates(now time.Time, controllerFetcher controllerfetcher.ControllerFetcher)

v0.9.2

Jan 15, 2021

v0.9.0

Oct 8, 2020

Changes in this version

+ const DefaultCPUHistogramDecayHalfLife

+ const DefaultHistogramBucketSizeGrowth

+ const DefaultMemoryAggregationInterval

+ const DefaultMemoryAggregationIntervalCount

+ const DefaultMemoryHistogramDecayHalfLife

+ const OOMBumpUpRatio

+ const OOMMinBumpUp

+ const RecommendationMissingMaxDuration

+ const SupportedCheckpointVersion

+ var DefaultControlledResources = []ResourceName

+ func BytesFromMemoryAmount(memoryAmount ResourceAmount) float64

+ func CoresFromCPUAmount(cpuAmount ResourceAmount) float64

+ func InitializeAggregationsConfig(config *AggregationsConfig)

+ func QuantityFromCPUAmount(cpuAmount ResourceAmount) resource.Quantity

+ func QuantityFromMemoryAmount(memoryAmount ResourceAmount) resource.Quantity

+ func ResourceNamesApiToModel(resources []apiv1.ResourceName) *[]ResourceName

+ func ResourcesAsResourceList(resources Resources) apiv1.ResourceList

+ type AggregateContainerState struct

+ AggregateCPUUsage util.Histogram

+ AggregateMemoryPeaks util.Histogram

+ ControlledResources *[]ResourceName

+ CreationTime time.Time

+ FirstSampleStart time.Time

+ IsUnderVPA bool

+ LastRecommendation corev1.ResourceList

+ LastSampleStart time.Time

+ ScalingMode *vpa_types.ContainerScalingMode

+ TotalSamplesCount int

+ UpdateMode *vpa_types.UpdateMode

+ func NewAggregateContainerState() *AggregateContainerState

+ func (a *AggregateContainerState) AddSample(sample *ContainerUsageSample)

+ func (a *AggregateContainerState) GetControlledResources() []ResourceName

+ func (a *AggregateContainerState) GetLastRecommendation() corev1.ResourceList

+ func (a *AggregateContainerState) GetScalingMode() *vpa_types.ContainerScalingMode

+ func (a *AggregateContainerState) GetUpdateMode() *vpa_types.UpdateMode

+ func (a *AggregateContainerState) LoadFromCheckpoint(checkpoint *vpa_types.VerticalPodAutoscalerCheckpointStatus) error

+ func (a *AggregateContainerState) MarkNotAutoscaled()

+ func (a *AggregateContainerState) MergeContainerState(other *AggregateContainerState)

+ func (a *AggregateContainerState) NeedsRecommendation() bool

+ func (a *AggregateContainerState) SaveToCheckpoint() (*vpa_types.VerticalPodAutoscalerCheckpointStatus, error)

+ func (a *AggregateContainerState) SubtractSample(sample *ContainerUsageSample)

+ func (a *AggregateContainerState) UpdateFromPolicy(resourcePolicy *vpa_types.ContainerResourcePolicy)

+ type AggregateStateKey interface

+ ContainerName func() string

+ Labels func() labels.Labels

+ Namespace func() string

+ type AggregationsConfig struct

+ CPUHistogramDecayHalfLife time.Duration

+ CPUHistogramOptions util.HistogramOptions

+ HistogramBucketSizeGrowth float64

+ MemoryAggregationInterval time.Duration

+ MemoryAggregationIntervalCount int64

+ MemoryHistogramDecayHalfLife time.Duration

+ MemoryHistogramOptions util.HistogramOptions

+ func GetAggregationsConfig() *AggregationsConfig

+ func NewAggregationsConfig(memoryAggregationInterval time.Duration, memoryAggregationIntervalCount int64, ...) *AggregationsConfig

+ func (a *AggregationsConfig) GetMemoryAggregationWindowLength() time.Duration

+ type ClusterState struct

+ EmptyVPAs map[VpaID]time.Time

+ ObservedVpas []*vpa_types.VerticalPodAutoscaler

+ Pods map[PodID]*PodState

+ Vpas map[VpaID]*Vpa

+ func NewClusterState() *ClusterState

+ func (cluster *ClusterState) AddOrUpdateContainer(containerID ContainerID, request Resources) error

+ func (cluster *ClusterState) AddOrUpdatePod(podID PodID, newLabels labels.Set, phase apiv1.PodPhase)

+ func (cluster *ClusterState) AddOrUpdateVpa(apiObject *vpa_types.VerticalPodAutoscaler, selector labels.Selector) error

+ func (cluster *ClusterState) AddSample(sample *ContainerUsageSampleWithKey) error

+ func (cluster *ClusterState) DeletePod(podID PodID)

+ func (cluster *ClusterState) DeleteVpa(vpaID VpaID) error

+ func (cluster *ClusterState) GarbageCollectAggregateCollectionStates(now time.Time)

+ func (cluster *ClusterState) GetContainer(containerID ContainerID) *ContainerState

+ func (cluster *ClusterState) GetMatchingPods(vpa *Vpa) []PodID

+ func (cluster *ClusterState) MakeAggregateStateKey(pod *PodState, containerName string) AggregateStateKey

+ func (cluster *ClusterState) RecordOOM(containerID ContainerID, timestamp time.Time, requestedMemory ResourceAmount) error

+ func (cluster *ClusterState) RecordRecommendation(vpa *Vpa, now time.Time) error

+ func (cluster *ClusterState) StateMapSize() int

+ type ContainerID struct

+ ContainerName string

+ type ContainerNameToAggregateStateMap map[string]*AggregateContainerState

+ func AggregateStateByContainerName(aggregateContainerStateMap aggregateContainerStatesMap) ContainerNameToAggregateStateMap

+ type ContainerState struct

+ LastCPUSampleStart time.Time

+ Request Resources

+ WindowEnd time.Time

+ func NewContainerState(request Resources, aggregator ContainerStateAggregator) *ContainerState

+ func (container *ContainerState) AddSample(sample *ContainerUsageSample) bool

+ func (container *ContainerState) GetMaxMemoryPeak() ResourceAmount

+ func (container *ContainerState) RecordOOM(timestamp time.Time, requestedMemory ResourceAmount) error

+ type ContainerStateAggregator interface

+ AddSample func(sample *ContainerUsageSample)

+ GetLastRecommendation func() corev1.ResourceList

+ GetUpdateMode func() *vpa_types.UpdateMode

+ NeedsRecommendation func() bool

+ SubtractSample func(sample *ContainerUsageSample)

+ func NewContainerStateAggregatorProxy(cluster *ClusterState, containerID ContainerID) ContainerStateAggregator

+ type ContainerStateAggregatorProxy struct

+ func (p *ContainerStateAggregatorProxy) AddSample(sample *ContainerUsageSample)

+ func (p *ContainerStateAggregatorProxy) GetLastRecommendation() corev1.ResourceList

+ func (p *ContainerStateAggregatorProxy) GetScalingMode() *vpa_types.ContainerScalingMode

+ func (p *ContainerStateAggregatorProxy) GetUpdateMode() *vpa_types.UpdateMode

+ func (p *ContainerStateAggregatorProxy) NeedsRecommendation() bool

+ func (p *ContainerStateAggregatorProxy) SubtractSample(sample *ContainerUsageSample)

+ type ContainerUsageSample struct

+ MeasureStart time.Time

+ Request ResourceAmount

+ Resource ResourceName

+ Usage ResourceAmount

+ type ContainerUsageSampleWithKey struct

+ Container ContainerID

+ type KeyError struct

+ func NewKeyError(key interface{}) KeyError

+ func (e KeyError) Error() string

+ type PodID struct

+ Namespace string

+ PodName string

+ type PodState struct

+ Containers map[string]*ContainerState

+ ID PodID

+ Phase apiv1.PodPhase

+ type ResourceAmount int64

+ func CPUAmountFromCores(cores float64) ResourceAmount

+ func MemoryAmountFromBytes(bytes float64) ResourceAmount

+ func ResourceAmountMax(amount1, amount2 ResourceAmount) ResourceAmount

+ func RoundResourceAmount(amount, unit ResourceAmount) ResourceAmount

+ func ScaleResource(amount ResourceAmount, factor float64) ResourceAmount

+ type ResourceName string

+ const MaxResourceAmount

+ const ResourceCPU

+ const ResourceMemory

+ type Resources map[ResourceName]ResourceAmount

+ type Vpa struct

+ Annotations vpaAnnotationsMap

+ CheckpointWritten time.Time

+ Conditions vpaConditionsMap

+ ContainersInitialAggregateState ContainerNameToAggregateStateMap

+ Created time.Time

+ ID VpaID

+ IsV1Beta1API bool

+ PodCount int

+ PodSelector labels.Selector

+ Recommendation *vpa_types.RecommendedPodResources

+ ResourcePolicy *vpa_types.PodResourcePolicy

+ TargetRef *autoscaling.CrossVersionObjectReference

+ UpdateMode *vpa_types.UpdateMode

+ func NewVpa(id VpaID, selector labels.Selector, created time.Time) *Vpa

+ func (vpa *Vpa) AggregateStateByContainerName() ContainerNameToAggregateStateMap

+ func (vpa *Vpa) AsStatus() *vpa_types.VerticalPodAutoscalerStatus

+ func (vpa *Vpa) DeleteAggregation(aggregationKey AggregateStateKey)

+ func (vpa *Vpa) HasMatchedPods() bool

+ func (vpa *Vpa) HasRecommendation() bool

+ func (vpa *Vpa) MergeCheckpointedState(aggregateContainerStateMap ContainerNameToAggregateStateMap)

+ func (vpa *Vpa) SetResourcePolicy(resourcePolicy *vpa_types.PodResourcePolicy)

+ func (vpa *Vpa) SetUpdateMode(updatePolicy *vpa_types.PodUpdatePolicy)

+ func (vpa *Vpa) UpdateConditions(podsMatched bool)

+ func (vpa *Vpa) UpdateRecommendation(recommendation *vpa_types.RecommendedPodResources)

+ func (vpa *Vpa) UseAggregationIfMatching(aggregationKey AggregateStateKey, aggregation *AggregateContainerState)

+ func (vpa *Vpa) UsesAggregation(aggregationKey AggregateStateKey) bool

+ type VpaID struct

+ Namespace string

+ VpaName string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL