karmada

Documentation

Index

• Constants
• func SecretFromSpec(namespace, name string, secretType corev1.SecretType, data map[string]string) *corev1.Secret
• func StaticYamlToJSONByte(staticYaml string) []byte
• type KarmadaController
  • func NewKarmadaController(client clientset.Interface, operatorClient operatorclient.Interface, ...) (*KarmadaController, error)
  • func (ctrl *KarmadaController) EnsureAPIServer(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureControllerManager(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureEtcd(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureEtcdService(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureEtcdStatefulSet(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKaramdaWebhook(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKaramdaWebhookDeployment(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKaramdaWebhookService(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaAggregatedAPIServer(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaAggregatedAPIServerAPIService(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaAggregatedAPIServerDeployment(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaAggregatedAPIServerService(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaCRDs(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaControllerManager(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaControllerManagerDeployment(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaDescheduler(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaDeschedulerDeployment(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaScheduler(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaSchedulerDeployment(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKarmadaWebhookConfiguration(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKubeAPIServer(karmada *operatorapi.Karmada) (kubernetes.Interface, error)
  • func (ctrl *KarmadaController) EnsureKubeAPIServerDeployment(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKubeAPIServerService(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKubeControllerManager(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureKubeControllerManagerDeployment(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureScheduler(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) EnsureWebhook(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) GenerateClientConfig(karmada *operatorapi.Karmada) (*restclient.Config, error)
  • func (ctrl *KarmadaController) RemoveKarmadaDescheduler(karmada *operatorapi.Karmada) error
  • func (ctrl *KarmadaController) Run(ctx context.Context, workers int)

Constants

const (

	// name of the karmada controller finalizer
	KarmadaControllerFinalizerName = "operator.karmada.firefly.io/finalizer"
)

Functions

func SecretFromSpec

func SecretFromSpec(namespace, name string, secretType corev1.SecretType, data map[string]string) *corev1.Secret

func StaticYamlToJSONByte

func StaticYamlToJSONByte(staticYaml string) []byte

StaticYamlToJSONByte Static yaml file conversion JSON Byte

Types

type KarmadaController

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

func NewKarmadaController

func NewKarmadaController(
	client clientset.Interface,
	operatorClient operatorclient.Interface,
	karmadaInformer installinformers.KarmadaInformer) (*KarmadaController, error)

NewKarmadaController returns a new *Controller.

func (*KarmadaController) EnsureAPIServer

func (ctrl *KarmadaController) EnsureAPIServer(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureControllerManager

func (ctrl *KarmadaController) EnsureControllerManager(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureEtcd

func (ctrl *KarmadaController) EnsureEtcd(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureEtcdService

func (ctrl *KarmadaController) EnsureEtcdService(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureEtcdStatefulSet

func (ctrl *KarmadaController) EnsureEtcdStatefulSet(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKaramdaWebhook

func (ctrl *KarmadaController) EnsureKaramdaWebhook(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKaramdaWebhookDeployment

func (ctrl *KarmadaController) EnsureKaramdaWebhookDeployment(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKaramdaWebhookService

func (ctrl *KarmadaController) EnsureKaramdaWebhookService(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaAggregatedAPIServer

func (ctrl *KarmadaController) EnsureKarmadaAggregatedAPIServer(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaAggregatedAPIServerAPIService

func (ctrl *KarmadaController) EnsureKarmadaAggregatedAPIServerAPIService(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaAggregatedAPIServerDeployment

func (ctrl *KarmadaController) EnsureKarmadaAggregatedAPIServerDeployment(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaAggregatedAPIServerService

func (ctrl *KarmadaController) EnsureKarmadaAggregatedAPIServerService(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaCRDs

func (ctrl *KarmadaController) EnsureKarmadaCRDs(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaControllerManager

func (ctrl *KarmadaController) EnsureKarmadaControllerManager(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaControllerManagerDeployment

func (ctrl *KarmadaController) EnsureKarmadaControllerManagerDeployment(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaDescheduler

func (ctrl *KarmadaController) EnsureKarmadaDescheduler(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaDeschedulerDeployment

func (ctrl *KarmadaController) EnsureKarmadaDeschedulerDeployment(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaScheduler

func (ctrl *KarmadaController) EnsureKarmadaScheduler(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaSchedulerDeployment

func (ctrl *KarmadaController) EnsureKarmadaSchedulerDeployment(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKarmadaWebhookConfiguration

func (ctrl *KarmadaController) EnsureKarmadaWebhookConfiguration(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKubeAPIServer

func (ctrl *KarmadaController) EnsureKubeAPIServer(karmada *operatorapi.Karmada) (kubernetes.Interface, error)

EnsureKubeAPIServer ensures the kube-apiserver components exists and returns a kubeclient if it's ready.

func (*KarmadaController) EnsureKubeAPIServerDeployment

func (ctrl *KarmadaController) EnsureKubeAPIServerDeployment(karmada *operatorapi.Karmada) error

EnsureKubeAPIServerDeployment ensures the kube-apiserver deployment exists.

func (*KarmadaController) EnsureKubeAPIServerService

func (ctrl *KarmadaController) EnsureKubeAPIServerService(karmada *operatorapi.Karmada) error

EnsureKubeAPIServerService ensures the kube-apiserver service exists.

func (*KarmadaController) EnsureKubeControllerManager

func (ctrl *KarmadaController) EnsureKubeControllerManager(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureKubeControllerManagerDeployment

func (ctrl *KarmadaController) EnsureKubeControllerManagerDeployment(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureScheduler

func (ctrl *KarmadaController) EnsureScheduler(karmada *operatorapi.Karmada) error

func (*KarmadaController) EnsureWebhook

func (ctrl *KarmadaController) EnsureWebhook(karmada *operatorapi.Karmada) error

func (*KarmadaController) GenerateClientConfig

func (ctrl *KarmadaController) GenerateClientConfig(karmada *operatorapi.Karmada) (*restclient.Config, error)

func (*KarmadaController) RemoveKarmadaDescheduler

func (ctrl *KarmadaController) RemoveKarmadaDescheduler(karmada *operatorapi.Karmada) error

func (*KarmadaController) Run

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

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