kubean

Documentation

Index

• Constants
• type ClusterController
  • func NewClusterController(karmadaNamespace string, client clientset.Interface, ...) (*ClusterController, error)
  • func (ctrl *ClusterController) Run(ctx context.Context, workers int)
• type ClusterRefController
  • func NewClusterRefController(client clientset.Interface, clustersInformer informers.GenericInformer, ...) (*ClusterRefController, error)
  • func (ctrl *ClusterRefController) Run(ctx context.Context, workers int)
• type ManifestController
  • func NewManifestController(kubeClient clientset.Interface, dynamicClient dynamic.Interface, ...) (*ManifestController, error)
  • func (ctrl *ManifestController) Run(ctx context.Context, workers int)

Constants

const (

	// name of the cluster controller finalizer
	ClusterControllerFinalizerName = "cluster.kubean.firefly.io/finalizer"
)

Types

type ClusterController

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

func NewClusterController

func NewClusterController(
	karmadaNamespace string,
	client clientset.Interface,
	dynamicClient dynamic.Interface,
	clustersInformer informers.GenericInformer,
	fireflyDynamicClient dynamic.Interface,
	hostClustersInformer informers.GenericInformer) (*ClusterController, error)

NewClusterController returns a new *Controller.

func (*ClusterController) Run

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

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

type ClusterRefController

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

func NewClusterRefController

func NewClusterRefController(
	client clientset.Interface,
	clustersInformer informers.GenericInformer,
	configMapInformer coreinformers.ConfigMapInformer,
	karmadaNamespace string,
	fireflyClient clientset.Interface) (*ClusterRefController, error)

NewClusterRefController returns a new *Controller.

func (*ClusterRefController) Run

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

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

type ManifestController

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

func NewManifestController

func NewManifestController(
	kubeClient clientset.Interface,
	dynamicClient dynamic.Interface,
	manifestInformer informers.GenericInformer,
	hostManifestInformer informers.GenericInformer,
) (*ManifestController, error)

NewManifestController returns a new *Controller.

func (*ManifestController) Run

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

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