Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AnnotationNodeInfoProvider ¶
type AnnotationNodeInfoProvider struct {
// contains filtered or unexported fields
}
AnnotationNodeInfoProvider is a wrapper for MixedTemplateNodeInfoProvider.
func NewAnnotationNodeInfoProvider ¶
func NewAnnotationNodeInfoProvider(t *time.Duration, forceDaemonSets bool) *AnnotationNodeInfoProvider
NewAnnotationNodeInfoProvider returns AnnotationNodeInfoProvider wrapping MixedTemplateNodeInfoProvider.
func NewCustomAnnotationNodeInfoProvider ¶
func NewCustomAnnotationNodeInfoProvider(templateNodeInfoProvider TemplateNodeInfoProvider) *AnnotationNodeInfoProvider
NewCustomAnnotationNodeInfoProvider returns AnnotationNodeInfoProvider wrapping TemplateNodeInfoProvider.
func (*AnnotationNodeInfoProvider) CleanUp ¶
func (p *AnnotationNodeInfoProvider) CleanUp()
CleanUp cleans up processor's internal structures.
func (*AnnotationNodeInfoProvider) Process ¶
func (p *AnnotationNodeInfoProvider) Process(ctx *context.AutoscalingContext, nodes []*apiv1.Node, daemonsets []*appsv1.DaemonSet, taintConfig taints.TaintConfig, currentTime time.Time) (map[string]*framework.NodeInfo, errors.AutoscalerError)
Process returns the nodeInfos set for this cluster.
type AsgTagResourceNodeInfoProvider ¶
type AsgTagResourceNodeInfoProvider struct {
// contains filtered or unexported fields
}
AsgTagResourceNodeInfoProvider is a wrapper for MixedTemplateNodeInfoProvider.
func NewAsgTagResourceNodeInfoProvider ¶
func NewAsgTagResourceNodeInfoProvider(t *time.Duration, forceDaemonSets bool) *AsgTagResourceNodeInfoProvider
NewAsgTagResourceNodeInfoProvider returns AsgTagResourceNodeInfoProvider.
func (*AsgTagResourceNodeInfoProvider) CleanUp ¶
func (p *AsgTagResourceNodeInfoProvider) CleanUp()
CleanUp cleans up processor's internal structures.
func (*AsgTagResourceNodeInfoProvider) Process ¶
func (p *AsgTagResourceNodeInfoProvider) Process(ctx *context.AutoscalingContext, nodes []*apiv1.Node, daemonsets []*appsv1.DaemonSet, taintConfig taints.TaintConfig, currentTime time.Time) (map[string]*framework.NodeInfo, errors.AutoscalerError)
Process returns the nodeInfos set for this cluster.
type MixedTemplateNodeInfoProvider ¶
type MixedTemplateNodeInfoProvider struct {
// contains filtered or unexported fields
}
MixedTemplateNodeInfoProvider build nodeInfos from the cluster's nodes and node groups.
func NewMixedTemplateNodeInfoProvider ¶
func NewMixedTemplateNodeInfoProvider(t *time.Duration, forceDaemonSets bool) *MixedTemplateNodeInfoProvider
NewMixedTemplateNodeInfoProvider returns a NodeInfoProvider processor building NodeInfos from real-world nodes when available, otherwise from node groups templates.
func (*MixedTemplateNodeInfoProvider) CleanUp ¶
func (p *MixedTemplateNodeInfoProvider) CleanUp()
CleanUp cleans up processor's internal structures.
func (*MixedTemplateNodeInfoProvider) Process ¶
func (p *MixedTemplateNodeInfoProvider) Process(ctx *context.AutoscalingContext, nodes []*apiv1.Node, daemonsets []*appsv1.DaemonSet, taintConfig taints.TaintConfig, now time.Time) (map[string]*framework.NodeInfo, caerror.AutoscalerError)
Process returns the nodeInfos set for this cluster
type TemplateNodeInfoProvider ¶
type TemplateNodeInfoProvider interface {
// Process returns a map of nodeInfos for node groups.
Process(ctx *context.AutoscalingContext, nodes []*apiv1.Node, daemonsets []*appsv1.DaemonSet, taintConfig taints.TaintConfig, currentTime time.Time) (map[string]*framework.NodeInfo, errors.AutoscalerError)
// CleanUp cleans up processor's internal structures.
CleanUp()
}
TemplateNodeInfoProvider is provides the initial nodeInfos set.
func NewDefaultTemplateNodeInfoProvider ¶
func NewDefaultTemplateNodeInfoProvider(time *time.Duration, forceDaemonSets bool) TemplateNodeInfoProvider
NewDefaultTemplateNodeInfoProvider returns a default TemplateNodeInfoProvider.
Source Files