estimator

Documentation

Index

• Constants
• func GenerateEstimatorKubeConfigSecretName(karmadaName, estimatorServicePrefix, clusterName string) string
• func GenerateEstimatorName(karmadaName, estimatorServicePrefix, clusterName string) string
• type EstimatorController
  • func NewEstimatorController(karmadaKubeClient clientset.Interface, ...) (*EstimatorController, error)
  • func (ctrl *EstimatorController) EnsureEstimator(ctx context.Context, karmada *installv1alpha1.Karmada, ...) error
  • func (ctrl *EstimatorController) EnsureEstimatorDeployment(ctx context.Context, karmada *installv1alpha1.Karmada, ...) error
  • func (ctrl *EstimatorController) EnsureEstimatorKubeconfigSecret(ctx context.Context, karmada *installv1alpha1.Karmada, ...) error
  • func (ctrl *EstimatorController) EnsureEstimatorService(ctx context.Context, karmada *installv1alpha1.Karmada, ...) error
  • func (ctrl *EstimatorController) KubeConfigFromSecret(ctx context.Context, cluster *clusterv1alpha1.Cluster) (*clientcmdapi.Config, error)
  • func (ctrl *EstimatorController) RemoveEstimator(ctx context.Context, karmada *installv1alpha1.Karmada, ...) error
  • func (ctrl *EstimatorController) Run(ctx context.Context, workers int)

Constants

const (

	// name of the estimator controller finalizer
	EstimatorControllerFinalizerName = "estimator.karmada.install.firefly.io/finalizer"
)

Functions

func GenerateEstimatorKubeConfigSecretName

func GenerateEstimatorKubeConfigSecretName(karmadaName, estimatorServicePrefix, clusterName string) string

GenerateEstimatorKubeConfigName generates the secret name which holds kubeconfig content.

func GenerateEstimatorName

func GenerateEstimatorName(karmadaName, estimatorServicePrefix, clusterName string) string

GenerateEstimatorName generates the gRPC scheduler estimator service name which belongs to a cluster.

Types

type EstimatorController

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

func NewEstimatorController

func NewEstimatorController(
	karmadaKubeClient clientset.Interface,
	karmadaClient karmadaversioned.Interface,
	clusterInformer clusterinformers.ClusterInformer,
	estimatorNamespace string,
	karmadaName string,
	fireflyKubeClient clientset.Interface,
	fireflyKarmadaInformer installinformers.KarmadaInformer,
) (*EstimatorController, error)

NewEstimatorController returns a new *Controller.

func (*EstimatorController) EnsureEstimator

func (ctrl *EstimatorController) EnsureEstimator(ctx context.Context, karmada *installv1alpha1.Karmada, cluster *clusterv1alpha1.Cluster) error

func (*EstimatorController) EnsureEstimatorDeployment

func (ctrl *EstimatorController) EnsureEstimatorDeployment(ctx context.Context, karmada *installv1alpha1.Karmada, cluster *clusterv1alpha1.Cluster) error

func (*EstimatorController) EnsureEstimatorKubeconfigSecret

func (ctrl *EstimatorController) EnsureEstimatorKubeconfigSecret(ctx context.Context, karmada *installv1alpha1.Karmada, cluster *clusterv1alpha1.Cluster) error

func (*EstimatorController) EnsureEstimatorService

func (ctrl *EstimatorController) EnsureEstimatorService(ctx context.Context, karmada *installv1alpha1.Karmada, cluster *clusterv1alpha1.Cluster) error

func (*EstimatorController) KubeConfigFromSecret

func (ctrl *EstimatorController) KubeConfigFromSecret(ctx context.Context, cluster *clusterv1alpha1.Cluster) (*clientcmdapi.Config, error)

func (*EstimatorController) RemoveEstimator

func (ctrl *EstimatorController) RemoveEstimator(ctx context.Context, karmada *installv1alpha1.Karmada, cluster *clusterv1alpha1.Cluster) error

func (*EstimatorController) Run

func (ctrl *EstimatorController) Run(ctx context.Context, workers int)

Run will not return until stopCh is closed. workers determines how many cluster will be handled in parallel.