Documentation
¶
Index ¶
- func RunOperator(ctx context.Context, kubeconfig *restclient.Config) error
- type AzurePathFixController
- type AzureStackCloudController
- type ClusterOperatorStatusController
- type Controller
- type ImageConfigController
- type ImagePrunerController
- type ImageRegistryCertificatesController
- type MetricsController
- type NodeCADaemonController
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunOperator ¶
func RunOperator(ctx context.Context, kubeconfig *restclient.Config) error
Types ¶
type AzurePathFixController ¶
type AzurePathFixController struct {
// contains filtered or unexported fields
}
func NewAzurePathFixController ¶
func NewAzurePathFixController( kubeconfig *restclient.Config, batchClient batchv1client.BatchV1Interface, operatorClient v1helpers.OperatorClient, jobInformer batchv1informers.JobInformer, imageRegistryConfigInformer imageregistryv1informers.ConfigInformer, infrastructureInformer configv1informers.InfrastructureInformer, secretInformer corev1informers.SecretInformer, proxyInformer configv1informers.ProxyInformer, openshiftConfigInformer corev1informers.ConfigMapInformer, podInformer corev1informers.PodInformer, ) (*AzurePathFixController, error)
func (*AzurePathFixController) Run ¶
func (c *AzurePathFixController) Run(stopCh <-chan struct{})
type AzureStackCloudController ¶
type AzureStackCloudController struct {
// contains filtered or unexported fields
}
func NewAzureStackCloudController ¶
func NewAzureStackCloudController( operatorClient v1helpers.OperatorClient, openshiftConfigInformer corev1informers.ConfigMapInformer, ) (*AzureStackCloudController, error)
func (*AzureStackCloudController) Run ¶
func (c *AzureStackCloudController) Run(ctx context.Context)
type ClusterOperatorStatusController ¶
type ClusterOperatorStatusController struct {
// contains filtered or unexported fields
}
func NewClusterOperatorStatusController ¶
func NewClusterOperatorStatusController( relatedObjects []configv1.ObjectReference, configClient configv1client.ConfigV1Interface, clusterOperatorInformer configv1informers.ClusterOperatorInformer, imageRegistryConfigInformer imageregistryv1informers.ConfigInformer, imagePrunerInformer imageregistryv1informers.ImagePrunerInformer, deploymentInformer appsv1informers.DeploymentInformer, ) (*ClusterOperatorStatusController, error)
func (*ClusterOperatorStatusController) Run ¶
func (c *ClusterOperatorStatusController) Run(stopCh <-chan struct{})
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller keeps track of openshift image registry components.
func NewController ¶
func NewController( eventRecorder events.Recorder, kubeconfig *restclient.Config, kubeClient kubeclient.Interface, configClient configclient.Interface, imageregistryClient imageregistryclient.Interface, routeClient routeclient.Interface, kubeInformerFactory kubeinformers.SharedInformerFactory, openshiftConfigKubeInformerFactory kubeinformers.SharedInformerFactory, openshiftConfigManagedKubeInformerFactory kubeinformers.SharedInformerFactory, kubeSystemKubeInformerFactory kubeinformers.SharedInformerFactory, configInformerFactory configinformers.SharedInformerFactory, regopInformerFactory imageregistryinformers.SharedInformerFactory, routeInformerFactory routeinformers.SharedInformerFactory, ) (*Controller, error)
NewController returns a controller for openshift image registry objects.
This controller keeps track of resources needed in order to have openshift internal registry working.
func (*Controller) Bootstrap ¶
func (c *Controller) Bootstrap() error
Bootstrap registers this operator with OpenShift by creating an appropriate ClusterOperator custom resource. This function also creates the initial configuration for the Image Registry.
func (*Controller) RemoveResources ¶
func (c *Controller) RemoveResources(o *imageregistryv1.Config) error
func (*Controller) Run ¶
func (c *Controller) Run(stopCh <-chan struct{})
Run starts the Controller.
type ImageConfigController ¶
type ImageConfigController struct {
// contains filtered or unexported fields
}
ImageConfigController controls image.config.openshift.io/cluster.
Watches for changes on image registry routes and services, updating the resource status appropriately.
func NewImageConfigController ¶
func NewImageConfigController( configClient configset.ConfigV1Interface, operatorClient v1helpers.OperatorClient, routeInformer routev1informers.RouteInformer, serviceInformer corev1informers.ServiceInformer, ) (*ImageConfigController, error)
func (*ImageConfigController) Run ¶
func (icc *ImageConfigController) Run(stopCh <-chan struct{})
type ImagePrunerController ¶
type ImagePrunerController struct {
// contains filtered or unexported fields
}
ImagePrunerController keeps track of openshift image pruner components.
func NewImagePrunerController ¶
func NewImagePrunerController( kubeClient kubeclient.Interface, imageregistryClient imageregistryclient.Interface, kubeInformerFactory kubeinformers.SharedInformerFactory, regopInformerFactory imageregistryinformers.SharedInformerFactory, imageConfigInformer configv1informers.ImageInformer, ) (*ImagePrunerController, error)
NewImagePrunerController returns a controller for openshift image pruner.
func (*ImagePrunerController) Bootstrap ¶
func (c *ImagePrunerController) Bootstrap() error
Bootstrap creates the initial configuration for the Image Pruner.
func (*ImagePrunerController) Run ¶
func (c *ImagePrunerController) Run(stopCh <-chan struct{})
Run starts the ImagePrunerController.
type ImageRegistryCertificatesController ¶
type ImageRegistryCertificatesController struct {
// contains filtered or unexported fields
}
func NewImageRegistryCertificatesController ¶
func NewImageRegistryCertificatesController( kubeconfig *restclient.Config, coreClient corev1client.CoreV1Interface, operatorClient v1helpers.OperatorClient, configMapInformer corev1informers.ConfigMapInformer, secretInformer corev1informers.SecretInformer, serviceInformer corev1informers.ServiceInformer, imageConfigInformer configv1informers.ImageInformer, infrastructureInformer configv1informers.InfrastructureInformer, openshiftConfigInformer corev1informers.ConfigMapInformer, openshiftConfigManagedInformer corev1informers.ConfigMapInformer, imageRegistryConfigInformer imageregistryv1informers.ConfigInformer, ) (*ImageRegistryCertificatesController, error)
func (*ImageRegistryCertificatesController) Run ¶
func (c *ImageRegistryCertificatesController) Run(stopCh <-chan struct{})
type MetricsController ¶
type MetricsController struct {
// contains filtered or unexported fields
}
MetricsController is a controller that runs from time to time and reports some metrics about the current status of the system.
func NewMetricsController ¶
func NewMetricsController(informer imageinformers.ImageStreamInformer) *MetricsController
NewMetricsController returns a new MetricsController.
func (*MetricsController) Run ¶
func (m *MetricsController) Run(ctx context.Context)
Run starts this controller. Runs the main loop in a separate go routine and bails out when the provided context is finished.
type NodeCADaemonController ¶
type NodeCADaemonController struct {
// contains filtered or unexported fields
}
func NewNodeCADaemonController ¶
func NewNodeCADaemonController( eventRecorder events.Recorder, appsClient appsv1client.AppsV1Interface, operatorClient v1helpers.OperatorClient, daemonSetInformer appsv1informers.DaemonSetInformer, serviceInformer corev1informers.ServiceInformer, ) (*NodeCADaemonController, error)
func (*NodeCADaemonController) Run ¶
func (c *NodeCADaemonController) Run(stopCh <-chan struct{})
Source Files
Click to show internal directories.
Click to hide internal directories.