nodegroupconfig

Documentation

Index

• type DelegatingNodeGroupConfigProcessor
  • func (p *DelegatingNodeGroupConfigProcessor) CleanUp()
  • func (p *DelegatingNodeGroupConfigProcessor) GetIgnoreDaemonSetsUtilization(nodeGroup cloudprovider.NodeGroup) (bool, error)
  • func (p *DelegatingNodeGroupConfigProcessor) GetMaxNodeProvisionTime(nodeGroup cloudprovider.NodeGroup) (time.Duration, error)
  • func (p *DelegatingNodeGroupConfigProcessor) GetScaleDownGpuUtilizationThreshold(nodeGroup cloudprovider.NodeGroup) (float64, error)
  • func (p *DelegatingNodeGroupConfigProcessor) GetScaleDownUnneededTime(nodeGroup cloudprovider.NodeGroup) (time.Duration, error)
  • func (p *DelegatingNodeGroupConfigProcessor) GetScaleDownUnreadyTime(nodeGroup cloudprovider.NodeGroup) (time.Duration, error)
  • func (p *DelegatingNodeGroupConfigProcessor) GetScaleDownUtilizationThreshold(nodeGroup cloudprovider.NodeGroup) (float64, error)
• type NodeGroupConfigProcessor
  • func NewDefaultNodeGroupConfigProcessor(nodeGroupDefaults config.NodeGroupAutoscalingOptions) NodeGroupConfigProcessor

Types

type DelegatingNodeGroupConfigProcessor

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

DelegatingNodeGroupConfigProcessor calls NodeGroup.GetOptions to get config for each NodeGroup. If NodeGroup doesn't return a value default config is used instead.

func (*DelegatingNodeGroupConfigProcessor) CleanUp

func (p *DelegatingNodeGroupConfigProcessor) CleanUp()

CleanUp cleans up processor's internal structures.

func (*DelegatingNodeGroupConfigProcessor) GetIgnoreDaemonSetsUtilization

func (p *DelegatingNodeGroupConfigProcessor) GetIgnoreDaemonSetsUtilization(nodeGroup cloudprovider.NodeGroup) (bool, error)

GetIgnoreDaemonSetsUtilization returns IgnoreDaemonSetsUtilization value that should be used for a given NodeGroup.

func (*DelegatingNodeGroupConfigProcessor) GetMaxNodeProvisionTime

func (p *DelegatingNodeGroupConfigProcessor) GetMaxNodeProvisionTime(nodeGroup cloudprovider.NodeGroup) (time.Duration, error)

GetMaxNodeProvisionTime returns MaxNodeProvisionTime value that should be used for a given NodeGroup.

func (*DelegatingNodeGroupConfigProcessor) GetScaleDownGpuUtilizationThreshold

func (p *DelegatingNodeGroupConfigProcessor) GetScaleDownGpuUtilizationThreshold(nodeGroup cloudprovider.NodeGroup) (float64, error)

GetScaleDownGpuUtilizationThreshold returns ScaleDownGpuUtilizationThreshold value that should be used for a given NodeGroup.

func (*DelegatingNodeGroupConfigProcessor) GetScaleDownUnneededTime

func (p *DelegatingNodeGroupConfigProcessor) GetScaleDownUnneededTime(nodeGroup cloudprovider.NodeGroup) (time.Duration, error)

GetScaleDownUnneededTime returns ScaleDownUnneededTime value that should be used for a given NodeGroup.

func (*DelegatingNodeGroupConfigProcessor) GetScaleDownUnreadyTime

func (p *DelegatingNodeGroupConfigProcessor) GetScaleDownUnreadyTime(nodeGroup cloudprovider.NodeGroup) (time.Duration, error)

GetScaleDownUnreadyTime returns ScaleDownUnreadyTime value that should be used for a given NodeGroup.

func (*DelegatingNodeGroupConfigProcessor) GetScaleDownUtilizationThreshold

func (p *DelegatingNodeGroupConfigProcessor) GetScaleDownUtilizationThreshold(nodeGroup cloudprovider.NodeGroup) (float64, error)

GetScaleDownUtilizationThreshold returns ScaleDownUtilizationThreshold value that should be used for a given NodeGroup.

type NodeGroupConfigProcessor

type NodeGroupConfigProcessor interface {
	// GetScaleDownUnneededTime returns ScaleDownUnneededTime value that should be used for a given NodeGroup.
	GetScaleDownUnneededTime(nodeGroup cloudprovider.NodeGroup) (time.Duration, error)
	// GetScaleDownUnreadyTime returns ScaleDownUnreadyTime value that should be used for a given NodeGroup.
	GetScaleDownUnreadyTime(nodeGroup cloudprovider.NodeGroup) (time.Duration, error)
	// GetScaleDownUtilizationThreshold returns ScaleDownUtilizationThreshold value that should be used for a given NodeGroup.
	GetScaleDownUtilizationThreshold(nodeGroup cloudprovider.NodeGroup) (float64, error)
	// GetScaleDownGpuUtilizationThreshold returns ScaleDownGpuUtilizationThreshold value that should be used for a given NodeGroup.
	GetScaleDownGpuUtilizationThreshold(nodeGroup cloudprovider.NodeGroup) (float64, error)
	// GetMaxNodeProvisionTime return MaxNodeProvisionTime value that should be used for a given NodeGroup.
	GetMaxNodeProvisionTime(nodeGroup cloudprovider.NodeGroup) (time.Duration, error)
	// GetIgnoreDaemonSetsUtilization returns IgnoreDaemonSetsUtilization value that should be used for a given NodeGroup.
	GetIgnoreDaemonSetsUtilization(nodeGroup cloudprovider.NodeGroup) (bool, error)
	// CleanUp cleans up processor's internal structures.
	CleanUp()
}

NodeGroupConfigProcessor provides config values for a particular NodeGroup.

func NewDefaultNodeGroupConfigProcessor

func NewDefaultNodeGroupConfigProcessor(nodeGroupDefaults config.NodeGroupAutoscalingOptions) NodeGroupConfigProcessor

NewDefaultNodeGroupConfigProcessor returns a default instance of NodeGroupConfigProcessor.