Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ControlInterface ¶
type ControlInterface interface {
// ReconcileCloudProfile implements the control logic for CloudProfile creation, update, and deletion.
// If an implementation returns a non-nil error, the invocation will be retried using a rate-limited strategy.
// Implementors should sink any errors that they do not wish to trigger a retry, and they may feel free to
// exit exceptionally at any point provided they wish the update to be re-run at a later point in time.
ReconcileCloudProfile(cloudprofile *gardencorev1beta1.CloudProfile, key string) error
}
ControlInterface implements the control logic for reconciling CloudProfiles. It is implemented as an interface to allow for extensions that provide different semantics. Currently, there is only one implementation.
func NewDefaultControl ¶
func NewDefaultControl(clientMap clientmap.ClientMap, shootLister gardencorelisters.ShootLister, recorder record.EventRecorder) ControlInterface
NewDefaultControl returns a new instance of the default implementation ControlInterface that implements the documented semantics for CloudProfiles.
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller controls CloudProfiles.
func NewCloudProfileController ¶
func NewCloudProfileController(clientMap clientmap.ClientMap, k8sGardenCoreInformers gardencoreinformers.SharedInformerFactory, recorder record.EventRecorder) *Controller
NewCloudProfileController takes a Kubernetes client <k8sGardenClient> and a <k8sGardenCoreInformers> for the Garden clusters. It creates and return a new Garden controller to control CloudProfiles.
func (*Controller) CollectMetrics ¶
func (c *Controller) CollectMetrics(ch chan<- prometheus.Metric)
CollectMetrics implements gardenmetrics.ControllerMetricsCollector interface
func (*Controller) Run ¶
func (c *Controller) Run(ctx context.Context, workers int)
Run runs the Controller until the given stop channel can be read from.
func (*Controller) RunningWorkers ¶
func (c *Controller) RunningWorkers() int
RunningWorkers returns the number of running workers.
Source Files