federatedhpa

Documentation

Index

• Constants
• type FederatedHPAController
  • func NewFederatedHPAController(kubeClient kubernetes.Interface, fedClient fedclient.Interface, ...) (*FederatedHPAController, error)
  • func (f *FederatedHPAController) HasSynced() bool
  • func (f *FederatedHPAController) IsControllerReady() bool
  • func (f *FederatedHPAController) Run(ctx context.Context)
• type Resource
  • func (r Resource) QualifiedName() common.QualifiedName

Constants

const (
	FederatedHPAControllerName         = "federatedhpa-controller"
	PrefixedFederatedHPAControllerName = common.DefaultPrefix + FederatedHPAControllerName

	EventReasonCentralizedHPANotWork = "CentralizedHPANotWork"
	EventReasonDistributedHPANotWork = "DistributedHPANotWork"

	FederatedHPAMode            = common.DefaultPrefix + "hpa-mode"
	FederatedHPAModeCentralized = "centralized"
	FederatedHPAModeDistributed = "distributed"
	FederatedHPAModeDefault     = ""
)

const (
	PropagationPolicyKind        = "PropagationPolicy"
	ClusterPropagationPolicyKind = "ClusterPropagationPolicy"

	FedHPANotWorkReason = common.DefaultPrefix + "fed-hpa-not-work-reason"

	EventReasonUpdateHPASourceObject = "UpdateHPASourceObject"
	EventReasonUpdateHPAFedObject    = "UpdateHPAFedObject"
)

Types

type FederatedHPAController

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

FederatedHPAController reconciles an HPA object

func NewFederatedHPAController

func NewFederatedHPAController(
	kubeClient kubernetes.Interface,
	fedClient fedclient.Interface,
	dynamicClient dynamic.Interface,
	informerManager informermanager.InformerManager,
	fedObjectInformer fedcorev1a1informers.FederatedObjectInformer,
	propagationPolicyInformer fedcorev1a1informers.PropagationPolicyInformer,
	clusterPropagationPolicyInformer fedcorev1a1informers.ClusterPropagationPolicyInformer,
	metrics stats.Metrics,
	logger klog.Logger,
	workerCount int,
) (*FederatedHPAController, error)

func (*FederatedHPAController) HasSynced

func (f *FederatedHPAController) HasSynced() bool

func (*FederatedHPAController) IsControllerReady

func (f *FederatedHPAController) IsControllerReady() bool

func (*FederatedHPAController) Run

func (f *FederatedHPAController) Run(ctx context.Context)

type Resource

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

func (Resource) QualifiedName

func (r Resource) QualifiedName() common.QualifiedName